crossvpceni

Documentation

Index

• Variables
• func NewIPAM(kubeClient kubernetes.Interface, crdClient versioned.Interface, ...) (ipam.ExclusiveEniInterface, error)
• type IPAM
  • func (ipam *IPAM) Allocate(ctx context.Context, name, namespace, containerID string) (*v1alpha1.CrossVPCEni, error)
  • func (ipam *IPAM) Ready(ctx context.Context) bool
  • func (ipam *IPAM) Release(ctx context.Context, name, namespace, containerID string) (*v1alpha1.CrossVPCEni, error)
  • func (ipam *IPAM) Run(ctx context.Context, stopCh <-chan struct{}) error

Variables

var (
	PodAnnotationCrossVPCEniUserID                          = "cross-vpc-eni.cce.io/userID"
	PodAnnotationCrossVPCEniSubnetID                        = "cross-vpc-eni.cce.io/subnetID"
	PodAnnotationCrossVPCEniSecurityGroupIDs                = "cross-vpc-eni.cce.io/securityGroupIDs"
	PodAnnotationCrossVPCEniPrivateIPAddress                = "cross-vpc-eni.cce.io/privateIPAddress"
	PodAnnotationCrossVPCEniVPCCIDR                         = "cross-vpc-eni.cce.io/vpcCidr"
	PodAnnotationCrossVPCEniDefaultRouteInterfaceDelegation = "cross-vpc-eni.cce.io/defaultRouteInterfaceDelegation"
	PodAnnotationCrossVPCEniDefaultRouteExcludedCidrs       = "cross-vpc-eni.cce.io/defaultRouteExcludedCidrs"

	NodeAnnotationMaxCrossVPCEni = "cross-vpc-eni.cce.io/maxEniNumber"
	NodeLabelMaxCrossVPCEni      = "cross-vpc-eni.cce.io/max-eni-number"

	PodLabelOwnerNamespace = "cce.io/ownerNamespace"
	PodLabelOwnerName      = "cce.io/ownerName"
	PodLabelOwnerNode      = "cce.io/ownerNode"
	PodLabelOwnerInstance  = "cce.io/ownerInstance"
)

Functions

func NewIPAM

func NewIPAM(
	kubeClient kubernetes.Interface,
	crdClient versioned.Interface,
	cniMode types.ContainerNetworkMode,
	vpcID string,
	clusterID string,
	resyncPeriod time.Duration,
	gcPeriod time.Duration,
	debug bool,
) (ipam.ExclusiveEniInterface, error)

Types

type IPAM

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

func (*IPAM) Allocate

func (ipam *IPAM) Allocate(ctx context.Context, name, namespace, containerID string) (*v1alpha1.CrossVPCEni, error)

func (*IPAM) Ready

func (ipam *IPAM) Ready(ctx context.Context) bool

func (*IPAM) Release

func (ipam *IPAM) Release(ctx context.Context, name, namespace, containerID string) (*v1alpha1.CrossVPCEni, error)

func (*IPAM) Run

func (ipam *IPAM) Run(ctx context.Context, stopCh <-chan struct{}) error