ovssubnet

Documentation

Index

• Constants
• func GetNodeIP(nodeName string) (string, error)
• type FlowController
• type OvsController
  • func NewController(sub api.SubnetRegistry, hostname string, selfIP string, ready chan struct{}) (*OvsController, error)
  • func NewDefaultController(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) ServeExistingNodes() error
  • func (oc *OvsController) StartMaster(sync bool, containerNetwork string, containerSubnetLength uint, ...) error
  • func (oc *OvsController) StartNode(sync, skipsetup bool, mtu uint) error
  • func (oc *OvsController) Stop()

Constants

const (
	// Maximum VXLAN Network Identifier as per RFC#7348
	MaxVNID = ((1 << 24) - 1)
)

Functions

func GetNodeIP

func GetNodeIP(nodeName string) (string, error)

Types

type FlowController

type FlowController interface {
	Setup(localSubnetIP, globalSubnetIP, serviceSubnetIP string, mtu uint) error
	AddOFRules(nodeIP, localSubnetIP, 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
}

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 NewDefaultController

func NewDefaultController(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) ServeExistingNodes

func (oc *OvsController) ServeExistingNodes() error

func (*OvsController) StartMaster

func (oc *OvsController) StartMaster(sync bool, containerNetwork string, containerSubnetLength uint, serviceNetwork string) error

func (*OvsController) StartNode

func (oc *OvsController) StartNode(sync, skipsetup bool, mtu uint) error

func (*OvsController) Stop

func (oc *OvsController) Stop()