lokistack

Documentation

Index

• Variables
• func CheckFinalizer(ctx context.Context, client client.Client, obj client.Object) error
• func FormatOutputNameFromInput(inputName string) string
• func LokiStackGatewayService(logStore *loggingv1.LogStoreSpec) string
• func ProcessForwarderPipelines(logStore *loggingv1.LogStoreSpec, namespace string, ...) ([]loggingv1.OutputSpec, []loggingv1.PipelineSpec, map[string]bool)
• func ReconcileLokiReadRoles(k8sClient client.Client) (modified bool, err error)
• func ReconcileLokiWriteRbac(k8sClient client.Client) error
• func RemoveLokiReadRoles(k8sClient client.Client) error
• func RemoveLokiWriteRbac(k8sClient client.Client) error
• func RemoveRbac(k8sClient client.Client) error

Variables

var (
	DefaultLokiOutputNames sets.String
)

Functions

func CheckFinalizer

func CheckFinalizer(ctx context.Context, client client.Client, obj client.Object) error

CheckFinalizer checks if the finalizer used for tracking the cluster-wide RBAC resources is attached to the provided object and removes it, if present.

func FormatOutputNameFromInput

func FormatOutputNameFromInput(inputName string) string

FormatOutputNameFromInput takes an clf.input and formats the output name for 'default' output

func LokiStackGatewayService

func LokiStackGatewayService(logStore *loggingv1.LogStoreSpec) string

LokiStackGatewayService returns the name of LokiStack gateway service. Returns an empty string if ClusterLogging is not configured for a LokiStack log store.

func ProcessForwarderPipelines

func ProcessForwarderPipelines(logStore *loggingv1.LogStoreSpec, namespace string, spec loggingv1.ClusterLogForwarderSpec, extras map[string]bool, saTokenSecret string) ([]loggingv1.OutputSpec, []loggingv1.PipelineSpec, map[string]bool)

func ReconcileLokiReadRoles

func ReconcileLokiReadRoles(k8sClient client.Client) (modified bool, err error)

func ReconcileLokiWriteRbac

func ReconcileLokiWriteRbac(k8sClient client.Client) error

func RemoveLokiReadRoles

func RemoveLokiReadRoles(k8sClient client.Client) error

func RemoveLokiWriteRbac

func RemoveLokiWriteRbac(k8sClient client.Client) error

func RemoveRbac

func RemoveRbac(k8sClient client.Client) error