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

• type Closeable
• type LocalPortOpener
• type NodePortData
• type PortTable
  • func NewPortTable(start, end int) (*PortTable, error)
  • func (pt *PortTable) AddRule(podIP string, podPort int) (int, error)
  • func (pt *PortTable) CleanupAllEntries()
  • func (pt *PortTable) DeleteRule(podIP string, podPort int) error
  • func (pt *PortTable) GetDataForPodIP(ip string) []NodePortData
  • func (pt *PortTable) GetEntry(nodeport int) *NodePortData
  • func (pt *PortTable) GetEntryByPodIPPort(ip string, port int) *NodePortData
  • func (pt *PortTable) RuleExists(podIP string, podPort int) bool
  • func (pt *PortTable) SyncRules(allNPLPorts []rules.PodNodePort) error

Types

type Closeable

type Closeable interface {
	Close() error
}

Using Closeable instead of net.Listener makes writing tests easier

type LocalPortOpener

type LocalPortOpener interface {
	OpenLocalPort(port int) (Closeable, error)
}

type NodePortData

type NodePortData struct {
	NodePort int
	PodPort  int
	PodIP    string
	// contains filtered or unexported fields
}

type PortTable

type PortTable struct {
	Table           map[int]NodePortData
	StartPort       int
	EndPort         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) (int, error)

func (*PortTable) CleanupAllEntries

func (pt *PortTable) CleanupAllEntries()

func (*PortTable) DeleteRule

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

func (*PortTable) GetDataForPodIP

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

func (*PortTable) GetEntry

func (pt *PortTable) GetEntry(nodeport int) *NodePortData

func (*PortTable) GetEntryByPodIPPort

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

func (*PortTable) RuleExists

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

func (*PortTable) SyncRules

func (pt *PortTable) SyncRules(allNPLPorts []rules.PodNodePort) error