syncer

Documentation

Index

• Variables
• type GatewaySyncer
  • func NewGatewaySyncer(engine cableengine.Engine, client v1typed.GatewayInterface, version string, ...) *GatewaySyncer
  • func (gs *GatewaySyncer) CleanupGatewayEntry()
  • func (gs *GatewaySyncer) Run(stopCh <-chan struct{})
  • func (gs *GatewaySyncer) SetGatewayStatusError(err error)

Variables

var GatewayStaleTimeout = GatewayUpdateInterval * 3

var GatewayUpdateInterval = 5 * time.Second

Types

type GatewaySyncer

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

func NewGatewaySyncer

func NewGatewaySyncer(engine cableengine.Engine, client v1typed.GatewayInterface,
	version string, healthCheck healthchecker.Interface) *GatewaySyncer

NewEngine creates a new Engine for the local cluster

func (*GatewaySyncer) CleanupGatewayEntry

func (gs *GatewaySyncer) CleanupGatewayEntry()

CleanupGatewayEntry removes this Gateway entry from the k8s API, it does not propagate error up because it's a termination function that we also provide externally

func (*GatewaySyncer) Run

func (gs *GatewaySyncer) Run(stopCh <-chan struct{})

func (*GatewaySyncer) SetGatewayStatusError

func (gs *GatewaySyncer) SetGatewayStatusError(err error)