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

• Constants
• func GetPortTableKey(obj interface{}) (string, error)
• func NodePortIndexFunc(obj interface{}) ([]string, error)
• func NodePortProtoFormat(nodeport int, protocol string) string
• func PodEndpointIndexFunc(obj interface{}) ([]string, error)
• func PodIPIndexFunc(obj interface{}) ([]string, error)
• type LocalPortOpener
• type NodePortData
  • func (d *NodePortData) CloseSockets() error
  • 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

Constants

const (
	NodePortIndex    = "nodePortIndex"
	PodEndpointIndex = "podEndpointIndex"
	PodIPIndex       = "podIPIndex"
)

Functions

func GetPortTableKey

func GetPortTableKey(obj interface{}) (string, error)

func NodePortIndexFunc

func NodePortIndexFunc(obj interface{}) ([]string, error)

func NodePortProtoFormat

func NodePortProtoFormat(nodeport int, protocol string) string

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

func PodEndpointIndexFunc

func PodEndpointIndexFunc(obj interface{}) ([]string, error)

func PodIPIndexFunc

func PodIPIndexFunc(obj interface{}) ([]string, error)

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
	Protocol ProtocolSocketData
}

func (*NodePortData) CloseSockets

func (d *NodePortData) CloseSockets() error

func (*NodePortData) ProtocolInUse

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

type PortTable

type PortTable struct {
	PortTableCache  cache.Indexer
	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
}