portcache

Documentation

Overview

portcache maintains the state about all current NodePortLocal port mappings for this Node and takes care of configuring the host accordingly.

Index

• func NodePortProtoFormat(nodeport int, protocol string) string
• type LocalPortOpener
• type NodePortData
  • func (d *NodePortData) CloseSockets() error
  • func (d *NodePortData) FindProtocol(protocol string) *ProtocolSocketData
  • func (d *NodePortData) ProtocolInUse(protocol string) bool
• type PortTable
  • func NewPortTable(start, end int) (*PortTable, error)
  • func (pt *PortTable) AddRule(podIP string, podPort int, protocol string) (int, error)
  • func (pt *PortTable) CleanupAllEntries()
  • func (pt *PortTable) DeleteRule(podIP string, podPort int, protocol string) error
  • func (pt *PortTable) DeleteRulesForPod(podIP string) error
  • func (pt *PortTable) GetDataForPodIP(ip string) []NodePortData
  • func (pt *PortTable) GetEntry(ip string, port int, protocol string) *NodePortData
  • func (pt *PortTable) RestoreRules(allNPLPorts []rules.PodNodePort, synced chan<- struct{}) error
  • func (pt *PortTable) RuleExists(podIP string, podPort int, protocol string) bool
• type ProtocolSocketData

Functions

func NodePortProtoFormat

func NodePortProtoFormat(nodeport int, protocol string) string

nodePortProtoFormat formats the nodeport, protocol to string port:protocol.

Types

type LocalPortOpener

type LocalPortOpener interface {
	OpenLocalPort(port int, protocol string) (io.Closer, error)
}

type NodePortData

type NodePortData struct {
	NodePort  int
	PodPort   int
	PodIP     string
	Protocols []ProtocolSocketData
}

func (*NodePortData) CloseSockets

func (d *NodePortData) CloseSockets() error

func (*NodePortData) FindProtocol

func (d *NodePortData) FindProtocol(protocol string) *ProtocolSocketData

func (*NodePortData) ProtocolInUse

func (d *NodePortData) ProtocolInUse(protocol string) bool

type PortTable

type PortTable struct {
	NodePortTable    map[string]*NodePortData
	PodEndpointTable map[string]*NodePortData
	StartPort        int
	EndPort          int
	PortSearchStart  int
	PodPortRules     rules.PodPortRules
	LocalPortOpener  LocalPortOpener
	// contains filtered or unexported fields
}

func NewPortTable

func NewPortTable(start, end int) (*PortTable, error)

func (*PortTable) AddRule

func (pt *PortTable) AddRule(podIP string, podPort int, protocol string) (int, error)

func (*PortTable) CleanupAllEntries

func (pt *PortTable) CleanupAllEntries()

func (*PortTable) DeleteRule

func (pt *PortTable) DeleteRule(podIP string, podPort int, protocol string) error

func (*PortTable) DeleteRulesForPod

func (pt *PortTable) DeleteRulesForPod(podIP string) error

func (*PortTable) GetDataForPodIP

func (pt *PortTable) GetDataForPodIP(ip string) []NodePortData

func (*PortTable) GetEntry

func (pt *PortTable) GetEntry(ip string, port int, protocol string) *NodePortData

func (*PortTable) RestoreRules

func (pt *PortTable) RestoreRules(allNPLPorts []rules.PodNodePort, synced chan<- struct{}) error

RestoreRules should be called at Antrea Agent startup to restore a set of NPL rules. It is non-blocking but takes a channel parameter - synced, which will be closed when the necessary rules have been restored successfully. No other operations should be performed on the PortTable until the channel is closed.

func (*PortTable) RuleExists

func (pt *PortTable) RuleExists(podIP string, podPort int, protocol string) bool

type ProtocolSocketData

type ProtocolSocketData struct {
	Protocol string
	State    protocolSocketState
	// contains filtered or unexported fields
}