controllers

Documentation

Index

• type AgentPipelineReconciler
  • func (r *AgentPipelineReconciler) PipelineConfigMapFromCR(instance *loggerv1beta.VectorAgent, ...) *corev1.ConfigMap
  • func (r *AgentPipelineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AgentPipelineReconciler) SetupWithManager(mgr ctrl.Manager) error
• type AgentReconciler
  • func (r *AgentReconciler) PipelineConfigMapFromCR(instance *loggerv1beta.VectorAgent, ...) *corev1.ConfigMap
  • func (r *AgentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AgentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type AggregatorReconciler
  • func (r *AggregatorReconciler) PipelineConfigMapFromCR(instance *loggerv1beta.VectorAggregator, namespace string) *corev1.ConfigMap
  • func (r *AggregatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AggregatorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PipelineSinks
• type PipelineSinksPrometheus
• type PipelineSources
• type PipelineSourcesKafka
• type PipelineSourcesKubernetes
• type PipelineSourcesMetrics
• type PipelineTransforms
• type PipelineTransformsFilter
• type VectorAgentPipeline
• type VectorAggregatorPipeline

Types

type AgentPipelineReconciler

type AgentPipelineReconciler struct {
	// client.Client
	Log logr.Logger
	util.ReconcilerBase
}

func (*AgentPipelineReconciler) PipelineConfigMapFromCR

func (r *AgentPipelineReconciler) PipelineConfigMapFromCR(
	instance *loggerv1beta.VectorAgent, agentPipeline *loggerv1beta.VectorAgentPipeline, namespaces []string) *corev1.ConfigMap

func (*AgentPipelineReconciler) Reconcile

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

func (*AgentPipelineReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type AgentReconciler

type AgentReconciler struct {
	// client.Client
	Log logr.Logger
	util.ReconcilerBase
}

func (*AgentReconciler) PipelineConfigMapFromCR

func (r *AgentReconciler) PipelineConfigMapFromCR(
	instance *loggerv1beta.VectorAgent, agentPipeline *loggerv1beta.VectorAgentPipeline, namespaces []string) *corev1.ConfigMap

func (*AgentReconciler) Reconcile

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

func (*AgentReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type AggregatorReconciler

type AggregatorReconciler struct {
	// client.Client
	Log logr.Logger
	util.ReconcilerBase
}

func (*AggregatorReconciler) PipelineConfigMapFromCR

func (r *AggregatorReconciler) PipelineConfigMapFromCR(instance *loggerv1beta.VectorAggregator, namespace string) *corev1.ConfigMap

func (*AggregatorReconciler) Reconcile

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

func (*AggregatorReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type PipelineSinks

type PipelineSinks struct {
	Prometheus PipelineSinksPrometheus
}

type PipelineSinksPrometheus

type PipelineSinksPrometheus struct {
	Namespace string
}

type PipelineSources

type PipelineSources struct {
	Metrics    PipelineSourcesMetrics
	Kubernetes PipelineSourcesKubernetes
	Kafka      PipelineSourcesKafka
}

type PipelineSourcesKafka

type PipelineSourcesKafka struct {
	Topics string
}

type PipelineSourcesKubernetes

type PipelineSourcesKubernetes struct {
	PodAnnotations map[string]string
}

type PipelineSourcesMetrics

type PipelineSourcesMetrics struct {
	Namespace string
}

type PipelineTransforms

type PipelineTransforms struct {
	Filter PipelineTransformsFilter
}

type PipelineTransformsFilter

type PipelineTransformsFilter struct {
	Namespaces []string
}

type VectorAgentPipeline

type VectorAgentPipeline struct {
	Sources    PipelineSources
	Transforms PipelineTransforms
	Sinks      PipelineSinks
	CRD        loggerv1beta.VectorAgentPipelineSpec
}

type VectorAggregatorPipeline

type VectorAggregatorPipeline struct {
	Sources    PipelineSources
	Transforms PipelineTransforms
	Sinks      PipelineSinks
	CRD        loggerv1beta.VectorAggregatorSpec
}