fakereconciler

Documentation

Index

• Constants
• type FakeReconciler
  • func NewFakeReconciler(fakeClient controllerRTclient.WithWatch, scheme *runtime.Scheme) FakeReconciler
• type ReconcileResponce
  • func (r *ReconcileResponce) IsRequeued() bool
  • func (r *ReconcileResponce) String() string

Constants

const (
	BasePauseTime       = 373 * time.Millisecond
	ControlChanBuffSize = 255

	MsgUnableToWatch        = "Unable to watch"
	MsgMainLoopIsNotStarted = "MainLoop is not started"
)

Types

type FakeReconciler

type FakeReconciler interface {
	// Run main loop to watch create/delete/reconcile requests.
	// Context will be stored to future use
	Run(ctx context.Context) error

	// Wait -- wait to finish all running fake reconcile loops
	// and user requested create/reconcile calls. Like sync.Wait()
	// context, passed to Run(...) will be used to cancel all waiters.
	Wait()

	// Reconcile -- invoke to reconcile the corresponded resource.
	// Returns chan which can be used to obtain reconcile response and timings
	Reconcile(kindName, key string) (chan *ReconcileResponce, error)

	// LockReconciler -- lock watchers/reconcilers for the specifyed Kind type.
	// returns callable to Unock thread
	LockReconciler(kindName string) (unlock func())

	// WaitToBeCreated -- block goroutine while corresponded CRD will be created.
	//
	// If isReconciled is false just reconciliation record (fact) will be probed,
	// else (if true) -- reconciled result (status exists and not empty) will be waited.
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	WaitToBeCreated(ctx context.Context, kindName, key string, isReconciled bool) error

	// WatchToBeCreated -- run goroutine to wait while corresponded CRD will be created.
	//
	// If isReconciled is false just reconciliation record (fact) will be probed,
	// else (if true) -- reconciled result (status exists and not empty) will be watched.
	// Does not block current goroutine,  error chan returned to obtain result if need
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	WatchToBeCreated(ctx context.Context, kindName, key string, isReconciled bool) (chan error, error)

	// WaitToBeReconciled -- block goroutine while corresponded CRD will be reconciled.
	//
	// if reconciledAfter if zero just reconciliation record (fact) will be probed,
	// else (if real time passed) only fresh reconciliation (after given time) will be accounted
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	// Throw error if kind not found, use Wait/WatchToBeCreated(...) to check it.
	WaitToBeReconciled(ctx context.Context, kindName, key string, reconciledAfter time.Time) error

	// WatchToBeReconciled -- run goroutine to wait while corresponded CRD will be reconciled.
	//
	// if reconciledAfter if zero just reconciliation record (fact) will be probed,
	// else (if real time passed) only fresh reconciliation (after given time) will be accounted
	// Does not block current goroutine,  error chan returned to obtain result if need
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	// Throw error if kind not found, use Wait/WatchToBeCreated(...) to check it.
	WatchToBeReconciled(ctx context.Context, kindName, key string, reconciledAfter time.Time) (chan *ReconcileResponce, error)

	// WaitToSatisfyJQ -- block goroutine while correspond CRD is not satisfied to the given JQ script
	//
	// for additional info see https://stedolan.github.io/jq/ and https://pkg.go.dev/github.com/itchyny/gojq
	// ./JQ query result should return a bool result
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	// Throw error if wrong JQ script given
	WaitToSatisfyJQ(ctx context.Context, kindName, key, jq string) error

	// WatchToSatisfyJQ -- run goroutine to wait while correspond CRD is not satisfied to the given JQ script and reports to chan
	//
	// for additional info see https://stedolan.github.io/jq/ and https://pkg.go.dev/github.com/itchyny/gojq
	// ./JQ query result should return a bool result
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	// Throw error if wrong JQ script given
	WatchToSatisfyJQ(ctx context.Context, kindName, key, jq string) (chan error, error)

	// WaitToFieldSatisfyRE -- block goroutine while corresponded CRD field will be satisfy to the given regexp.
	//
	// The dot '.' is a separator in the fieldPath
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	//
	// Deprecated: Use WaitToSatisfyJQ(...) instead.
	WaitToFieldSatisfyRE(ctx context.Context, kind, key, fieldPath, reString string) error

	// WatchToFieldSatisfyRE -- run goroutine to wait while corresponded CRD field will be satisfy to the given regexp.
	//
	// The dot '.' is a separator in the fieldPath
	// Pass nil instead context, to use stored early
	//
	// Deprecated: Use WatchToSatisfyJQ(...) instead.
	WatchToFieldSatisfyRE(ctx context.Context, kind, key, fieldPath, reString string) (chan error, error)

	// WaitToFieldBeChecked -- block goroutine while corresponded CRD field will be exists and checked by callback function.
	//
	// The dot '.' is a separator in the fieldPath
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	//
	// Deprecated: Use WaitToSatisfyJQ(...) instead.
	WaitToFieldBeChecked(ctx context.Context, kind, key, fieldPath string, callbackFunc func(any) bool) error

	// WatchToFieldBeChecked -- run goroutine to wait while corresponded CRD field will be exists and checked by callback function.
	//
	// The dot '.' is a separator in the fieldPath
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	//
	// Deprecated: Use WatchToSatisfyJQ(...) instead.
	WatchToFieldBeChecked(ctx context.Context, kind, key, fieldPath string, callbackFunc func(any) bool) (chan error, error)

	// WaitToFieldBeNotFound -- block goroutine while corresponded CRD field will be not exists (cleaned).
	//
	// The dot '.' is a separator in the fieldPath
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	//
	// Deprecated: Use WaitToSatisfyJQ(...) instead.
	WaitToFieldBeNotFound(ctx context.Context, kind, key, fieldpath string) error

	// WatchToFieldBeNotFound -- run goroutine to wait while corresponded CRD field will be not exists (cleaned).
	//
	// The dot '.' is a separator in the fieldPath
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	//
	// Deprecated: Use WatchToSatisfyJQ(...) instead.
	WatchToFieldBeNotFound(ctx context.Context, kind, key, fieldpath string) (chan error, error)

	// WaitToBeDeleted -- block goroutine while corresponded CRD will be deleted.
	//
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	// If requireValidDeletion is `true` object should be really deleted,
	// otherwise valid deletionTimestamp is enough
	WaitToBeDeleted(ctx context.Context, kindName, key string, requireValidDeletion bool) error

	// WatchToBeDeleted -- run goroutine to wait while corresponded CRD will be deleted.
	//
	// Does not block current goroutine,  error chan returned to obtain result if need
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	// If requireValidDeletion is `true` object should be really deleted,
	// otherwise valid deletionTimestamp is enough
	WatchToBeDeleted(ctx context.Context, kindName, key string, requireValidDeletion bool) (chan error, error)

	// WaitToBeFinished -- block current goroutine and wait all channels reports about finish or error.
	// If error received, deadline happens or context cancelled error will be returned
	//
	// Pass nil instead context, to use fakeReconciler .Run(ctx) context
	WaitToBeFinished(ctx context.Context, chanList []chan error) error

	GetAndPublishIfTestFailed(ctx context.Context, t *testing.T, kindName, key string) (shouldBeDeffered func())
	GetAndPublishIfTestFailedWithCancel(ctx context.Context, t *testing.T, kindName, key string) (shouldBeDeffered, cancel func())

	// AddController -- add reconciler to the monitor loop while setup (before .Run(...) call)
	AddController(gvk *schema.GroupVersionKind, rcl controllerRTreconcile.Reconciler) error
	AddControllerByType(m schema.ObjectKind, rcl controllerRTreconcile.Reconciler) error

	GetClient() controllerRTclient.WithWatch
	GetScheme() *runtime.Scheme

	// SetPauseTime -- Configure pause between resource state check for Wait/Watch calls
	SetPauseTime(time.Duration)
	GetPauseTime() time.Duration
}

func NewFakeReconciler

func NewFakeReconciler(fakeClient controllerRTclient.WithWatch, scheme *runtime.Scheme) FakeReconciler

type ReconcileResponce

type ReconcileResponce struct {
	Err             error
	Result          controllerRTreconcile.Result
	StartFinishTime k8t.TimeInterval
}

func (*ReconcileResponce) IsRequeued

func (r *ReconcileResponce) IsRequeued() bool

func (*ReconcileResponce) String

func (r *ReconcileResponce) String() string