daemon

Jan 23, 2024

Changes in this version

type Kubernetes

+ PodExist func(namespace, name string) (bool, error)

Sep 21, 2023

Changes in this version

type Kubernetes

+ GetClient func() client.Client

Aug 17, 2023

Changes in this version

type Kubernetes

+ GetTrunkID func() string

+ PatchNodeAnnotations func(anno map[string]string) error

+ PatchNodeIPResCondition func(status corev1.ConditionStatus, reason, message string) error

Nov 25, 2022

Changes in this version

+ const IfEth0

type Kubernetes

+ PatchPodIPInfo func(info *types.PodInfo, ips string) error

Jul 25, 2022

Changes in this version

type Kubernetes

+ WaitTrunkReady func() (string, error)

Mar 17, 2022

Changes in this version

+ type AllocCtx struct

+ Trace []Trace

+ func (a *AllocCtx) String() string

+ type Trace struct

+ Msg string

Jan 11, 2022

Changes in this version

type Kubernetes

+ GetPodENIInfo func(info *types.PodInfo) (podEni *podENITypes.PodENI, err error)

Nov 12, 2021

Changes in this version

+ type Item struct

+ Key string

+ Val int

type Kubernetes

+ GetDynamicConfigWithName func(name string) (string, error)

+ GetNodeDynamicConfigLabel func() string

+ GetServiceCIDR func() *types.IPNetSet

+ PatchEipInfo func(info *types.PodInfo) error

+ PatchTrunkInfo func(trunkEni string) error

+ RecordNodeEvent func(eventType, reason, message string)

+ RecordPodEvent func(podName, podNamespace, eventType, reason, message string) error

+ SetCustomStatefulWorkloadKinds func(kinds []string) error

+ SetSvcCidr func(svcCidr *types.IPNetSet) error

+ WaitPodENIInfo func(info *types.PodInfo) (podEni *podENITypes.PodENI, err error)

+ type MapSorter []Item

+ func (ms MapSorter) SortInDescendingOrder()

type ResourceManager

+ Stat func(context *networkContext, resID string) (types.NetworkResource, error)

Mar 20, 2019

Changes in this version

+ const BYTE

+ const DBName

+ const DBPath

+ const DaemonModeENIMultiIP

+ const DaemonModeVPC

+ const GIGABYTE

+ const K8S_KUBEADM_CONFIGMAP_ClusterConfiguration

+ const KILOBYTE

+ const MEGABYTE

+ const PodNetworkTypeENIMultiIP

+ const PodNetworkTypeVPCENI

+ const PodNetworkTypeVPCIP

+ const ResDBName

+ const ResDBPath

+ const TERABYTE

+ var StorageCleanPeriod = 1 * time.Hour

+ func RunDebugServer(debugSocketListen string) error

+ type ENI struct

+ type ENIFactory struct

+ 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 struct

+ type ENIIPFactory struct

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

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

+ type ENIIPResourceManager struct

+ 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 struct

+ 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 interface

+ GetLocalPods func() ([]*podInfo, error)

+ GetNodeCidr func() *net.IPNet

+ GetPod func(namespace, name string) (*podInfo, error)

+ GetServiceCidr func() *net.IPNet

+ SetNodeAllocatablePod func(count int) error

+ type NetworkContext struct

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

+ type NullResourceManager struct

+ 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 struct

+ PodInfo *podInfo

+ Resources []ResourceItem

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

+ type ResourceItem struct

+ ID string

+ Type string

+ type ResourceManager interface

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

+ GarbageCollection func(inUseResList map[string]interface{}, expireResList map[string]interface{}) error

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

+ 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 struct

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

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

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

Nov 21, 2018

Changes in this version

+ const DELEGATE_CONF

+ const DELEGATE_PLUGIN

+ const IPMASQ_CHAIN

+ const K8S_KUBEADM_CONFIGMAP

+ const K8S_KUBEADM_CONFIGMAP_NETWORKING

+ const K8S_POD_NAMESPACE_ARGS

+ const K8S_POD_NAME_ARGS

+ const K8S_SYSTEM_NAMESPACE

+ const POD_EGRESS_BANDWIDTH

+ const POD_INGRESS_BANDWIDTH

+ const POD_NEED_ENI

+ var KUBERNETES_ALICLOUD_IDENTITY = "Kubernetes.Alicloud"

+ var LINK_IP = &net.IPNet

+ var ROLE_NAME = "KubernetesMasterRole"

+ var TOKEN_RESYNC_PERIOD = 5 * time.Minute

+ func GetMacAddress(ifName string, netns ns.NetNS) (string, error)

+ func NewRateLimiter(thro int) *ratelimit

+ func Run(pidFilePath string, socketFilePath string, configFilePath string) error

+ func SetupVethPair(contVethName, pairName string, mtu int, hostNS ns.NetNS) (net.Interface, net.Interface, error)

+ func VethNameForWorkload(workload string) string

+ type ClientMgr struct

+ func NewClientMgr(key, secret string) (*ClientMgr, error)

+ func (c *ClientMgr) MetaData() *metadata.MetaData

+ type CmdArgs struct

+ Args string

+ ContainerID string

+ IfName string

+ Netns ns.NetNS

+ Path string

+ PodNS string

+ PodName string

+ type ENIPlugin struct

+ ENI *types.ENI

+ func (ep *ENIPlugin) Add(args *CmdArgs, result *current.Result) error

+ func (ep *ENIPlugin) Del(args *CmdArgs, result *current.Result) error

+ func (ep *ENIPlugin) Get(args *CmdArgs) (string, error)

+ type ENIService struct

+ func (eni *ENIService) Allocate(skelArgs *skel.CmdArgs, result *current.Result) error

+ func (eni *ENIService) Release(skelArgs *skel.CmdArgs, result *current.Result) error

+ type Pool struct

+ func (p *Pool) Allocate() (*types.ENI, error)

+ func (p *Pool) AvailableNics() int

+ func (p *Pool) RefreshNics() error

+ func (p *Pool) Release(mac string) error

+ type TokenAuth struct

+ type VETHPlugin struct

+ ENI *types.ENI

+ ServiceAddress *net.IPNet

+ Subnet *net.IPNet

+ func (vp *VETHPlugin) Add(args *CmdArgs, result *current.Result) error

+ func (vp *VETHPlugin) Del(args *skel.CmdArgs, result *current.Result) error