portcache

Documentation

Index

• type NodePortData
• type PortTable
  • func NewPortTable(start, end int) (*PortTable, bool)
  • func (pt *PortTable) AddRule(podIP string, podPort int) (int, error)
  • func (pt *PortTable) AddUpdateEntry(nodeport, podport int, podip string)
  • func (pt *PortTable) CleanupAllEntries()
  • func (pt *PortTable) DeleteEntry(nodeport int)
  • func (pt *PortTable) DeleteEntryByPodIP(ip string)
  • func (pt *PortTable) DeleteEntryByPodIPPort(ip string, port int)
  • 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

Types

type NodePortData

type NodePortData struct {
	NodePort int
	PodPort  int
	PodIP    string
	Status   int
}

type PortTable

type PortTable struct {
	Table        map[int]NodePortData
	StartPort    int
	EndPort      int
	PodPortRules rules.PodPortRules
	// contains filtered or unexported fields
}

func NewPortTable

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

func (*PortTable) AddRule

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

func (*PortTable) AddUpdateEntry

func (pt *PortTable) AddUpdateEntry(nodeport, podport int, podip string)

func (*PortTable) CleanupAllEntries

func (pt *PortTable) CleanupAllEntries()

func (*PortTable) DeleteEntry

func (pt *PortTable) DeleteEntry(nodeport int)

func (*PortTable) DeleteEntryByPodIP

func (pt *PortTable) DeleteEntryByPodIP(ip string)

func (*PortTable) DeleteEntryByPodIPPort

func (pt *PortTable) DeleteEntryByPodIPPort(ip string, port int)

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