reconciler

type Controller ¶

type Controller interface {
	Reconcile(k any) (*Result, error)
}

controller interface meant for registering to database manager for processing changes inoccuring to varies entries in the database

type Manager ¶

type Manager interface {
	// function to get all existing keys in the collection
	ReconcilerGetAllKeys() []any
	// contains filtered or unexported methods
}

Manager interface for enforcing implementation of specific functions

type ManagerImpl ¶

type ManagerImpl struct {
	Manager
	// contains filtered or unexported fields
}

Manager implementation with implementation of the core logic typically built over and above database store on which it will offer reconcilation capabilities

func (m *ManagerImpl) Initialize(ctx context.Context, parent Manager) error

func (m *ManagerImpl) NotifyCallback(wKey any)

func (m *ManagerImpl) Register(name string, crtl Controller) error

type Pipeline ¶

type Pipeline struct {
	// contains filtered or unexported fields
}

Pipeline of elements to be processed by reconciler upon notification

func NewPipeline(ctx context.Context, fn reconcilerFunc) *Pipeline

func (p *Pipeline) Enqueue(k any) error

type Request ¶

type Request struct {
	Key any
}

type Result ¶

type Result struct {
	// RequeueAfter if greater than 0, tells the Controller to requeue the reconcile key after the Duration.
	RequeueAfter time.Duration
}

Taking motivation from kubernetes https://github.com/kubernetes-sigs/controller-runtime/blob/main/pkg/reconcile/reconcile.go enable a reconciler function