idempotency

Jul 8, 2025

Changes in this version

type IdempotencyStore

+ Error func(ctx context.Context, key string, code int, headers, body []byte) error

Jul 8, 2025

Changes in this version

type Status

+ const Error

Jul 8, 2025

Changes in this version

+ type IdempotencyRequest struct

+ CreatedAt time.Time

+ Key string

+ ResponseBody []byte

+ ResponseCode sql.NullInt64

+ ResponseHeaders []byte

+ Status Status

+ UpdatedAt sql.NullTime

+ type IdempotencyStore interface

+ Cleanup func(ctx context.Context) error

+ Create func(ctx context.Context, key string) error

+ DB func() *sqlx.DB

+ Get func(ctx context.Context, key string) (*IdempotencyRequest, error)

+ Update func(ctx context.Context, key string, code int, headers, body []byte) error

+ func NewIdempotencyStore(db *sqlx.DB, cleanUpThresholdInDays int) (IdempotencyStore, error)

+ type Status string

+ const Completed

+ const Pending