egressservice

Documentation

Index

• Constants
• type Controller
  • func NewController(stopCh <-chan struct{}, returnMark, thisNode string, ...) (*Controller, error)
  • func (c *Controller) Run(wg *sync.WaitGroup, threadiness int) error

Constants

const (
	IPRulePriority = 5000 // the priority of the ip rules created by the controller. Egress IP priority is 6000.

	// chain for egress service NAT rules
	NFTablesChainName = "egress-services"

	// map for IPv4 SNAT mappings
	NFTablesMapV4 = "egress-service-snat-v4"

	// map for IPv6 SNAT mappings
	NFTablesMapV6 = "egress-service-snat-v6"
)

Types

type Controller

type Controller struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewController

func NewController(stopCh <-chan struct{}, returnMark, thisNode string,
	esInformer egressserviceinformer.EgressServiceInformer,
	serviceInformer cache.SharedIndexInformer,
	endpointSliceInformer cache.SharedIndexInformer) (*Controller, error)

func (*Controller) Run

func (c *Controller) Run(wg *sync.WaitGroup, threadiness int) error