handlers

Documentation

Index

• type GetAllocatorFunc
• type Handlers
  • func New(poolConfReader poolPkg.ConfigReader, store storePkg.Store, ...) *Handlers
  • func (h *Handlers) Allocate(ctx context.Context, req *nodev1.AllocateRequest) (*nodev1.AllocateResponse, error)
  • func (h *Handlers) Deallocate(ctx context.Context, req *nodev1.DeallocateRequest) (*nodev1.DeallocateResponse, error)
  • func (h *Handlers) IsAllocated(ctx context.Context, req *nodev1.IsAllocatedRequest) (*nodev1.IsAllocatedResponse, error)
• type PoolAlloc

Types

type GetAllocatorFunc

type GetAllocatorFunc = func(s *allocator.RangeSet, poolName string, session storePkg.Session) allocator.IPAllocator

type Handlers

type Handlers struct {
	nodev1.UnsafeIPAMServiceServer
	// contains filtered or unexported fields
}

Handlers contains implementation of the GRPC endpoints handlers for ipam-daemon

func New

func New(poolConfReader poolPkg.ConfigReader, store storePkg.Store, getAllocFunc GetAllocatorFunc) *Handlers

New create and initialize new instance of grpc Handlers

func (*Handlers) Allocate

func (h *Handlers) Allocate(ctx context.Context, req *nodev1.AllocateRequest) (*nodev1.AllocateResponse, error)

Allocate is the handler for Allocate GRPC endpoint

func (*Handlers) Deallocate

func (h *Handlers) Deallocate(
	ctx context.Context, req *nodev1.DeallocateRequest) (*nodev1.DeallocateResponse, error)

Deallocate is the handler for Deallocate GRPC endpoint

func (*Handlers) IsAllocated

func (h *Handlers) IsAllocated(
	ctx context.Context, req *nodev1.IsAllocatedRequest) (*nodev1.IsAllocatedResponse, error)

IsAllocated is the handler for IsAllocated GRPC endpoint

type PoolAlloc

type PoolAlloc struct {
	Pool string
	*current.IPConfig
}

PoolAlloc container which store Pool name and allocation