route

Documentation

Index

• Constants
• Variables
• type RouteController
  • func NewRouteController(kubeClient kubernetes.Interface, eventRecorder record.EventRecorder, ...) (*RouteController, error)
  • func (rc *RouteController) SyncNode(nodeKey string, nodeLister corelisters.NodeLister) error
• type StaticRouteCache

Constants

const (
	// NodeAnnotationPrefix is the annotation prefix of Node
	NodeAnnotationPrefix = "node.alpha.kubernetes.io/"
	// NodeAnnotationAdvertiseRoute indicates whether to advertise route to vpc route table
	NodeAnnotationAdvertiseRoute = NodeAnnotationPrefix + "advertise-route"
)

Variables

var (
	// ErrNoPodCIDR it may happen when kube-controller-manager not update pod CIDR for a new node that in time.
	ErrNoPodCIDR = errors.New("no pod CIDR found")
	// ErrNoNodeAddress if a node does not have a address
	ErrNoNodeAddress = errors.New("no node address found")
	// ErrInvalidAddress if an IP Address/CIDR not valid
	ErrInvalidAddress = errors.New("invalid IP addr/cidr")
)

Types

type RouteController

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

RouteController manages both vpc and static routes for local host

func NewRouteController

func NewRouteController(
	kubeClient kubernetes.Interface,
	eventRecorder record.EventRecorder,
	cloudClient cloud.Interface,
	crdClient clientset.Interface,
	hostName string,
	instanceID string,
	clusterID string,
	enableVPCRoute bool,
	enableStaticRoute bool,
	containerNetworkCIDRIPv4 string,
	containerNetworkCIDRIPv6 string,
) (*RouteController, error)

func (*RouteController) SyncNode

func (rc *RouteController) SyncNode(nodeKey string, nodeLister corelisters.NodeLister) error

type StaticRouteCache

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