Versions in this module Expand all Collapse all 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