ovssubnet

Documentation

Index

• Constants
• func GetNodeIP(nodeName string) (string, error)
• func SetupIptables(ipt iptables.Interface, clusterNetworkCIDR string) error
• type FirewallRule
• type FlowController
• type OvsController
  • func NewController(sub api.SubnetRegistry, hostname string, selfIP string, ready chan struct{}) (*OvsController, error)
  • func NewKubeController(sub api.SubnetRegistry, hostname string, selfIP string, ready chan struct{}) (*OvsController, error)
  • func NewMultitenantController(sub api.SubnetRegistry, hostname string, selfIP string, ready chan struct{}) (*OvsController, error)
  • func (oc *OvsController) AddNode(nodeName string, nodeIP string) error
  • func (oc *OvsController) DeleteNode(nodeName string) error
  • func (oc *OvsController) StartMaster(clusterNetworkCIDR string, clusterBitsPerSubnet uint, ...) error
  • func (oc *OvsController) StartNode(mtu uint) error
  • func (oc *OvsController) Stop()

Constants

const (
	// Maximum VXLAN Network Identifier as per RFC#7348
	MaxVNID = ((1 << 24) - 1)
	// VNID for the admin namespaces
	AdminVNID = uint(0)
)

Functions

func GetNodeIP

func GetNodeIP(nodeName string) (string, error)

func SetupIptables

func SetupIptables(ipt iptables.Interface, clusterNetworkCIDR string) error

Types

type FirewallRule

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

type FlowController

type FlowController interface {
	Setup(localSubnetCIDR, clusterNetworkCIDR, serviceNetworkCIDR string, mtu uint) error

	AddOFRules(nodeIP, nodeSubnetCIDR, localIP string) error
	DelOFRules(nodeIP, localIP string) error

	AddServiceOFRules(netID uint, IP string, protocol api.ServiceProtocol, port uint) error
	DelServiceOFRules(netID uint, IP string, protocol api.ServiceProtocol, port uint) error

	UpdatePod(namespace, podName, containerID string, netID uint) error
}

type OvsController

type OvsController struct {
	VNIDMap map[string]uint

	AdminNamespaces []string
	// contains filtered or unexported fields
}

func NewController

func NewController(sub api.SubnetRegistry, hostname string, selfIP string, ready chan struct{}) (*OvsController, error)

func NewKubeController

func NewKubeController(sub api.SubnetRegistry, hostname string, selfIP string, ready chan struct{}) (*OvsController, error)

func NewMultitenantController

func NewMultitenantController(sub api.SubnetRegistry, hostname string, selfIP string, ready chan struct{}) (*OvsController, error)

func (*OvsController) AddNode

func (oc *OvsController) AddNode(nodeName string, nodeIP string) error

func (*OvsController) DeleteNode

func (oc *OvsController) DeleteNode(nodeName string) error

func (*OvsController) StartMaster

func (oc *OvsController) StartMaster(clusterNetworkCIDR string, clusterBitsPerSubnet uint, serviceNetworkCIDR string) error

func (*OvsController) StartNode

func (oc *OvsController) StartNode(mtu uint) error

func (*OvsController) Stop

func (oc *OvsController) Stop()