allocator

Documentation

Index

• func AllocateIP(ctx context.Context, cli *clientv3.Client, ipHeap *IPHeap, publicKey string) (net.IP, error)
• func LoadAvailableIPs(ctx context.Context, cli *clientv3.Client) ([]net.IP, error)
• func ReleaseIP(ctx context.Context, cli *clientv3.Client, ip net.IP) error
• func RemoveIPFromHeap(ipHeap *IPHeap, ip net.IP)
• func WatchAvailableIPs(ctx context.Context, cli *clientv3.Client, ipHeap *IPHeap)
• type IPAllocator
  • func NewIPAllocator(cidr string) (*IPAllocator, error)
  • func (a *IPAllocator) Allocate() (string, error)
• type IPHeap
  • func (h IPHeap) Len() int
  • func (h IPHeap) Less(i, j int) bool
  • func (h *IPHeap) Pop() interface{}
  • func (h *IPHeap) Push(x interface{})
  • func (h IPHeap) Swap(i, j int)

Functions

func AllocateIP

func AllocateIP(ctx context.Context, cli *clientv3.Client, ipHeap *IPHeap, publicKey string) (net.IP, error)

func LoadAvailableIPs

func LoadAvailableIPs(ctx context.Context, cli *clientv3.Client) ([]net.IP, error)

func ReleaseIP

func ReleaseIP(ctx context.Context, cli *clientv3.Client, ip net.IP) error

func RemoveIPFromHeap

func RemoveIPFromHeap(ipHeap *IPHeap, ip net.IP)

func WatchAvailableIPs

func WatchAvailableIPs(ctx context.Context, cli *clientv3.Client, ipHeap *IPHeap)

Types

type IPAllocator

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

func NewIPAllocator

func NewIPAllocator(cidr string) (*IPAllocator, error)

func (*IPAllocator) Allocate

func (a *IPAllocator) Allocate() (string, error)

type IPHeap

type IPHeap []net.IP

IPHeap implements a min-heap for IP addresses (net.IP)

func (IPHeap) Len

func (h IPHeap) Len() int

func (IPHeap) Less

func (h IPHeap) Less(i, j int) bool

func (*IPHeap) Pop

func (h *IPHeap) Pop() interface{}

func (*IPHeap) Push

func (h *IPHeap) Push(x interface{})

func (IPHeap) Swap

func (h IPHeap) Swap(i, j int)