allocator

Documentation

Index

• func SetupAllocator(conf conf.PoolConf)
• type Allocator
  • func (a *Allocator) AllocHostNic(args *rpc.PodInfo) (*rpc.HostNic, error)
  • func (a *Allocator) CleanDeletingMark(nicID string)
  • func (a *Allocator) CreateVIPs(vxNetID, IPStart, IPEnd, namespace, NADName string) error
  • func (a *Allocator) FreeHostNic(args *rpc.PodInfo, vxNetID string) (*rpc.HostNic, error)
  • func (a *Allocator) GetCurrentNodePods() map[string]bool
  • func (a *Allocator) GetNicStat(args *rpc.NicStatMessage) int32
  • func (a *Allocator) IsDeleting(nicID string) bool
  • func (a *Allocator) MarkToDelete(nicID string)
  • func (a *Allocator) Start(stopCh <-chan struct{}) error
  • func (a *Allocator) SyncHostNic(node bool)
  • func (a *Allocator) TryToFreeVxNetVIPs(NADName, namespace string)
• type VipJobInfo

Functions

func SetupAllocator

func SetupAllocator(conf conf.PoolConf)

Types

type Allocator

type Allocator struct {
	StopCh <-chan struct{}
	// contains filtered or unexported fields
}

var (
	Alloc *Allocator
)

func (*Allocator) AllocHostNic

func (a *Allocator) AllocHostNic(args *rpc.PodInfo) (*rpc.HostNic, error)

func (*Allocator) CleanDeletingMark

func (a *Allocator) CleanDeletingMark(nicID string)

func (*Allocator) CreateVIPs

func (a *Allocator) CreateVIPs(vxNetID, IPStart, IPEnd, namespace, NADName string) error

func (*Allocator) FreeHostNic

func (a *Allocator) FreeHostNic(args *rpc.PodInfo, vxNetID string) (*rpc.HostNic, error)

func (*Allocator) GetCurrentNodePods

func (a *Allocator) GetCurrentNodePods() map[string]bool

func (*Allocator) GetNicStat

func (a *Allocator) GetNicStat(args *rpc.NicStatMessage) int32

func (*Allocator) IsDeleting

func (a *Allocator) IsDeleting(nicID string) bool

func (*Allocator) MarkToDelete

func (a *Allocator) MarkToDelete(nicID string)

func (*Allocator) Start

func (a *Allocator) Start(stopCh <-chan struct{}) error

func (*Allocator) SyncHostNic

func (a *Allocator) SyncHostNic(node bool)

func (*Allocator) TryToFreeVxNetVIPs

func (a *Allocator) TryToFreeVxNetVIPs(NADName, namespace string)

type VipJobInfo

type VipJobInfo struct {
	VxNetID   string
	IPStart   string
	IPEnd     string
	Namespace string
	VIPs      []string
	NADName   string
}