multipool

Documentation

Index

• Variables
• type Allocator
  • func (a *Allocator) DeletePool(ctx context.Context, pool *cilium_v2alpha1.CiliumPodIPPool) error
  • func (a *Allocator) Init(ctx context.Context) error
  • func (a *Allocator) Start(ctx context.Context, getterUpdater ipam.CiliumNodeGetterUpdater) (allocator.NodeEventHandler, error)
  • func (a *Allocator) UpsertPool(ctx context.Context, pool *cilium_v2alpha1.CiliumPodIPPool) error
• type NodeHandler
  • func NewNodeHandler(manager *PoolAllocator, nodeUpdater ipam.CiliumNodeGetterUpdater) *NodeHandler
  • func (n *NodeHandler) Delete(resource *v2.CiliumNode)
  • func (n *NodeHandler) Resync(context.Context, time.Time)
  • func (n *NodeHandler) Upsert(resource *v2.CiliumNode)
• type PoolAllocator
  • func NewPoolAllocator() *PoolAllocator
  • func (p *PoolAllocator) AllocateToNode(cn *v2.CiliumNode) error
  • func (p *PoolAllocator) AllocatedPools(targetNode string) (pools []types.IPAMPoolAllocation)
  • func (p *PoolAllocator) DeletePool(poolName string) error
  • func (p *PoolAllocator) ReleaseNode(nodeName string) error
  • func (p *PoolAllocator) RestoreFinished()
  • func (p *PoolAllocator) UpsertPool(poolName string, ipv4CIDRs []string, ipv4MaskSize int, ipv6CIDRs []string, ...) error

Variables

var ErrAllocatorNotReady = errAllocatorNotReady{}

Types

type Allocator

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

Allocator implements allocator.AllocatorProvider

func (*Allocator) DeletePool

func (a *Allocator) DeletePool(ctx context.Context, pool *cilium_v2alpha1.CiliumPodIPPool) error

func (*Allocator) Init

func (a *Allocator) Init(ctx context.Context) error

func (*Allocator) Start

func (a *Allocator) Start(ctx context.Context, getterUpdater ipam.CiliumNodeGetterUpdater) (allocator.NodeEventHandler, error)

func (*Allocator) UpsertPool

func (a *Allocator) UpsertPool(ctx context.Context, pool *cilium_v2alpha1.CiliumPodIPPool) error

type NodeHandler

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

func NewNodeHandler

func NewNodeHandler(manager *PoolAllocator, nodeUpdater ipam.CiliumNodeGetterUpdater) *NodeHandler

func (*NodeHandler) Delete

func (n *NodeHandler) Delete(resource *v2.CiliumNode)

func (*NodeHandler) Resync

func (n *NodeHandler) Resync(context.Context, time.Time)

func (*NodeHandler) Upsert

func (n *NodeHandler) Upsert(resource *v2.CiliumNode)

type PoolAllocator

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

func NewPoolAllocator

func NewPoolAllocator() *PoolAllocator

func (*PoolAllocator) AllocateToNode

func (p *PoolAllocator) AllocateToNode(cn *v2.CiliumNode) error

func (*PoolAllocator) AllocatedPools

func (p *PoolAllocator) AllocatedPools(targetNode string) (pools []types.IPAMPoolAllocation)

func (*PoolAllocator) DeletePool

func (p *PoolAllocator) DeletePool(poolName string) error

DeletePool deletes a pool from p. No new allocations to nodes will be made from the pool and all internal bookkeeping is removed. However, nodes will still retain their in-flight CIDRs until next time the respective CiliumNode is updated.

func (*PoolAllocator) ReleaseNode

func (p *PoolAllocator) ReleaseNode(nodeName string) error

func (*PoolAllocator) RestoreFinished

func (p *PoolAllocator) RestoreFinished()

func (*PoolAllocator) UpsertPool

func (p *PoolAllocator) UpsertPool(poolName string, ipv4CIDRs []string, ipv4MaskSize int, ipv6CIDRs []string, ipv6MaskSize int) error