nodemanager

Documentation

Index

• Constants
• Variables
• type Node
• type NodeManager
  • func New(c cache.Cache, vgName, labelKey, labelValue string) *NodeManager
  • func (m *NodeManager) AddNode(k8snode *corev1.Node)
  • func (m *NodeManager) Allocate(name string, size uint64) error
  • func (m *NodeManager) DeleteNode(name string)
  • func (m *NodeManager) GetNodes() []Node
  • func (m *NodeManager) GetNodesHasFreeSize(size uint64) []string
  • func (m *NodeManager) OnCreate(e event.CreateEvent) (handler.Result, error)
  • func (m *NodeManager) OnDelete(e event.DeleteEvent) (handler.Result, error)
  • func (m *NodeManager) OnGeneric(e event.GenericEvent) (handler.Result, error)
  • func (m *NodeManager) OnUpdate(e event.UpdateEvent) (handler.Result, error)
  • func (m *NodeManager) Release(name string, size uint64) error
• type VGSizeGetter

Constants

const (
	ZkeInternalIPAnnKey = "zdnscloud.cn/internal-ip"
)

Variables

var (
	ErrVGNotExist        = errors.New("vg doesn't exist")
	ErrUnknownNode       = errors.New("unknown node")
	ErrNoEnoughFreeSpace = errors.New("no node with enough size")

	ConnectTimeout = 3 * time.Second
)

Types

type Node

type Node struct {
	Name     string
	Addr     string
	Size     uint64
	FreeSize uint64
}

type NodeManager

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

func New

func New(c cache.Cache, vgName, labelKey, labelValue string) *NodeManager

func (*NodeManager) AddNode

func (m *NodeManager) AddNode(k8snode *corev1.Node)

func (*NodeManager) Allocate

func (m *NodeManager) Allocate(name string, size uint64) error

func (*NodeManager) DeleteNode

func (m *NodeManager) DeleteNode(name string)

func (*NodeManager) GetNodes

func (m *NodeManager) GetNodes() []Node

func (*NodeManager) GetNodesHasFreeSize

func (m *NodeManager) GetNodesHasFreeSize(size uint64) []string

func (*NodeManager) OnCreate

func (m *NodeManager) OnCreate(e event.CreateEvent) (handler.Result, error)

func (*NodeManager) OnDelete

func (m *NodeManager) OnDelete(e event.DeleteEvent) (handler.Result, error)

func (*NodeManager) OnGeneric

func (m *NodeManager) OnGeneric(e event.GenericEvent) (handler.Result, error)

func (*NodeManager) OnUpdate

func (m *NodeManager) OnUpdate(e event.UpdateEvent) (handler.Result, error)

func (*NodeManager) Release

func (m *NodeManager) Release(name string, size uint64) error

type VGSizeGetter

type VGSizeGetter func(string, string) (uint64, uint64, error)