daemon

Documentation

Index

• Constants
• Variables
• 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
  • func NewClientMgr(key, secret string) (*ClientMgr, error)
  • func (c *ClientMgr) MetaData() *metadata.MetaData
• type CmdArgs
• type ENIPlugin
  • 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
  • func (eni *ENIService) Allocate(skelArgs *skel.CmdArgs, result *current.Result) error
  • func (eni *ENIService) Release(skelArgs *skel.CmdArgs, result *current.Result) error
• type Pool
  • 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
• type VETHPlugin
  • func (vp *VETHPlugin) Add(args *CmdArgs, result *current.Result) error
  • func (vp *VETHPlugin) Del(args *skel.CmdArgs, result *current.Result) error

Constants

const (
	IPMASQ_CHAIN = "eni-masq"

	DELEGATE_PLUGIN = "host-local"
	DELEGATE_CONF   = `
{
	"ipam": {
		"type": "host-local",
		"subnet": "%s",
		"routes": [
			{ "dst": "0.0.0.0/0" }
		]
	}
}
`
)

const K8S_KUBEADM_CONFIGMAP = "kubeadm-config"

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 KUBERNETES_ALICLOUD_IDENTITY = "Kubernetes.Alicloud"

var (
	LINK_IP = &net.IPNet{
		IP:   net.IPv4(169, 254, 1, 1),
		Mask: net.CIDRMask(32, 32),
	}
)

var ROLE_NAME = "KubernetesMasterRole"

var TOKEN_RESYNC_PERIOD = 5 * time.Minute

Functions

func GetMacAddress

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

func NewRateLimiter

func NewRateLimiter(thro int) *ratelimit

func Run

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

func SetupVethPair

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

func VethNameForWorkload

func VethNameForWorkload(workload string) string

VethNameForWorkload returns a deterministic veth name for the given Kubernetes workload.

Types

type ClientMgr

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

func NewClientMgr

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

func (*ClientMgr) MetaData

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

type CmdArgs

type CmdArgs struct {
	ContainerID string
	Netns       ns.NetNS
	IfName      string
	Args        string
	Path        string
	PodName     string
	PodNS       string
}

type ENIPlugin

type ENIPlugin struct {
	ENI *types.ENI
}

func (*ENIPlugin) Add

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

func (*ENIPlugin) Del

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

func (*ENIPlugin) Get

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

type ENIService

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

func (*ENIService) Allocate

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

func (*ENIService) Release

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

type Pool

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

func (*Pool) Allocate

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

func (*Pool) AvailableNics

func (p *Pool) AvailableNics() int

func (*Pool) RefreshNics

func (p *Pool) RefreshNics() error

func (*Pool) Release

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

type TokenAuth

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

type VETHPlugin

type VETHPlugin struct {
	ENI            *types.ENI
	ServiceAddress *net.IPNet
	Subnet         *net.IPNet
	// contains filtered or unexported fields
}

func (*VETHPlugin) Add

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

func (*VETHPlugin) Del

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