observability

Documentation

Index

• func EvaluateAnnotationsForEnabledCapabilities(annotations map[string]string, options framework.Options)
• func FetchClusterLogForwarder(k8sClient client.Client, namespace, name string) (*obs.ClusterLogForwarder, error)
• func FetchConfigMaps(k8sClient client.Client, namespace string, names ...string) (configMaps []*corev1.ConfigMap, err error)
• func FetchSecrets(k8sClient client.Client, namespace string, names ...string) (secrets []*corev1.Secret, err error)
• func GenerateConfig(k8Client client.Client, spec obs.ClusterLogForwarder, ...) (config string, err error)
• func LogLevel(annotations map[string]string) string
• func MapConfigMaps(k8Client client.Client, namespace string, inputs internalobs.Inputs, ...) (configMaps map[string]*corev1.ConfigMap, err error)
• func MapSecrets(k8Client client.Client, namespace string, inputs internalobs.Inputs, ...) (secretMap map[string]*corev1.Secret, err error)
• func ReconcileCollector(context internalcontext.ForwarderContext, pollInterval, timeout time.Duration) (err error)
• func RemoveStaleWorkload(k8Client client.Client, forwarder *obsv1.ClusterLogForwarder) error
• type ClusterLogForwarderReconciler
  • func (r *ClusterLogForwarderReconciler) Initialize() (err error)
  • func (r *ClusterLogForwarderReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)
  • func (r *ClusterLogForwarderReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func EvaluateAnnotationsForEnabledCapabilities

func EvaluateAnnotationsForEnabledCapabilities(annotations map[string]string, options framework.Options)

EvaluateAnnotationsForEnabledCapabilities populates generator options with capabilities enabled by the ClusterLogForwarder

func FetchClusterLogForwarder

func FetchClusterLogForwarder(k8sClient client.Client, namespace, name string) (*obs.ClusterLogForwarder, error)

FetchClusterLogForwarder returns a copy of the ClusterLogForwarder

func FetchConfigMaps

func FetchConfigMaps(k8sClient client.Client, namespace string, names ...string) (configMaps []*corev1.ConfigMap, err error)

FetchConfigMaps from a list of names in a given namespace

func FetchSecrets

func FetchSecrets(k8sClient client.Client, namespace string, names ...string) (secrets []*corev1.Secret, err error)

FetchSecrets from a list of names in a given namespace

func GenerateConfig

func GenerateConfig(k8Client client.Client, spec obs.ClusterLogForwarder, resourceNames factory.ForwarderResourceNames, secrets internalobs.Secrets, op framework.Options) (config string, err error)

func LogLevel

func LogLevel(annotations map[string]string) string

func MapConfigMaps

func MapConfigMaps(k8Client client.Client, namespace string, inputs internalobs.Inputs, outputs internalobs.Outputs) (configMaps map[string]*corev1.ConfigMap, err error)

func MapSecrets

func MapSecrets(k8Client client.Client, namespace string, inputs internalobs.Inputs, outputs internalobs.Outputs) (secretMap map[string]*corev1.Secret, err error)

func ReconcileCollector

func ReconcileCollector(context internalcontext.ForwarderContext, pollInterval, timeout time.Duration) (err error)

func RemoveStaleWorkload

func RemoveStaleWorkload(k8Client client.Client, forwarder *obsv1.ClusterLogForwarder) error

RemoveStaleWorkload removes existing workload if the ClusterLogForwarder was modified such that the deployment will change from a daemonSet to a deployment or vise versa

Types

type ClusterLogForwarderReconciler

type ClusterLogForwarderReconciler struct {
	internalcontext.ForwarderContext
	Scheme *runtime.Scheme
}

ClusterLogForwarderReconciler reconciles a ClusterLogForwarder object

func (*ClusterLogForwarderReconciler) Initialize

func (r *ClusterLogForwarderReconciler) Initialize() (err error)

Initialize evaluates the spec and initializes any values that can not be enforced with annotations or are implied in their usage (i.e. reserved input names)

func (*ClusterLogForwarderReconciler) Reconcile

func (r *ClusterLogForwarderReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)

func (*ClusterLogForwarderReconciler) SetupWithManager

func (r *ClusterLogForwarderReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.