rdma

Documentation

Index

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

Functions

func NewIPAM

func NewIPAM(
	vpcID string,
	kubeClient kubernetes.Interface,
	crdClient versioned.Interface,
	bceClient cloud.Interface,
	informerResyncPeriod time.Duration,
	gcPeriod time.Duration,
) (ipamgeneric.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, ipType rpc.IPType) (*v1alpha1.WorkloadEndpoint, error)

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