ippool

Documentation

Index

• func IPResourceFlags(flagset *pflag.FlagSet)
• func NewBBCIPResourceManager(kubeClient kubernetes.Interface, preAttachedENINum int, node *corev1.Node) *bbcIPResourceManager
• func NewBCCIPResourceManager(kubeClient kubernetes.Interface, preAttachedENINum int, node *corev1.Node, ...) *bccIPResourceManager
• func NewCrossVPCEniResourceManager(kubeClient kubernetes.Interface, node *corev1.Node, ...) *crossVPCEniResourceManager
• func NewRangeIPResourceManager(kubeClient kubernetes.Interface, preAttachedENINum int, node *corev1.Node) *rangeIPResourceManager
• type Controller
  • func New(kubeClient kubernetes.Interface, cloudClient cloud.Interface, ...) *Controller
  • func (c *Controller) SyncNode(nodeKey string, nodeLister corelisters.NodeLister) error
• type IPResourceManager

Functions

func IPResourceFlags

func IPResourceFlags(flagset *pflag.FlagSet)

func NewBBCIPResourceManager

func NewBBCIPResourceManager(kubeClient kubernetes.Interface, preAttachedENINum int, node *corev1.Node) *bbcIPResourceManager

func NewBCCIPResourceManager

func NewBCCIPResourceManager(kubeClient kubernetes.Interface, preAttachedENINum int, node *corev1.Node, bccInstance *bccapi.InstanceModel) *bccIPResourceManager

func NewCrossVPCEniResourceManager

func NewCrossVPCEniResourceManager(kubeClient kubernetes.Interface, node *corev1.Node, bccInstance *bccapi.InstanceModel) *crossVPCEniResourceManager

func NewRangeIPResourceManager

func NewRangeIPResourceManager(kubeClient kubernetes.Interface, preAttachedENINum int, node *corev1.Node) *rangeIPResourceManager

Types

type Controller

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

Controller manipulates IPPool CRDs

func New

func New(
	kubeClient kubernetes.Interface,
	cloudClient cloud.Interface,
	crdClient clientset.Interface,
	cniMode ccetypes.ContainerNetworkMode,
	nodeName string,
	instanceID string,
	instanceType metadata.InstanceTypeEx,
	eniSubnetList []string,
	securityGroupList []string,
	enterpriseSecurityGroupList []string,
	preAttachedENINum int,
	podSubnetList []string,
) *Controller

func (*Controller) SyncNode

func (c *Controller) SyncNode(nodeKey string, nodeLister corelisters.NodeLister) error

type IPResourceManager

type IPResourceManager interface {
	SyncCapacity(ctx context.Context) error
}