driver

Documentation

Index

• Constants
• Variables
• func NewIpamDriver(client *datastoreClient.Client) ipam.Ipam
• func NewNetworkDriver(client *datastoreClient.Client) 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) AllocateNetwork(request *network.AllocateNetworkRequest) (*network.AllocateNetworkResponse, error)
  • 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) FreeNetwork(request *network.FreeNetworkRequest) 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"

	CalicoLocalAddressSpace  = "CalicoLocalAddressSpace"
	CalicoGlobalAddressSpace = "CalicoGlobalAddressSpace"
)

const CREATE_PROFILES_ENVKEY = "CALICO_LIBNETWORK_CREATE_PROFILES"

const DOCKER_LABEL_PREFIX = "org.projectcalico.label."

const LABEL_ENDPOINTS_ENVKEY = "CALICO_LIBNETWORK_LABEL_ENDPOINTS"

const LABEL_POLL_TIMEOUT_ENVKEY = "CALICO_LIBNETWORK_LABEL_POLL_TIMEOUT"

const VETH_MTU_ENVKEY = "CALICO_LIBNETWORK_VETH_MTU"

Variables

var IFPrefix = "cali"

Functions

func NewIpamDriver

func NewIpamDriver(client *datastoreClient.Client) ipam.Ipam

func NewNetworkDriver

func NewNetworkDriver(client *datastoreClient.Client) 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) AllocateNetwork

func (d NetworkDriver) AllocateNetwork(request *network.AllocateNetworkRequest) (*network.AllocateNetworkResponse, error)

AllocateNetwork is used for swarm-mode support in remote plugins, which Calico's libnetwork-plugin doesn't currently support.

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) FreeNetwork

func (d NetworkDriver) FreeNetwork(request *network.FreeNetworkRequest) error

FreeNetwork is used for swarm-mode support in remote plugins, which Calico's libnetwork-plugin doesn't currently support.

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