handlers

Documentation

Index

• func AnnotatePodWithAvailabilityZone(ctx context.Context, log logr.Logger, c k8s.Client, pod *corev1.Pod) error
• func CheckCertExpiry(ctx context.Context, log logr.Logger, req ctrl.Request, k k8s.Client, ...) error
• func CreateDashboards(ctx context.Context, log logr.Logger, operatorNs string, k k8s.Client, ...) error
• func CreateOrRotateCertificates(ctx context.Context, log logr.Logger, req ctrl.Request, k k8s.Client, ...) error
• func CreateOrUpdateLokiStack(ctx context.Context, log logr.Logger, req ctrl.Request, k k8s.Client, ...) (lokiv1.CredentialMode, error)
• func CreateUpdateDeleteCredentialsRequest(ctx context.Context, log logr.Logger, scheme *runtime.Scheme, ...) error
• func DeleteDashboards(ctx context.Context, k k8s.Client, operatorNs string) error

Functions

func AnnotatePodWithAvailabilityZone

func AnnotatePodWithAvailabilityZone(ctx context.Context, log logr.Logger, c k8s.Client, pod *corev1.Pod) error

func CheckCertExpiry

func CheckCertExpiry(ctx context.Context, log logr.Logger, req ctrl.Request, k k8s.Client, fg configv1.FeatureGates) error

CheckCertExpiry handles the case if the LokiStack managed signing CA, client and/or serving certificates expired. Returns true if any of those expired and an error representing the reason of expiry.

func CreateDashboards

func CreateDashboards(ctx context.Context, log logr.Logger, operatorNs string, k k8s.Client, s *runtime.Scheme) error

CreateDashboards handles the LokiStack dashboards create events.

func CreateOrRotateCertificates

func CreateOrRotateCertificates(ctx context.Context, log logr.Logger, req ctrl.Request, k k8s.Client, s *runtime.Scheme, fg configv1.FeatureGates) error

CreateOrRotateCertificates handles the LokiStack client and serving certificate creation and rotation including the signing CA and a ca bundle or else returns an error. It returns only a degrade-condition-worthy error if building the manifests fails for any reason.

func CreateOrUpdateLokiStack

func CreateOrUpdateLokiStack(
	ctx context.Context,
	log logr.Logger,
	req ctrl.Request,
	k k8s.Client,
	s *runtime.Scheme,
	fg configv1.FeatureGates,
) (lokiv1.CredentialMode, error)

CreateOrUpdateLokiStack handles LokiStack create and update events.

func CreateUpdateDeleteCredentialsRequest

func CreateUpdateDeleteCredentialsRequest(ctx context.Context, log logr.Logger, scheme *runtime.Scheme, tokenCCOAuth *config.TokenCCOAuthConfig, k k8s.Client, req ctrl.Request) error

CreateUpdateDeleteCredentialsRequest creates a new CredentialsRequest resource for a Lokistack to request a cloud credentials Secret resource from the OpenShift cloud-credentials-operator.

func DeleteDashboards

func DeleteDashboards(ctx context.Context, k k8s.Client, operatorNs string) error

DeleteDashboards removes all cluster-scoped dashboard resources.