Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

daemon

package

Go to main page

Versions in this module

v1

v1.0.10

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

v0

v0.1.0

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