bcc

Documentation

Index

• Constants
• func IsFixIPStatefulSetPod(pod *corev1.Pod) bool
• func NewIPAM(kubeClient kubernetes.Interface, crdClient versioned.Interface, ...) (ipamgeneric.Interface, error)
• type IPAM
  • func (ipam *IPAM) Allocate(ctx context.Context, name, namespace, containerID string) (*v1alpha1.WorkloadEndpoint, error)
  • func (ipam *IPAM) FilterIP(ip net.IP) bool
  • func (ipam *IPAM) Ready(_ 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
• type SubnetSelectionPolicy

Constants

const (
	ENIAttachTimeout        int = 50
	ENIAttachMaxRetry       int = 10
	ENIReadyTimeToAttach        = 5 * time.Second
	CreateENIMaxConcurrency     = 15
)

const (
	StsPodAnnotationEnableFixIP       = "cce.io/sts-enable-fix-ip"
	EnableFixIPTrue                   = "True"
	StsPodAnnotationFixIPDeletePolicy = "cce.io/sts-pod-fix-ip-delete-policy"
	FixIPDeletePolicyNever            = "Never"
)

Functions

func IsFixIPStatefulSetPod

func IsFixIPStatefulSetPod(pod *corev1.Pod) bool

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,
	subnetSelectionPolicy SubnetSelectionPolicy,
	ipMutatingRate float64,
	ipMutatingBurst int64,
	idleIPPoolMinSize int,
	idleIPPoolMaxSize int,
	batchAddIPNum int,
	eniSyncPeriod time.Duration,
	gcPeriod time.Duration,
	_ bool,
) (ipamgeneric.Interface, 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.WorkloadEndpoint, error)

func (*IPAM) FilterIP

func (ipam *IPAM) FilterIP(ip net.IP) bool

FilterIP return true if ip was not used

func (*IPAM) Ready

func (ipam *IPAM) Ready(_ 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

type SubnetSelectionPolicy

type SubnetSelectionPolicy string

const (
	SubnetSelectionPolicyLeastENI   SubnetSelectionPolicy = "LeastENI"
	SubnetSelectionPolicyMostFreeIP SubnetSelectionPolicy = "MostFreeIP"
)