gc

Documentation

Index

• Variables
• type Enabler
  • func NewFake() Enabler
• type EndpointManager
• type GC
  • func New(params parameters) *GC
  • func (gc *GC) Enable()
• type PerClusterCTMapsRetriever
• type SignalData
  • func (d SignalData) String() string
• type SignalHandler
  • func (sh *SignalHandler) MuteSignals() error
  • func (sh *SignalHandler) Signals() <-chan SignalData
  • func (sh *SignalHandler) UnmuteSignals() error

Variables

var Cell = cell.Module(
	"ct-nat-map-gc",
	"Garbage collection of CT and NAT maps",

	cell.Provide(

		func(gc *GC) Enabler { return gc },
	),

	cell.ProvidePrivate(
		New,

		newSignalHandler,

		func(mgr endpointmanager.EndpointManager) EndpointManager { return mgr },
	),
)

Types

type Enabler

type Enabler interface {
	// Enable enables the connection tracking garbage collection.
	Enable()
}

func NewFake

func NewFake() Enabler

type EndpointManager

type EndpointManager interface {
	GetEndpoints() []*endpoint.Endpoint
}

EndpointManager is any type which returns the list of Endpoints which are globally exposed on the current node.

type GC

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

func New

func New(params parameters) *GC

func (*GC) Enable

func (gc *GC) Enable()

Enable enables the connection tracking garbage collection.

type PerClusterCTMapsRetriever

type PerClusterCTMapsRetriever func() []*ctmap.Map

type SignalData

type SignalData uint32

SignalData holds the IP address family type BPF program sent along with the SignalNatFillUp and SignalCTFillUp signals.

const (
	// SignalProtoV4 denotes IPv4 protocol
	SignalProtoV4 SignalData = iota
	// SignalProtoV6 denotes IPv6 protocol
	SignalProtoV6
	SignalProtoMax
)

func (SignalData) String

func (d SignalData) String() string

String implements fmt.Stringer for SignalData

type SignalHandler

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

func (*SignalHandler) MuteSignals

func (sh *SignalHandler) MuteSignals() error

func (*SignalHandler) Signals

func (sh *SignalHandler) Signals() <-chan SignalData

func (*SignalHandler) UnmuteSignals

func (sh *SignalHandler) UnmuteSignals() error