idempotency

type IdempotencyRequest struct {
	Key             string        `db:"idempotency_key"`
	Status          Status        `db:"status"`
	ResponseCode    sql.NullInt64 `db:"response_code"`
	ResponseHeaders []byte        `db:"response_headers"`
	ResponseBody    []byte        `db:"response_body"`
	CreatedAt       time.Time     `db:"created_at"`
	UpdatedAt       sql.NullTime  `db:"updated_at"`
}

type IdempotencyStore interface {
	io.Closer
	Get(ctx context.Context, key string) (*IdempotencyRequest, error)
	Create(ctx context.Context, key string) error
	Update(ctx context.Context, key string, code int, headers, body []byte) error
	Error(ctx context.Context, key string, code int, headers, body []byte) error
	Cleanup(ctx context.Context) error
	DB() *sqlx.DB
}

type Status string