Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var (
ErrBuildConfigFailed = errors.New("failed to build config")
)
Functions ¶
This section is empty.
Types ¶
type ClusterVectorAggregatorReconciler ¶
type ClusterVectorAggregatorReconciler struct {
client.Client
Scheme *runtime.Scheme
Clientset *kubernetes.Clientset
ConfigCheckTimeout time.Duration
EventChan chan event.GenericEvent
}
ClusterVectorAggregatorReconciler reconciles a ClusterVectorAggregator object
func (*ClusterVectorAggregatorReconciler) Reconcile ¶
func (r *ClusterVectorAggregatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the ClusterVectorAggregator object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.19.0/pkg/reconcile
func (*ClusterVectorAggregatorReconciler) SetupWithManager ¶
func (r *ClusterVectorAggregatorReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type PipelineReconciler ¶
type PipelineReconciler struct {
client.Client
Scheme *runtime.Scheme
// Temp. Wait this issue - https://github.com/kubernetes-sigs/controller-runtime/issues/452
Clientset *kubernetes.Clientset
ConfigCheckTimeout time.Duration
VectorAgentEventCh chan event.GenericEvent
VectorAggregatorsEventCh chan event.GenericEvent
ClusterVectorAggregatorsEventCh chan event.GenericEvent
EnableReconciliationInvalidPipelines bool
ReconciliationInvalidPipelinesRetryDelay time.Duration
}
func (*PipelineReconciler) SetupWithManager ¶
func (r *PipelineReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type VectorAggregatorReconciler ¶
type VectorAggregatorReconciler struct {
client.Client
Scheme *runtime.Scheme
Clientset *kubernetes.Clientset
ConfigCheckTimeout time.Duration
EventChan chan event.GenericEvent
}
VectorAggregatorReconciler reconciles a VectorAggregator object
func (*VectorAggregatorReconciler) Reconcile ¶
func (r *VectorAggregatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the VectorAggregator object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.19.0/pkg/reconcile
func (*VectorAggregatorReconciler) SetupWithManager ¶
func (r *VectorAggregatorReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type VectorReconciler ¶
type VectorReconciler struct {
client.Client
Scheme *runtime.Scheme
// Temp. Wait this issue - https://github.com/kubernetes-sigs/controller-runtime/issues/452
Clientset *kubernetes.Clientset
ConfigCheckTimeout time.Duration
DiscoveryClient *discovery.DiscoveryClient
EventChan chan event.GenericEvent
}
VectorReconciler reconciles a Vector object
func (*VectorReconciler) SetupWithManager ¶
func (r *VectorReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.