Documentation ¶
Index ¶
- type AgentPipelineReconciler
- type AgentReconciler
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) 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) 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) 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 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 }
Click to show internal directories.
Click to hide internal directories.