Documentation ¶
Index ¶
- func EventForwarderWorker(t *testing.T, ctx context.Context, logger *slog.Logger, ...)
- type Balance
- type MockKVStore
- type ProjectionMock
- func (p *ProjectionMock[K]) BalanceByID(id K) (Balance, bool)
- func (*ProjectionMock[K]) CatchUpOptions() projection.CatchUpOptions
- func (p *ProjectionMock[K]) Events() []*sink.Message[K]
- func (p *ProjectionMock[K]) Handle(ctx context.Context, e *sink.Message[K]) error
- func (p *ProjectionMock[K]) Name() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EventForwarderWorker ¶
func EventForwarderWorker(t *testing.T, ctx context.Context, logger *slog.Logger, dbConfig shared.DBConfig, sinker sink.Sinker[ids.AggID])
EventForwarderWorker creates workers that listen to database changes, transform them to events and publish them into the message bus.
Types ¶
type MockKVStore ¶
type MockKVStore struct {
// contains filtered or unexported fields
}
func (*MockKVStore) Data ¶ added in v0.38.1
func (s *MockKVStore) Data() map[string]string
type ProjectionMock ¶
type ProjectionMock[K eventsourcing.ID] struct { // contains filtered or unexported fields }
func NewProjectionMock ¶
func NewProjectionMock[K eventsourcing.ID](name string, codec *jsoncodec.Codec[K]) *ProjectionMock[K]
func (*ProjectionMock[K]) BalanceByID ¶
func (p *ProjectionMock[K]) BalanceByID(id K) (Balance, bool)
func (*ProjectionMock[K]) CatchUpOptions ¶
func (*ProjectionMock[K]) CatchUpOptions() projection.CatchUpOptions
func (*ProjectionMock[K]) Events ¶
func (p *ProjectionMock[K]) Events() []*sink.Message[K]
func (*ProjectionMock[K]) Name ¶
func (p *ProjectionMock[K]) Name() string
Click to show internal directories.
Click to hide internal directories.