doubles

Documentation

Index

• type StubOnePhaseCommitProtocol
  • 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
  • func (s StubSubscriber[Ent, ID]) Handle(ctx context.Context, event interface{}) error
  • func (s StubSubscriber[Ent, ID]) HandleCreateEvent(ctx context.Context, event frameless.CreateEvent[Ent]) error
  • func (s StubSubscriber[Ent, ID]) HandleDeleteAllEvent(ctx context.Context, event frameless.DeleteAllEvent) error
  • func (s StubSubscriber[Ent, ID]) HandleDeleteByIDEvent(ctx context.Context, event frameless.DeleteByIDEvent[ID]) error
  • func (s StubSubscriber[Ent, ID]) HandleError(ctx context.Context, err error) error
  • func (s StubSubscriber[Ent, ID]) HandleUpdateEvent(ctx context.Context, event frameless.UpdateEvent[Ent]) error

Types

type StubOnePhaseCommitProtocol

type StubOnePhaseCommitProtocol struct {
	frameless.OnePhaseCommitProtocol
	BeginTxFunc    func(ctx context.Context) (context.Context, error)
	CommitTxFunc   func(ctx context.Context) error
	RollbackTxFunc func(ctx context.Context) error
}

func (*StubOnePhaseCommitProtocol) BeginTx

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

func (*StubOnePhaseCommitProtocol) CommitTx

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

func (*StubOnePhaseCommitProtocol) RollbackTx

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

type StubSubscriber

type StubSubscriber[Ent any, ID any] struct {
	HandleFunc func(ctx context.Context, event interface{}) error
	ErrorFunc  func(ctx context.Context, err error) error
}

func (StubSubscriber[Ent, ID]) Handle

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

func (StubSubscriber[Ent, ID]) HandleCreateEvent

func (s StubSubscriber[Ent, ID]) HandleCreateEvent(ctx context.Context, event frameless.CreateEvent[Ent]) error

func (StubSubscriber[Ent, ID]) HandleDeleteAllEvent

func (s StubSubscriber[Ent, ID]) HandleDeleteAllEvent(ctx context.Context, event frameless.DeleteAllEvent) error

func (StubSubscriber[Ent, ID]) HandleDeleteByIDEvent

func (s StubSubscriber[Ent, ID]) HandleDeleteByIDEvent(ctx context.Context, event frameless.DeleteByIDEvent[ID]) error

func (StubSubscriber[Ent, ID]) HandleError

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

func (StubSubscriber[Ent, ID]) HandleUpdateEvent

func (s StubSubscriber[Ent, ID]) HandleUpdateEvent(ctx context.Context, event frameless.UpdateEvent[Ent]) error