bbc

Documentation

Index

• Constants
• func GetPodSpecificSubnetsFromAnnotation(pod *v1.Pod) []string
• func NewIPAM(kubeClient kubernetes.Interface, crdClient versioned.Interface, ...) (ipam.Interface, error)
• func PodNeedsSpecificSubnets(pod *v1.Pod) bool
• type IPAM
  • func (ipam *IPAM) Allocate(ctx context.Context, name, namespace, containerID string) (*v1alpha1.WorkloadEndpoint, error)
  • func (ipam *IPAM) Ready(ctx context.Context) bool
  • func (ipam *IPAM) Release(ctx context.Context, name, namespace, containerID string) (*v1alpha1.WorkloadEndpoint, error)
  • func (ipam *IPAM) Run(ctx context.Context, stopCh <-chan struct{}) error

Constants

const (
	PodAnnotationSpecificSubnets = "cce.io/subnets"
)

Functions

func GetPodSpecificSubnetsFromAnnotation

func GetPodSpecificSubnetsFromAnnotation(pod *v1.Pod) []string

func NewIPAM

func NewIPAM(
	kubeClient kubernetes.Interface,
	crdClient versioned.Interface,
	kubeInformer informers.SharedInformerFactory,
	crdInformer crdinformers.SharedInformerFactory,
	bceClient cloud.Interface,
	cniMode types.ContainerNetworkMode,
	vpcID string,
	clusterID string,
	gcPeriod time.Duration,
	batchAddIPNum int,
	ipMutatingRate float64,
	ipMutatingBurst int64,
	idleIPPoolMinSize int,
	idleIPPoolMaxSize int,
	debug bool,
) (ipam.Interface, error)

func PodNeedsSpecificSubnets

func PodNeedsSpecificSubnets(pod *v1.Pod) bool

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.WorkloadEndpoint, 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.WorkloadEndpoint, error)

func (*IPAM) Run

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