Versions in this module Expand all Collapse all v1 v1.0.0 Aug 26, 2026 Changes in this version + func GoMigration() (migrations.Migration, error) + func RecordKeyDigest(key idempotency.Key) []byte + type Migration struct + Down string + Name string + Up string + Version uint + func SchemaMigration() Migration + type Options struct + OwnerTokens func() (string, error) + Retention time.Duration + type Store struct + func New(pool *pgxpool.Pool, options Options) (*Store, error) + func (s *Store) Acquire(ctx context.Context, request idempotency.AcquireRequest) (result idempotency.AcquireResult, err error) + func (s *Store) Cleanup(ctx context.Context, batch int) (int64, error) + func (s *Store) Complete(ctx context.Context, request idempotency.CompleteRequest) (idempotency.Record, error) + func (s *Store) CompleteTx(ctx context.Context, tx pgx.Tx, request idempotency.CompleteRequest) (idempotency.Record, error) + func (s *Store) Expire(ctx context.Context, key idempotency.Key) (record idempotency.Record, err error) + func (s *Store) Fail(ctx context.Context, request idempotency.FailRequest) (idempotency.Record, error) + func (s *Store) Heartbeat(ctx context.Context, request idempotency.HeartbeatRequest) (idempotency.Record, error) + func (s *Store) Inspect(ctx context.Context, key idempotency.Key) (record idempotency.Record, err error) + func (s *Store) Release(ctx context.Context, ownership idempotency.Ownership) (idempotency.Record, error)
Go to main page