reconciler

Documentation

Index

• type OutputReference
  • func (o OutputReference) Add(refs []string) []string
  • func (o OutputReference) Remove(refs []string) []string
• type Reconciler
  • func New(ingestAddr string, client client.Client) *Reconciler
  • func (r *Reconciler) EnsureOutput(ctx context.Context, flowRef internal.FlowReference) (res ctrl.Result, err error)
  • func (r *Reconciler) HTTPOuput(flowRef internal.FlowReference) *output.HTTPOutputConfig
  • func (r *Reconciler) OutputObjectMeta(key types.NamespacedName, flowName string) metav1.ObjectMeta
  • func (r *Reconciler) Reconcile(ctx context.Context, event internal.ReconcileEvent) (res ctrl.Result, err error)
  • func (r *Reconciler) ReconcileFlow(ctx context.Context, ref internal.FlowReference, updater UpdateReference) (res ctrl.Result, err error)
  • func (r *Reconciler) RemoveOutput(ctx context.Context, obj client.Object) (res ctrl.Result, err error)
• type UpdateReference

Types

type OutputReference

type OutputReference string

func (OutputReference) Add

func (o OutputReference) Add(refs []string) []string

func (OutputReference) Remove

func (o OutputReference) Remove(refs []string) []string

type Reconciler

type Reconciler struct {
	Client     client.Client
	IngestAddr string
}

func New

func New(ingestAddr string, client client.Client) *Reconciler

func (*Reconciler) EnsureOutput

func (r *Reconciler) EnsureOutput(ctx context.Context, flowRef internal.FlowReference) (res ctrl.Result, err error)

func (*Reconciler) HTTPOuput

func (r *Reconciler) HTTPOuput(flowRef internal.FlowReference) *output.HTTPOutputConfig

func (*Reconciler) OutputObjectMeta

func (r *Reconciler) OutputObjectMeta(key types.NamespacedName, flowName string) metav1.ObjectMeta

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, event internal.ReconcileEvent) (res ctrl.Result, err error)

func (*Reconciler) ReconcileFlow

func (r *Reconciler) ReconcileFlow(ctx context.Context, ref internal.FlowReference, updater UpdateReference) (res ctrl.Result, err error)

func (*Reconciler) RemoveOutput

func (r *Reconciler) RemoveOutput(ctx context.Context, obj client.Object) (res ctrl.Result, err error)

type UpdateReference

type UpdateReference func(refs []string) []string