mirror of
https://github.com/moby/moby.git
synced 2026-08-08 09:01:44 +00:00
e5bf6d8ba0
Before that change, we were passing the datastore to network drivers
through a `map[string]interface{}`. Then, each driver that needed the
store would cast the datastore to the correct type.
This was not a good design, as it was not clear which drivers were using
the store and which were not. Not all unit tests were passing the store,
leading to logs about uninitialized store being written.
This change makes the store a parameter of the `RegisterX` functions.
All unit tests are now passing a valid datastore to the drivers. A new
testutil func is added for that purpose.
Signed-off-by: Albin Kerouanton <albinker@gmail.com>
108 lines
2.6 KiB
Go
108 lines
2.6 KiB
Go
//go:build linux
|
|
|
|
package macvlan
|
|
|
|
import (
|
|
"context"
|
|
"net"
|
|
"sync"
|
|
|
|
"github.com/docker/docker/libnetwork/datastore"
|
|
"github.com/docker/docker/libnetwork/driverapi"
|
|
"github.com/docker/docker/libnetwork/scope"
|
|
"github.com/docker/docker/libnetwork/types"
|
|
)
|
|
|
|
const (
|
|
containerVethPrefix = "eth"
|
|
vethPrefix = "veth"
|
|
vethLen = len(vethPrefix) + 7
|
|
NetworkType = "macvlan" // driver type name
|
|
modePrivate = "private" // macvlan mode private
|
|
modeVepa = "vepa" // macvlan mode vepa
|
|
modeBridge = "bridge" // macvlan mode bridge
|
|
modePassthru = "passthru" // macvlan mode passthrough
|
|
parentOpt = "parent" // parent interface -o parent
|
|
driverModeOpt = "macvlan_mode" // macvlan mode ux opt suffix
|
|
)
|
|
|
|
type endpointTable map[string]*endpoint
|
|
|
|
type networkTable map[string]*network
|
|
|
|
type driver struct {
|
|
networks networkTable
|
|
sync.Once
|
|
sync.Mutex
|
|
store *datastore.Store
|
|
}
|
|
|
|
type endpoint struct {
|
|
id string
|
|
nid string
|
|
mac net.HardwareAddr
|
|
addr *net.IPNet
|
|
addrv6 *net.IPNet
|
|
srcName string
|
|
dbIndex uint64
|
|
dbExists bool
|
|
}
|
|
|
|
type network struct {
|
|
id string
|
|
endpoints endpointTable
|
|
driver *driver
|
|
config *configuration
|
|
sync.Mutex
|
|
}
|
|
|
|
// Register initializes and registers the libnetwork macvlan driver
|
|
func Register(r driverapi.Registerer, store *datastore.Store, _ map[string]interface{}) error {
|
|
d := &driver{
|
|
store: store,
|
|
networks: networkTable{},
|
|
}
|
|
if err := d.initStore(); err != nil {
|
|
return err
|
|
}
|
|
return r.RegisterDriver(NetworkType, d, driverapi.Capability{
|
|
DataScope: scope.Local,
|
|
ConnectivityScope: scope.Global,
|
|
})
|
|
}
|
|
|
|
func (d *driver) NetworkAllocate(id string, option map[string]string, ipV4Data, ipV6Data []driverapi.IPAMData) (map[string]string, error) {
|
|
return nil, types.NotImplementedErrorf("not implemented")
|
|
}
|
|
|
|
func (d *driver) NetworkFree(id string) error {
|
|
return types.NotImplementedErrorf("not implemented")
|
|
}
|
|
|
|
func (d *driver) EndpointOperInfo(nid, eid string) (map[string]interface{}, error) {
|
|
return make(map[string]interface{}), nil
|
|
}
|
|
|
|
func (d *driver) Type() string {
|
|
return NetworkType
|
|
}
|
|
|
|
func (d *driver) IsBuiltIn() bool {
|
|
return true
|
|
}
|
|
|
|
func (d *driver) ProgramExternalConnectivity(_ context.Context, nid, eid string, options map[string]interface{}) error {
|
|
return nil
|
|
}
|
|
|
|
func (d *driver) RevokeExternalConnectivity(nid, eid string) error {
|
|
return nil
|
|
}
|
|
|
|
func (d *driver) EventNotify(etype driverapi.EventType, nid, tableName, key string, value []byte) {
|
|
}
|
|
|
|
func (d *driver) DecodeTableEntry(tablename string, key string, value []byte) (string, map[string]string) {
|
|
return "", nil
|
|
}
|