mirror of
https://github.com/moby/moby.git
synced 2026-08-08 00:52:17 +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>
114 lines
2.7 KiB
Go
114 lines
2.7 KiB
Go
//go:build linux
|
|
|
|
package ipvlan
|
|
|
|
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 = "ipvlan" // driver type name
|
|
parentOpt = "parent" // parent interface -o parent
|
|
driverModeOpt = "ipvlan_mode" // mode -o ipvlan_mode
|
|
driverFlagOpt = "ipvlan_flag" // flag -o ipvlan_flag
|
|
|
|
modeL2 = "l2" // ipvlan L2 mode (default)
|
|
modeL3 = "l3" // ipvlan L3 mode
|
|
modeL3S = "l3s" // ipvlan L3S mode
|
|
|
|
flagBridge = "bridge" // ipvlan flag bridge (default)
|
|
flagPrivate = "private" // ipvlan flag private
|
|
flagVepa = "vepa" // ipvlan flag vepa
|
|
)
|
|
|
|
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 ipvlan driver.
|
|
func Register(r driverapi.Registerer, store *datastore.Store, config 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
|
|
}
|