gateway

Documentation

Index

• Constants
• func PersistUpdates(client gwclient.Interface, gw *v1alpha1.Gateway, log *logrus.Logger) (*v1alpha1.Gateway, error)
• func Validate(gatewayObj *v1alpha1.Gateway) error
• type Controller
  • func NewGatewayController(rest *rest.Config, configMap, namespace, clientImage string, ...) *Controller
  • func (c *Controller) ResyncConfig(namespace string) error
  • func (c *Controller) Run(ctx context.Context, threads int)
• type ControllerConfig

Constants

const (
	//LabelControllerInstanceID is the label which allows to separate gateways among multiple running controllers.
	LabelControllerInstanceID = gateway.FullName + "/gateway-controller-instanceid"
	// LabelGatewayKeyPhase is a label applied to gateways to indicate the current phase of the controller (for filtering purposes)
	LabelPhase = gateway.FullName + "/phase"
)

Labels

Functions

func PersistUpdates

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

PersistUpdates persists the updates for the gateway object.

func Validate

func Validate(gatewayObj *v1alpha1.Gateway) error

Validate validates the gateway resource.

Types

type Controller

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

Controller 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, clientImage string, gatewayImages map[apicommon.EventSourceType]string) *Controller

NewGatewayController creates a new controller

func (*Controller) ResyncConfig

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

ResyncConfig reloads the gateway-controller config from the configmap

func (*Controller) Run

func (c *Controller) Run(ctx context.Context, threads int)

Run processes the gateway resources on the controller's queue

type ControllerConfig

type ControllerConfig struct {
	// InstanceID is a label selector to limit the controller's watch of gateway to a specific instance.
	InstanceID string
	// Namespace is a label selector filter to limit controller's watch to specific namespace
	Namespace string
}

ControllerConfig contain the configuration settings for the controller