idempotencyredis

package

v2.0.1 Latest Latest Go to latest Published: Feb 2, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Package idempotencyredis provides Redis-backed idempotency storage.

This section is empty.

This section is empty.

This section is empty.

type Options struct {
	KeyPrefix string
}

Options configures Redis-backed idempotency storage.

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

Store implements ports.IdempotencyStore using Redis.

func New(client redis.UniversalClient, opts Options) *Store

New constructs a Redis-backed idempotency store.

func (s *Store) Get(ctx context.Context, key string) (ports.IdempotencyRecord, bool, error)

Get returns an idempotency record if present.

func (s *Store) Save(ctx context.Context, key string, record ports.IdempotencyRecord, ttl time.Duration) error

Save persists a completed idempotency record.

func (s *Store) TryBegin(ctx context.Context, key string, record ports.IdempotencyRecord, ttl time.Duration) (bool, error)

TryBegin reserves a key for an in-flight request.