idempotence

type Idempotence ¶

type Idempotence interface {
	Exec(ctx context.Context, key string, exec func(context.Context) error) error
	// Processed reports whether key was marked processed (by MarkProcessed or
	// a successful Exec) within the SuccessfulTTL window.
	Processed(ctx context.Context, key string) (bool, error)
	// MarkProcessed marks key processed for the SuccessfulTTL window.
	MarkProcessed(ctx context.Context, key string) error
}

Idempotence deduplicates work by key. Exec is the packaged form: it claims the key, runs the callback, and marks the key processed — for work that completes within one call. Processed and MarkProcessed expose the check and mark phases separately, for callers whose work spans a boundary Exec can't wrap (e.g. the effects finish on another goroutine); such callers get no in-flight conflict detection — concurrent duplicates both run, so their effects must tolerate duplication.

func New(redisClient redis.Cmdable, opts ...func(opts *IdempotenceImplOptions)) Idempotence

type IdempotenceImpl ¶

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

func (i *IdempotenceImpl) Exec(ctx context.Context, key string, exec func(context.Context) error) error

func (i *IdempotenceImpl) MarkProcessed(ctx context.Context, key string) error

func (i *IdempotenceImpl) Processed(ctx context.Context, key string) (bool, error)

type IdempotenceImplOptions ¶

type IdempotenceImplOptions struct {
	Timeout       time.Duration
	SuccessfulTTL time.Duration
	DeploymentID  string
}