gateway

Documentation

Overview

Copyright 2018 BlackRock, Inc.

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

• func PersistUpdates(client gwclient.Interface, gw *v1alpha1.Gateway, log *zerolog.Logger) (*v1alpha1.Gateway, error)
• func ReapplyUpdate(client gwclient.Interface, gw *v1alpha1.Gateway) error
• func Validate(gw *v1alpha1.Gateway) error
• type GatewayController
  • func NewGatewayController(rest *rest.Config, configMap, namespace string) *GatewayController
  • func (c *GatewayController) ResyncConfig(namespace string) error
  • func (c *GatewayController) Run(ctx context.Context, gwThreads, eventThreads int)
• type GatewayControllerConfig

Functions

func PersistUpdates

func PersistUpdates(client gwclient.Interface, gw *v1alpha1.Gateway, log *zerolog.Logger) (*v1alpha1.Gateway, error)

persist the updates to the gateway resource

func ReapplyUpdate

func ReapplyUpdate(client gwclient.Interface, gw *v1alpha1.Gateway) error

reapply the updates to gateway resource

func Validate

func Validate(gw *v1alpha1.Gateway) error

Validate validates the gateway resource. Exporting this function so that external APIs can use this to validate gateway resource.

Types

type GatewayController

type GatewayController struct {
	// ConfigMap is the name of the config map in which to derive configuration of the contoller
	ConfigMap string
	// Namespace for gateway controller
	Namespace string
	// Config is the gateway-controller gateway-controller-controller's configuration
	Config GatewayControllerConfig
	// contains filtered or unexported fields
}

GatewayController listens for new gateways and hands off handling of each gateway-controller on the queue to the operator

func NewGatewayController

func NewGatewayController(rest *rest.Config, configMap, namespace string) *GatewayController

NewGatewayController creates a new Controller

func (*GatewayController) ResyncConfig

func (c *GatewayController) ResyncConfig(namespace string) error

ResyncConfig reloads the gateway-controller config from the configmap

func (*GatewayController) Run

func (c *GatewayController) Run(ctx context.Context, gwThreads, eventThreads int)

Run executes the gateway-controller

type GatewayControllerConfig

type GatewayControllerConfig struct {
	// InstanceID is a label selector to limit the gateway-controller's watch of gateway jobs to a specific instance.
	InstanceID string

	// Namespace is a label selector filter to limit gateway-controller-controller's watch to specific namespace
	Namespace string
}

GatewayControllerConfig contain the configuration settings for the gateway-controller