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.