handlers

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 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,
) error

CreateOrUpdateLokiStack handles LokiStack create and update events.