Documentation
¶
Index ¶
Constants ¶
View Source
const UpdateTimestampAnnotation = "update-timestamp"
Variables ¶
View Source
var ( GatewayUpdateInterval = 5 * time.Second GatewayStaleTimeout = GatewayUpdateInterval * 3 )
Functions ¶
This section is empty.
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 ¶ added in v0.7.0
func (gs *GatewaySyncer) SetGatewayStatusError(ctx context.Context, err error)
Source Files
Click to show internal directories.
Click to hide internal directories.