controller

type Ack[I ID] struct {
	// contains filtered or unexported fields
}

type Backoff func(attempt int) time.Duration

type Controller[I ID] struct {
	Log dazl.Logger
	// contains filtered or unexported fields
}

type Directive[I ID] interface {
	Do(controller *Controller[I])
}

type Fail[I ID] struct {
	Error error
	// contains filtered or unexported fields
}

type ID interface {
	~string | ~int | ~int32 | ~int64 | ~uint | ~uint32 | ~uint64
	fmt.Stringer
}

type Option func(*Options)

type Options struct {
	Log         dazl.Logger
	Parallelism int
	BufferSize  int
	Timeout     *time.Duration
}

type Reconciler[I ID] func(ctx context.Context, request Request[I]) Directive[I]

type Request[I ID] struct {
	ID I
	// contains filtered or unexported fields
}

type Requeue[I ID] struct {
	// contains filtered or unexported fields
}

type Retry[I ID] struct {
	Error error
	// contains filtered or unexported fields
}

type RetryAfter[I ID] struct {
	*Retry[I]
	// contains filtered or unexported fields
}

type RetryAt[I ID] struct {
	*Retry[I]
	// contains filtered or unexported fields
}

type RetryWith[I ID] struct {
	*Retry[I]
	// contains filtered or unexported fields
}