daemon

Documentation

Index

• Constants
• Variables
• func Run(pidFilePath string, socketFilePath string, debugSocketListen string, ...) error
• func RunDebugServer(debugSocketListen string) error
• type ENI
• type ENIFactory
  • func NewENIFactory(poolConfig *types.PoolConfig, ecs aliyun.ECS) (*ENIFactory, error)
  • func (f *ENIFactory) Create() (types.NetworkResource, error)
  • func (f *ENIFactory) Dispose(resource types.NetworkResource) error
• type ENIIP
• type ENIIPFactory
  • func (f *ENIIPFactory) Create() (ip types.NetworkResource, err error)
  • func (f *ENIIPFactory) Dispose(res types.NetworkResource) (err error)
• type ENIIPResourceManager
  • func (m *ENIIPResourceManager) Allocate(ctx *NetworkContext, prefer string) (types.NetworkResource, error)
  • func (m *ENIIPResourceManager) GarbageCollection(inUseSet map[string]interface{}, expireResSet map[string]interface{}) error
  • func (m *ENIIPResourceManager) Release(context *NetworkContext, resId string) error
• type ENIResourceManager
  • func (m *ENIResourceManager) Allocate(ctx *NetworkContext, prefer string) (types.NetworkResource, error)
  • func (m *ENIResourceManager) GarbageCollection(inUseSet map[string]interface{}, expireResSet map[string]interface{}) error
  • func (m *ENIResourceManager) Release(context *NetworkContext, resId string) error
• type Kubernetes
• type NetworkContext
  • func (networkContext *NetworkContext) Log() *logrus.Entry
• type NullResourceManager
  • func (NullResourceManager) Allocate(context *NetworkContext, prefer string) (types.NetworkResource, error)
  • func (NullResourceManager) GarbageCollection(inUseResList []string, expireResList []string) error
  • func (NullResourceManager) Release(context *NetworkContext, resId string) error
• type PodResources
  • func (p PodResources) GetResourceItemByType(resType string) []ResourceItem
• type ResourceItem
• type ResourceManager
  • func NewENIIPResourceManager(poolConfig *types.PoolConfig, ecs aliyun.ECS, allocatedResources []string) (ResourceManager, error)
  • func NewENIResourceManager(poolConfig *types.PoolConfig, ecs aliyun.ECS, allocatedResource []string) (ResourceManager, error)
  • func NewVPCResourceManager() (ResourceManager, error)
• type VethResourceManager
  • func (*VethResourceManager) Allocate(context *NetworkContext, prefer string) (types.NetworkResource, error)
  • func (f *VethResourceManager) GarbageCollection(inUseSet map[string]interface{}, expireResSet map[string]interface{}) error
  • func (*VethResourceManager) Release(context *NetworkContext, resId string) error

Constants

const (
	DaemonModeVPC        = "VPC"
	DaemonModeENIMultiIP = "ENIMultiIP"
)

const (
	PodNetworkTypeVPCIP      = "VPCIP"
	PodNetworkTypeVPCENI     = "VPCENI"
	PodNetworkTypeENIMultiIP = "ENIMultiIP"
	DBPath                   = "/var/lib/cni/terway/pod.db"
	DBName                   = "pods"
)

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

const (
	ResDBPath = "/var/lib/cni/terway/ResRelation.db"
	ResDBName = "relation"
)

const K8S_KUBEADM_CONFIGMAP = "kubeadm-config"

const K8S_KUBEADM_CONFIGMAP_ClusterConfiguration = "ClusterConfiguration"

const K8S_KUBEADM_CONFIGMAP_NETWORKING = "MasterConfiguration"

const K8S_POD_NAMESPACE_ARGS = "K8S_POD_NAMESPACE"

const K8S_POD_NAME_ARGS = "K8S_POD_NAME"

const K8S_SYSTEM_NAMESPACE = "kube-system"

const POD_EGRESS_BANDWIDTH = "k8s.aliyun.com/egress-bandwidth"

const POD_INGRESS_BANDWIDTH = "k8s.aliyun.com/ingress-bandwidth"

const POD_NEED_ENI = "k8s.aliyun.com/eni"

Variables

var StorageCleanPeriod = 1 * time.Hour

Functions

func Run

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

func RunDebugServer

func RunDebugServer(debugSocketListen string) error

Types

type ENI

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

type ENIFactory

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

func NewENIFactory

func NewENIFactory(poolConfig *types.PoolConfig, ecs aliyun.ECS) (*ENIFactory, error)

func (*ENIFactory) Create

func (f *ENIFactory) Create() (types.NetworkResource, error)

func (*ENIFactory) Dispose

func (f *ENIFactory) Dispose(resource types.NetworkResource) error

type ENIIP

type ENIIP struct {
	*types.ENIIP
}

type ENIIPFactory

type ENIIPFactory struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*ENIIPFactory) Create

func (f *ENIIPFactory) Create() (ip types.NetworkResource, err error)

func (*ENIIPFactory) Dispose

func (f *ENIIPFactory) Dispose(res types.NetworkResource) (err error)

type ENIIPResourceManager

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

func (*ENIIPResourceManager) Allocate

func (m *ENIIPResourceManager) Allocate(ctx *NetworkContext, prefer string) (types.NetworkResource, error)

func (*ENIIPResourceManager) GarbageCollection

func (m *ENIIPResourceManager) GarbageCollection(inUseSet map[string]interface{}, expireResSet map[string]interface{}) error

func (*ENIIPResourceManager) Release

func (m *ENIIPResourceManager) Release(context *NetworkContext, resId string) error

type ENIResourceManager

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

func (*ENIResourceManager) Allocate

func (m *ENIResourceManager) Allocate(ctx *NetworkContext, prefer string) (types.NetworkResource, error)

func (*ENIResourceManager) GarbageCollection

func (m *ENIResourceManager) GarbageCollection(inUseSet map[string]interface{}, expireResSet map[string]interface{}) error

func (*ENIResourceManager) Release

func (m *ENIResourceManager) Release(context *NetworkContext, resId string) error

type Kubernetes

type Kubernetes interface {
	GetLocalPods() ([]*podInfo, error)
	GetPod(namespace, name string) (*podInfo, error)
	GetServiceCidr() *net.IPNet
	GetNodeCidr() *net.IPNet
	SetNodeAllocatablePod(count int) error
}

type NetworkContext

type NetworkContext struct {
	context.Context
	// contains filtered or unexported fields
}

func (*NetworkContext) Log

func (networkContext *NetworkContext) Log() *logrus.Entry

type NullResourceManager

type NullResourceManager struct {
}

func (NullResourceManager) Allocate

func (NullResourceManager) Allocate(context *NetworkContext, prefer string) (types.NetworkResource, error)

func (NullResourceManager) GarbageCollection

func (NullResourceManager) GarbageCollection(inUseResList []string, expireResList []string) error

func (NullResourceManager) Release

func (NullResourceManager) Release(context *NetworkContext, resId string) error

type PodResources

type PodResources struct {
	Resources []ResourceItem
	PodInfo   *podInfo
	// contains filtered or unexported fields
}

func (PodResources) GetResourceItemByType

func (p PodResources) GetResourceItemByType(resType string) []ResourceItem

type ResourceItem

type ResourceItem struct {
	Type string `json:"type"`
	ID   string `json:"id"`
}

type ResourceManager

type ResourceManager interface {
	Allocate(context *NetworkContext, prefer string) (types.NetworkResource, error)
	Release(context *NetworkContext, resId string) error
	GarbageCollection(inUseResList map[string]interface{}, expireResList map[string]interface{}) error
}

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

func NewENIIPResourceManager

func NewENIIPResourceManager(poolConfig *types.PoolConfig, ecs aliyun.ECS, allocatedResources []string) (ResourceManager, error)

func NewENIResourceManager

func NewENIResourceManager(poolConfig *types.PoolConfig, ecs aliyun.ECS, allocatedResource []string) (ResourceManager, error)

func NewVPCResourceManager

func NewVPCResourceManager() (ResourceManager, error)

type VethResourceManager

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

func (*VethResourceManager) Allocate

func (*VethResourceManager) Allocate(context *NetworkContext, prefer string) (types.NetworkResource, error)

func (*VethResourceManager) GarbageCollection

func (f *VethResourceManager) GarbageCollection(inUseSet map[string]interface{}, expireResSet map[string]interface{}) error

func (*VethResourceManager) Release

func (*VethResourceManager) Release(context *NetworkContext, resId string) error