controllers

package
v1.3.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 19, 2024 License: AGPL-3.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDeploymentReconciler added in v0.6.0

func NewDeploymentReconciler(client client.Client, updater IngressUpdater) *deploymentReconciler

NewDeploymentReconciler creates a new deployment reconciler.

func NewMaintenanceModeUpdater added in v0.5.0

func NewMaintenanceModeUpdater(client k8sClient, namespace string, ingressUpdater IngressUpdater, recorder eventRecorder, globalConfigRepo GlobalConfigRepository) (*maintenanceModeUpdater, error)

NewMaintenanceModeUpdater creates a new maintenance mode updater.

func NewSelfsignedCertificateUpdater added in v0.12.0

func NewSelfsignedCertificateUpdater(client client.Client, namespace string, globalConfigRepo GlobalConfigRepository, recorder eventRecorder) *selfsignedCertificateUpdater

NewSelfsignedCertificateUpdater creates a new updater.

func NewServiceReconciler added in v0.5.0

func NewServiceReconciler(client client.Client, ingressUpdater IngressUpdater, exposedPortUpdater ExposedPortUpdater, networkPolicyUpdater NetworkPolicyUpdater, networkPoliciesEnabled bool) *serviceReconciler

NewServiceReconciler creates a new service reconciler.

func NewSslCertificateUpdater added in v0.3.0

func NewSslCertificateUpdater(client client.Client, namespace string, globalConfigRepo GlobalConfigRepository, recorder eventRecorder) *sslCertificateUpdater

NewSslCertificateUpdater creates a new updater.

func NewWarpMenuCreator added in v0.2.0

func NewWarpMenuCreator(client client.Client, doguVersionRegistry warp.DoguVersionRegistry, localDoguRepo warp.LocalDoguRepo, namespace string, recorder eventRecorder, globalConfig warp.GlobalConfigRepository) *warpMenuCreator

NewWarpMenuCreator initialises a creator object to start the warp menu creation

Types

type ExposedPortUpdater added in v1.3.0

type ExposedPortUpdater interface {
	UpsertCesLoadbalancerService(ctx context.Context, service *corev1.Service) error
	RemoveExposedPorts(ctx context.Context, serviceName string) error
}

type GlobalConfigRepository added in v0.15.1

type GlobalConfigRepository interface {
	Get(context.Context) (libconfig.GlobalConfig, error)
	Watch(context.Context, ...libconfig.WatchFilter) (<-chan repository.GlobalConfigWatchResult, error)
	Update(ctx context.Context, globalConfig libconfig.GlobalConfig) (libconfig.GlobalConfig, error)
}

type IngressUpdater added in v0.5.0

type IngressUpdater interface {
	// UpsertIngressForService creates or updates the ingress object of the given service.
	UpsertIngressForService(ctx context.Context, service *corev1.Service) error
}

IngressUpdater is responsible to create and update the actual ingress objects in the cluster.

type NetworkPolicyUpdater added in v1.3.0

type NetworkPolicyUpdater interface {
	UpsertNetworkPoliciesForService(ctx context.Context, service *corev1.Service) error
	RemoveExposedPorts(ctx context.Context, serviceName string) error
	RemoveNetworkPolicy(ctx context.Context) error
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL