roce

Documentation

Index

• func NewIPAM(kubeClient kubernetes.Interface, crdClient versioned.Interface, ...) (ipam.RoceInterface, error)
• type IPAM
  • func (ipam *IPAM) Allocate(ctx context.Context, name, namespace, containerID string, mac string) (*v1alpha1.WorkloadEndpoint, error)
  • func (ipam *IPAM) DeleteNodeFromCache(node *v1.Node) 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

Functions

func NewIPAM

func NewIPAM(
	kubeClient kubernetes.Interface,
	crdClient versioned.Interface,
	bceClient cloud.Interface,
	informerResyncPeriod time.Duration,
	eniSyncPeriod time.Duration,
	gcPeriod time.Duration,
	debug bool,
) (ipam.RoceInterface, 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, mac string) (*v1alpha1.WorkloadEndpoint, error)

func (*IPAM) DeleteNodeFromCache

func (ipam *IPAM) DeleteNodeFromCache(node *v1.Node) 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