doubles

Apr 4, 2023

Changes in this version

+ type StubOnePhaseCommitProtocol struct

+ BeginTxFunc func(ctx context.Context) (context.Context, error)

+ CommitTxFunc func(ctx context.Context) error

+ RollbackTxFunc func(ctx context.Context) error

+ func (spy *StubOnePhaseCommitProtocol) BeginTx(ctx context.Context) (context.Context, error)

+ func (spy *StubOnePhaseCommitProtocol) CommitTx(ctx context.Context) error

+ func (spy *StubOnePhaseCommitProtocol) RollbackTx(ctx context.Context) error

+ type StubSubscriber struct

+ ErrorFunc func(ctx context.Context, err error) error

+ HandleFunc func(ctx context.Context, event interface{}) error

+ func (s StubSubscriber[Entity, ID]) Handle(ctx context.Context, event interface{}) error

+ func (s StubSubscriber[Entity, ID]) HandleCreateEvent(ctx context.Context, event pubsub.CreateEvent[Entity]) error

+ func (s StubSubscriber[Entity, ID]) HandleDeleteAllEvent(ctx context.Context, event pubsub.DeleteAllEvent) error

+ func (s StubSubscriber[Entity, ID]) HandleDeleteByIDEvent(ctx context.Context, event pubsub.DeleteByIDEvent[ID]) error

+ func (s StubSubscriber[Entity, ID]) HandleError(ctx context.Context, err error) error

+ func (s StubSubscriber[Entity, ID]) HandleUpdateEvent(ctx context.Context, event pubsub.UpdateEvent[Entity]) error