controller

Documentation

Index

• Variables
• func IgnoreBuildConfigFailed(err error) error
• type ClusterVectorAggregatorReconciler
  • func (r *ClusterVectorAggregatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterVectorAggregatorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PipelineReconciler
  • func (r *PipelineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PipelineReconciler) SetupWithManager(mgr ctrl.Manager) error
• type VectorAggregatorReconciler
  • func (r *VectorAggregatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *VectorAggregatorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type VectorReconciler
  • func (r *VectorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *VectorReconciler) SetupWithManager(mgr ctrl.Manager) error

Variables

var (
	ErrBuildConfigFailed = errors.New("failed to build config")
)

Functions

func IgnoreBuildConfigFailed

func IgnoreBuildConfigFailed(err error) error

Types

type ClusterVectorAggregatorReconciler

type ClusterVectorAggregatorReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	EventsCollector    *k8sevents.EventsCollector
	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
	EventsCollector                 *k8sevents.EventsCollector
}

func (*PipelineReconciler) Reconcile

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

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

	EventsCollector    *k8sevents.EventsCollector
	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) Reconcile

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

func (*VectorReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.