grpc

Documentation

Index

• type ENIIPAMGrpcServer
  • func New(bccipam ipam.Interface, bbcipam ipam.Interface, ...) *ENIIPAMGrpcServer
  • func (cb *ENIIPAMGrpcServer) AllocateIP(ctx context.Context, req *rpc.AllocateIPRequest) (*rpc.AllocateIPReply, error)
  • func (cb *ENIIPAMGrpcServer) CheckIP(ctx context.Context, req *rpc.CheckIPRequest) (*rpc.CheckIPReply, error)
  • func (cb *ENIIPAMGrpcServer) ReleaseIP(ctx context.Context, req *rpc.ReleaseIPRequest) (*rpc.ReleaseIPReply, error)
  • func (cb *ENIIPAMGrpcServer) RunRPCHandler(ctx context.Context) error
• type Interface

Types

type ENIIPAMGrpcServer

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

func New

func New(
	bccipam ipam.Interface,
	bbcipam ipam.Interface,
	eniipam ipam.ExclusiveEniInterface,
	roceipamd ipam.RoceInterface,
	port int,
	allocLimit int,
	releaseLimit int,
	debug bool,
) *ENIIPAMGrpcServer

func (*ENIIPAMGrpcServer) AllocateIP

func (cb *ENIIPAMGrpcServer) AllocateIP(ctx context.Context, req *rpc.AllocateIPRequest) (*rpc.AllocateIPReply, error)

func (*ENIIPAMGrpcServer) CheckIP

func (cb *ENIIPAMGrpcServer) CheckIP(ctx context.Context, req *rpc.CheckIPRequest) (*rpc.CheckIPReply, error)

func (*ENIIPAMGrpcServer) ReleaseIP

func (cb *ENIIPAMGrpcServer) ReleaseIP(ctx context.Context, req *rpc.ReleaseIPRequest) (*rpc.ReleaseIPReply, error)

func (*ENIIPAMGrpcServer) RunRPCHandler

func (cb *ENIIPAMGrpcServer) RunRPCHandler(ctx context.Context) error

type Interface

type Interface interface {
	RunRPCHandler(context.Context) error
}