driver

Documentation

Index

• Constants
• func NewIpamDriver(client *datastoreClient.Client, logger *log.Logger) ipam.Ipam
• func NewNetworkDriver(client *datastoreClient.Client, logger *log.Logger) network.Driver
• type IpamDriver
  • func (i IpamDriver) GetCapabilities() (*ipam.CapabilitiesResponse, error)
  • func (i IpamDriver) GetDefaultAddressSpaces() (*ipam.AddressSpacesResponse, error)
  • func (i IpamDriver) ReleaseAddress(request *ipam.ReleaseAddressRequest) error
  • func (i IpamDriver) ReleasePool(request *ipam.ReleasePoolRequest) error
  • func (i IpamDriver) RequestAddress(request *ipam.RequestAddressRequest) (*ipam.RequestAddressResponse, error)
  • func (i IpamDriver) RequestPool(request *ipam.RequestPoolRequest) (*ipam.RequestPoolResponse, error)
• type NetworkDriver
  • func (d NetworkDriver) CreateEndpoint(request *network.CreateEndpointRequest) (*network.CreateEndpointResponse, error)
  • func (d NetworkDriver) CreateNetwork(request *network.CreateNetworkRequest) error
  • func (d NetworkDriver) DeleteEndpoint(request *network.DeleteEndpointRequest) error
  • func (d NetworkDriver) DeleteNetwork(request *network.DeleteNetworkRequest) error
  • func (d NetworkDriver) DiscoverDelete(request *network.DiscoveryNotification) error
  • func (d NetworkDriver) DiscoverNew(request *network.DiscoveryNotification) error
  • func (d NetworkDriver) EndpointInfo(request *network.InfoRequest) (*network.InfoResponse, error)
  • func (d NetworkDriver) GetCapabilities() (*network.CapabilitiesResponse, error)
  • func (d NetworkDriver) Join(request *network.JoinRequest) (*network.JoinResponse, error)
  • func (d NetworkDriver) Leave(request *network.LeaveRequest) error
  • func (d NetworkDriver) ProgramExternalConnectivity(*network.ProgramExternalConnectivityRequest) error
  • func (d NetworkDriver) RevokeExternalConnectivity(*network.RevokeExternalConnectivityRequest) error

Constants

const (
	// Calico IPAM module does not allow selection of pools from which to allocate
	// IP addresses.  The pool ID, which has to be supplied in the libnetwork IPAM
	// API is therefore fixed.  We use different values for IPv4 and IPv6 so that
	// during allocation we know which IP version to use.
	PoolIDV4 = "CalicoPoolIPv4"
	PoolIDV6 = "CalicoPoolIPv6"

	CalicoGlobalAddressSpace = "CalicoGlobalAddressSpace"

	IFPrefix = "cali"
)

Functions

func NewIpamDriver

func NewIpamDriver(client *datastoreClient.Client, logger *log.Logger) ipam.Ipam

func NewNetworkDriver

func NewNetworkDriver(client *datastoreClient.Client, logger *log.Logger) network.Driver

Types

type IpamDriver

type IpamDriver struct {
	// contains filtered or unexported fields
}

func (IpamDriver) GetCapabilities

func (i IpamDriver) GetCapabilities() (*ipam.CapabilitiesResponse, error)

func (IpamDriver) GetDefaultAddressSpaces

func (i IpamDriver) GetDefaultAddressSpaces() (*ipam.AddressSpacesResponse, error)

func (IpamDriver) ReleaseAddress

func (i IpamDriver) ReleaseAddress(request *ipam.ReleaseAddressRequest) error

func (IpamDriver) ReleasePool

func (i IpamDriver) ReleasePool(request *ipam.ReleasePoolRequest) error

func (IpamDriver) RequestAddress

func (i IpamDriver) RequestAddress(request *ipam.RequestAddressRequest) (*ipam.RequestAddressResponse, error)

func (IpamDriver) RequestPool

func (i IpamDriver) RequestPool(request *ipam.RequestPoolRequest) (*ipam.RequestPoolResponse, error)

type NetworkDriver

type NetworkDriver struct {
	DummyIPV4Nexthop string
	// contains filtered or unexported fields
}

NetworkDriver is the Calico network driver representation. Must be used with Calico IPAM and supports IPv4 only.

func (NetworkDriver) CreateEndpoint

func (d NetworkDriver) CreateEndpoint(request *network.CreateEndpointRequest) (*network.CreateEndpointResponse, error)

func (NetworkDriver) CreateNetwork

func (d NetworkDriver) CreateNetwork(request *network.CreateNetworkRequest) error

func (NetworkDriver) DeleteEndpoint

func (d NetworkDriver) DeleteEndpoint(request *network.DeleteEndpointRequest) error

func (NetworkDriver) DeleteNetwork

func (d NetworkDriver) DeleteNetwork(request *network.DeleteNetworkRequest) error

func (NetworkDriver) DiscoverDelete

func (d NetworkDriver) DiscoverDelete(request *network.DiscoveryNotification) error

func (NetworkDriver) DiscoverNew

func (d NetworkDriver) DiscoverNew(request *network.DiscoveryNotification) error

func (NetworkDriver) EndpointInfo

func (d NetworkDriver) EndpointInfo(request *network.InfoRequest) (*network.InfoResponse, error)

func (NetworkDriver) GetCapabilities

func (d NetworkDriver) GetCapabilities() (*network.CapabilitiesResponse, error)

func (NetworkDriver) Join

func (d NetworkDriver) Join(request *network.JoinRequest) (*network.JoinResponse, error)

func (NetworkDriver) Leave

func (d NetworkDriver) Leave(request *network.LeaveRequest) error

func (NetworkDriver) ProgramExternalConnectivity

func (d NetworkDriver) ProgramExternalConnectivity(*network.ProgramExternalConnectivityRequest) error

func (NetworkDriver) RevokeExternalConnectivity

func (d NetworkDriver) RevokeExternalConnectivity(*network.RevokeExternalConnectivityRequest) error