daemon

Documentation

Index

• Constants
• func Run(...) error
• type ENI
• type ENIIP
• type Item
• type Kubernetes
• type MapSorter
  • func (ms MapSorter) SortInDescendingOrder()
• type ResourceManager

Constants

const (
	BYTE = 1 << (10 * iota)
	KILOBYTE
	MEGABYTE
	GIGABYTE
	TERABYTE
)

bandwidth limit unit

Functions

func Run

func Run(pidFilePath, socketFilePath, debugSocketListen, configFilePath, kubeconfig, master, daemonMode, logLevel string) error

Run terway daemon

Types

type ENI

type ENI struct {
	*types.ENI
	// contains filtered or unexported fields
}

ENI to hold ENI's secondary config

type ENIIP

type ENIIP struct {
	*types.ENIIP
	// contains filtered or unexported fields
}

ENIIP the secondary ip of eni

type Item

type Item struct {
	Key string
	Val int
}

Item is the element type of MapSorter, which contains the values for sorting

type Kubernetes

type Kubernetes interface {
	GetLocalPods() ([]*types.PodInfo, error)
	GetPod(namespace, name string) (*types.PodInfo, error)
	GetServiceCIDR() *types.IPNetSet
	GetNodeCidr() *types.IPNetSet
	SetNodeAllocatablePod(count int) error
	PatchEipInfo(info *types.PodInfo) error
	PatchTrunkInfo(trunkEni string) error
	WaitPodENIInfo(info *types.PodInfo) (podEni *podENITypes.PodENI, err error)
	GetPodENIInfo(info *types.PodInfo) (podEni *podENITypes.PodENI, err error)
	RecordNodeEvent(eventType, reason, message string)
	RecordPodEvent(podName, podNamespace, eventType, reason, message string) error
	GetNodeDynamicConfigLabel() string
	GetDynamicConfigWithName(name string) (string, error)
	SetSvcCidr(svcCidr *types.IPNetSet) error
	SetCustomStatefulWorkloadKinds(kinds []string) error
}

Kubernetes operation set

type MapSorter

type MapSorter []Item

MapSorter is a slice container for sorting

func (MapSorter) SortInDescendingOrder

func (ms MapSorter) SortInDescendingOrder()

SortInDescendingOrder is a bubble sort per element's value

type ResourceManager

type ResourceManager interface {
	Allocate(context *networkContext, prefer string) (types.NetworkResource, error)
	Release(context *networkContext, resItem types.ResourceItem) error
	GarbageCollection(inUseResSet map[string]types.ResourceItem, expireResSet map[string]types.ResourceItem) error
	Stat(context *networkContext, resID string) (types.NetworkResource, error)
	tracing.ResourceMappingHandler
}

ResourceManager Allocate/Release/Pool/Stick/GC pod resource managed pod and resource relationship