syncer

Documentation

Overview

© 2021 Red Hat, Inc. and others

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

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)