node

Documentation

Overview

Package node contains the OpenShift SDN networking code that runs on the nodes

Index

• Constants
• func New(c *OsdnNodeConfig) (network.NodeInterface, error)
• func NewMultiTenantPlugin() osdnPolicy
• func NewNetworkPolicyPlugin() osdnPolicy
• func NewOVSController(ovsif ovs.Interface, pluginId int, useConnTrack bool) *ovsController
• func NewSingleTenantPlugin() osdnPolicy
• type Chain
• type NodeIPTables
  • func (n *NodeIPTables) Setup() error
• type OsdnNode
  • func (plugin *OsdnNode) AddHostSubnetRules(subnet *networkapi.HostSubnet)
  • func (plugin *OsdnNode) AddServiceRules(service *kapi.Service, netID uint32)
  • func (plugin *OsdnNode) DeleteHostSubnetRules(subnet *networkapi.HostSubnet)
  • func (plugin *OsdnNode) DeleteServiceRules(service *kapi.Service)
  • func (node *OsdnNode) GetLocalPods(namespace string) ([]kapi.Pod, error)
  • func (plugin *OsdnNode) SetupEgressNetworkPolicy() error
  • func (plugin *OsdnNode) SetupSDN() (bool, error)
  • func (node *OsdnNode) Start() error
  • func (node *OsdnNode) SubnetStartNode() error
  • func (plugin *OsdnNode) UpdateEgressNetworkPolicyVNID(namespace string, oldVnid, newVnid uint32)
  • func (node *OsdnNode) UpdatePod(pod kapi.Pod) error
• type OsdnNodeConfig

Constants

const (
	Br0    = "br0"
	Tun0   = "tun0"
	Vxlan0 = "vxlan0"
)

Functions

func New

func New(c *OsdnNodeConfig) (network.NodeInterface, error)

Called by higher layers to create the plugin SDN node instance

func NewMultiTenantPlugin

func NewMultiTenantPlugin() osdnPolicy

func NewNetworkPolicyPlugin

func NewNetworkPolicyPlugin() osdnPolicy

func NewOVSController

func NewOVSController(ovsif ovs.Interface, pluginId int, useConnTrack bool) *ovsController

func NewSingleTenantPlugin

func NewSingleTenantPlugin() osdnPolicy

Types

type Chain

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

type NodeIPTables

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

func (*NodeIPTables) Setup

func (n *NodeIPTables) Setup() error

type OsdnNode

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

func (*OsdnNode) AddHostSubnetRules

func (plugin *OsdnNode) AddHostSubnetRules(subnet *networkapi.HostSubnet)

func (*OsdnNode) AddServiceRules

func (plugin *OsdnNode) AddServiceRules(service *kapi.Service, netID uint32)

func (*OsdnNode) DeleteHostSubnetRules

func (plugin *OsdnNode) DeleteHostSubnetRules(subnet *networkapi.HostSubnet)

func (*OsdnNode) DeleteServiceRules

func (plugin *OsdnNode) DeleteServiceRules(service *kapi.Service)

func (*OsdnNode) GetLocalPods

func (node *OsdnNode) GetLocalPods(namespace string) ([]kapi.Pod, error)

func (*OsdnNode) SetupEgressNetworkPolicy

func (plugin *OsdnNode) SetupEgressNetworkPolicy() error

func (*OsdnNode) SetupSDN

func (plugin *OsdnNode) SetupSDN() (bool, error)

func (*OsdnNode) Start

func (node *OsdnNode) Start() error

func (*OsdnNode) SubnetStartNode

func (node *OsdnNode) SubnetStartNode() error

func (*OsdnNode) UpdateEgressNetworkPolicyVNID

func (plugin *OsdnNode) UpdateEgressNetworkPolicyVNID(namespace string, oldVnid, newVnid uint32)

func (*OsdnNode) UpdatePod

func (node *OsdnNode) UpdatePod(pod kapi.Pod) error

FIXME: this should eventually go into kubelet via a CNI UPDATE/CHANGE action See https://github.com/containernetworking/cni/issues/89

type OsdnNodeConfig

type OsdnNodeConfig struct {
	PluginName      string
	Hostname        string
	SelfIP          string
	RuntimeEndpoint string
	MTU             uint32
	EnableHostports bool

	NetworkClient networkclient.Interface
	KClient       kclientset.Interface

	KubeInformers kinternalinformers.SharedInformerFactory

	IPTablesSyncPeriod time.Duration
	ProxyMode          componentconfig.ProxyMode
}