controllers

Documentation

Index

• Constants
• Variables
• type PipelineReconciler
  • func (r *PipelineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PipelineReconciler) 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

Constants

const PipelineDeleteEventTimeout time.Duration = 3 * time.Second

Variables

var VectorAgentReconciliationSourceChannel = make(chan event.GenericEvent)

Types

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
	PipelineCheckWG            *sync.WaitGroup
	PipelineDeleteEventTimeout time.Duration
}

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 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
	PipelineCheckWG      *sync.WaitGroup
	PipelineCheckTimeout time.Duration
	DiscoveryClient      *discovery.DiscoveryClient
}

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.