gateway

Documentation

Index

• func NewGatewayResourceContext(gw *v1alpha1.Gateway, controller *GatewayController) gwResourceCtx
• func PersistUpdates(client gwclient.Interface, gw *v1alpha1.Gateway, log *logrus.Logger) (*v1alpha1.Gateway, error)
• func ReapplyUpdates(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 NewGatewayResourceContext

func NewGatewayResourceContext(gw *v1alpha1.Gateway, controller *GatewayController) gwResourceCtx

NewGatewayResourceContext returns new gwResourceCtx

func PersistUpdates

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

PersistUpdates of the gateway resource

func ReapplyUpdates

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

ReapplyUpdates 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 {
	// EventSource 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