committable

Feb 26, 2024

Changes in this version

+ var ApphashKey = []byte("apphash")

+ var IdempotencyKeyKey = []byte("idempotencyKey")

+ type CommittableStore interface

+ Get func(ctx context.Context, key []byte, sync bool) ([]byte, error)

+ Savepoint func() (sql.Savepoint, error)

+ Set func(ctx context.Context, key []byte, value []byte) error

+ type SavepointCommittable struct

+ func New(db CommittableStore) *SavepointCommittable

+ func (a *SavepointCommittable) Begin(ctx context.Context, idempotencyKey []byte) error

+ func (a *SavepointCommittable) BeginRecovery(ctx context.Context, idempotencyKey []byte) error

+ func (a *SavepointCommittable) Cancel(ctx context.Context) error

+ func (a *SavepointCommittable) Commit(ctx context.Context, idempotencyKey []byte) ([]byte, error)

+ func (a *SavepointCommittable) Register(value []byte) error

+ func (a *SavepointCommittable) SetIDFunc(idFn func() ([]byte, error))

+ func (a *SavepointCommittable) Skip() bool