conntrack

Documentation

Index

• func IsClearConntrackNeeded(proto v1.Protocol) bool
• type Conntrack
  • func New() Conntrack
  • func (ct Conntrack) Callback(ch <-chan *client.ServiceEndpoints)
• type Flow
  • func (f Flow) Key() string
• type IPPort
  • func (i IPPort) Key() string
• type IPPortLeaf
• type Leaf
• type Sink
  • func NewSink() *Sink
  • func (ps *Sink) DeleteEndpoint(namespace, serviceName, key string)
  • func (ps *Sink) DeleteService(namespace, name string)
  • func (ps *Sink) Reset()
  • func (ps *Sink) SetEndpoint(namespace, serviceName, key string, endpoint *localv1.Endpoint)
  • func (ps *Sink) SetService(svc *localv1.Service)
  • func (ps *Sink) Setup()
  • func (s *Sink) Sync()

Examples

• Conntrack

Functions

func IsClearConntrackNeeded

func IsClearConntrackNeeded(proto v1.Protocol) bool

IsClearConntrackNeeded returns true if protocol requires conntrack cleanup for the stale connections

Types

type Conntrack

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

Example

Output:

-- initial state --
/bin/conntrack [-D -p tcp --dport 80 --orig-dst 10.1.1.1]
/bin/conntrack [-D -p udp --dport 53 --orig-dst 10.1.1.1]
-- add one endpoint --
-- remove one endpoint --
/bin/conntrack [-D -p udp --dport 53 --dst-nat 10.1.3.1 --orig-dst 10.1.1.1]
-- remove one service --
/bin/conntrack [-D -p udp --dport 53 --dst-nat 10.1.2.1 --orig-dst 10.1.1.1]

func New

func New() Conntrack

func (Conntrack) Callback

func (ct Conntrack) Callback(ch <-chan *client.ServiceEndpoints)

type Flow

type Flow struct {
	IPPort
	EndpointIP string
	TargetPort int32
}

func (Flow) Key

func (f Flow) Key() string

type IPPort

type IPPort struct {
	Protocol api.Protocol
	DnatIP   string
	Port     int32
}

func (IPPort) Key

func (i IPPort) Key() string

type IPPortLeaf

type IPPortLeaf = diffstore.AnyLeaf[IPPort]

type Leaf

type Leaf = diffstore.AnyLeaf[Flow]

type Sink

type Sink struct {
	localsink.Config
	// contains filtered or unexported fields
}

func NewSink

func NewSink() *Sink

func (*Sink) DeleteEndpoint

func (ps *Sink) DeleteEndpoint(namespace, serviceName, key string)

func (*Sink) DeleteService

func (ps *Sink) DeleteService(namespace, name string)

func (*Sink) Reset

func (ps *Sink) Reset()

func (*Sink) SetEndpoint

func (ps *Sink) SetEndpoint(namespace, serviceName, key string, endpoint *localv1.Endpoint)

func (*Sink) SetService

func (ps *Sink) SetService(svc *localv1.Service)

func (*Sink) Setup

func (ps *Sink) Setup()

func (*Sink) Sync

func (s *Sink) Sync()