syncer

Documentation

Index

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

Constants

const UpdateTimestampAnnotation = "update-timestamp"

Variables

var (
	GatewayUpdateInterval = 5 * time.Second
	GatewayStaleTimeout   = GatewayUpdateInterval * 3
)

Types

type GatewaySyncer

type GatewaySyncer struct {
	// 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(ctx context.Context)

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(ctx context.Context, err error)