controller

Documentation

Index

• Variables
• type Action
• type ConfigMapAddedAction
• type ConfigMapDeletedAction
• type ConfigMapUpdatedAction
• type Converter
• type Informer
• type InformerFactory
• type IngressAddedAction
• type IngressDeletedAction
• type IngressUpdatedAction
• type KengineController
  • func NewKengineController(logger *zap.SugaredLogger, kubeClient *kubernetes.Clientset, ...) *KengineController
  • func (c *KengineController) Run()
  • func (c *KengineController) Shutdown() error
• type SecretAddedAction
• type SecretDeletedAction
• type SecretUpdatedAction
• type SyncStatusAction

Variables

var CertFolder = filepath.FromSlash("/etc/kengine/certs")

Types

type Action

type Action interface {
	// contains filtered or unexported methods
}

Action is an interface for ingress actions.

type ConfigMapAddedAction

type ConfigMapAddedAction struct {
	// contains filtered or unexported fields
}

ConfigMapAddedAction provides an implementation of the action interface.

type ConfigMapDeletedAction

type ConfigMapDeletedAction struct {
	// contains filtered or unexported fields
}

ConfigMapDeletedAction provides an implementation of the action interface.

type ConfigMapUpdatedAction

type ConfigMapUpdatedAction struct {
	// contains filtered or unexported fields
}

ConfigMapUpdatedAction provides an implementation of the action interface.

type Converter

type Converter interface {
	ConvertToKengineConfig(store *store.Store) (interface{}, error)
}

type Informer

type Informer struct {
	Ingress   cache.SharedIndexInformer
	ConfigMap cache.SharedIndexInformer
	TLSSecret cache.SharedIndexInformer
}

Informer defines the required SharedIndexInformers that interact with the API server.

type InformerFactory

type InformerFactory struct {
	PodNamespace     informers.SharedInformerFactory
	WatchedNamespace informers.SharedInformerFactory
}

InformerFactory contains shared informer factory We need to type of factory: - One used to watch resources in the Pod namespaces (kengine config, secrets...) - Another one for Ingress resources in the selected namespace

type IngressAddedAction

type IngressAddedAction struct {
	// contains filtered or unexported fields
}

IngressAddedAction provides an implementation of the action interface.

type IngressDeletedAction

type IngressDeletedAction struct {
	// contains filtered or unexported fields
}

IngressDeletedAction provides an implementation of the action interface.

type IngressUpdatedAction

type IngressUpdatedAction struct {
	// contains filtered or unexported fields
}

IngressUpdatedAction provides an implementation of the action interface.

type KengineController

type KengineController struct {
	// contains filtered or unexported fields
}

KengineController represents a kengine ingress controller.

func NewKengineController

func NewKengineController(
	logger *zap.SugaredLogger,
	kubeClient *kubernetes.Clientset,
	opts store.Options,
	converter Converter,
	stopChan chan struct{},
) *KengineController

func (*KengineController) Run

func (c *KengineController) Run()

Run method starts the ingress controller.

func (*KengineController) Shutdown

func (c *KengineController) Shutdown() error

Shutdown stops the kengine controller.

type SecretAddedAction

type SecretAddedAction struct {
	// contains filtered or unexported fields
}

SecretAddedAction provides an implementation of the action interface.

type SecretDeletedAction

type SecretDeletedAction struct {
	// contains filtered or unexported fields
}

SecretDeletedAction provides an implementation of the action interface.

type SecretUpdatedAction

type SecretUpdatedAction struct {
	// contains filtered or unexported fields
}

SecretUpdatedAction provides an implementation of the action interface.

type SyncStatusAction

type SyncStatusAction struct {
}

SyncStatusAction provides an implementation of the action interface.