util

Documentation

Index

• func ReconcileObject(logger *slog.Logger, k8sClient client.Client, namespace string, ...) error
• type ReconcileItem
• type ReconcilerState
  • func (r *ReconcilerState) Cancel()
  • func (r *ReconcilerState) GetRunning() bool
  • func (r *ReconcilerState) SetBackoffCtx(ctx context.Context, cancel context.CancelFunc)
  • func (r *ReconcilerState) SetRunning(running bool)

Functions

func ReconcileObject

func ReconcileObject(logger *slog.Logger, k8sClient client.Client, namespace string, item ReconcileItem) error

Types

type ReconcileItem

type ReconcileItem lo.Tuple2[client.Object, bool]

(obj, shouldExist))

type ReconcilerState

type ReconcilerState struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*ReconcilerState) Cancel

func (r *ReconcilerState) Cancel()

func (*ReconcilerState) GetRunning

func (r *ReconcilerState) GetRunning() bool

func (*ReconcilerState) SetBackoffCtx

func (r *ReconcilerState) SetBackoffCtx(ctx context.Context, cancel context.CancelFunc)

func (*ReconcilerState) SetRunning

func (r *ReconcilerState) SetRunning(running bool)