controllers

Documentation

Index

• Constants
• func NewDeploymentReconciler(client client.Client, updater IngressUpdater) *deploymentReconciler
• func NewIngressClassCreator(client client.Client, className string, namespace string, ...) *ingressClassCreator
• func NewIngressUpdater(client client.Client, registry registry.Registry, namespace string, ...) (*ingressUpdater, error)
• func NewMaintenanceModeUpdater(client client.Client, namespace string, ingressUpdater IngressUpdater, ...) (*maintenanceModeUpdater, error)
• func NewServiceReconciler(client client.Client, updater IngressUpdater) *serviceReconciler
• func NewSslCertificateUpdater(client client.Client, namespace string, recorder record.EventRecorder) (*sslCertificateUpdater, error)
• func NewWarpMenuCreator(client client.Client, registry registry.Registry, namespace string, ...) *warpMenuCreator
• type CesService
• type DeploymentReadyChecker
• type IngressUpdater
• type ServiceRewriter
  • func NewServiceRewriter(t mockConstructorTestingTNewServiceRewriter) *ServiceRewriter

Constants

const CesServiceAnnotation = "k8s-dogu-operator.cloudogu.com/ces-services"

CesServiceAnnotation can be appended to service with information of ces services.

Functions

func NewDeploymentReconciler

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

NewDeploymentReconciler creates a new deployment reconciler.

func NewIngressClassCreator

func NewIngressClassCreator(client client.Client, className string, namespace string, recorder record.EventRecorder) *ingressClassCreator

NewIngressClassCreator creates a new ingress class creator.

func NewIngressUpdater

func NewIngressUpdater(client client.Client, registry registry.Registry, namespace string, ingressClassName string, recorder record.EventRecorder) (*ingressUpdater, error)

NewIngressUpdater creates a new instance responsible for updating ingress objects.

func NewMaintenanceModeUpdater

func NewMaintenanceModeUpdater(client client.Client, namespace string, ingressUpdater IngressUpdater, recorder record.EventRecorder) (*maintenanceModeUpdater, error)

NewMaintenanceModeUpdater creates a new maintenance mode updater.

func NewServiceReconciler

func NewServiceReconciler(client client.Client, updater IngressUpdater) *serviceReconciler

NewServiceReconciler creates a new service reconciler.

func NewSslCertificateUpdater

func NewSslCertificateUpdater(client client.Client, namespace string, recorder record.EventRecorder) (*sslCertificateUpdater, error)

NewSslCertificateUpdater creates a new updater.

func NewWarpMenuCreator

func NewWarpMenuCreator(client client.Client, registry registry.Registry, namespace string, recorder record.EventRecorder) *warpMenuCreator

NewWarpMenuCreator initialises a creator object to start the warp menu creation

Types

type CesService

type CesService struct {
	// Name of the ces service serving as identifier.
	Name string `json:"name"`
	// Port of the ces service.
	Port int `json:"port"`
	// Location of the ces service defining the external path to the service.
	Location string `json:"location"`
	// Pass of the ces service defining the target path inside the service's pod.
	Pass string `json:"pass"`
}

CesService contains information about one exposed ces service.

type DeploymentReadyChecker

type DeploymentReadyChecker interface {
	// IsReady checks whether the application of the deployment is ready, i.e., contains at least one ready pod.
	IsReady(ctx context.Context, deploymentName string) (bool, error)
}

DeploymentReadyChecker checks the readiness from deployments.

type IngressUpdater

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 ServiceRewriter

type ServiceRewriter struct {
	mock.Mock
}

ServiceRewriter is an autogenerated mock type for the ServiceRewriter type

func NewServiceRewriter

func NewServiceRewriter(t mockConstructorTestingTNewServiceRewriter) *ServiceRewriter

NewServiceRewriter creates a new instance of ServiceRewriter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.