integration

Documentation

Index

• func EventForwarderWorker(t *testing.T, ctx context.Context, logger *slog.Logger, ...)
• type Balance
• type KV
• type MockKVStore
  • func (s *MockKVStore) Data() map[string]string
  • func (s *MockKVStore) Get(_ context.Context, key string) (_ string, er error)
  • func (s *MockKVStore) Put(_ context.Context, key, token string) (er error)
  • func (s *MockKVStore) Puts() []KV
• type ProjectionMock
  • func NewProjectionMock[K eventsourcing.ID](name string, codec *jsoncodec.Codec[K]) *ProjectionMock[K]
  • 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, msg projection.Message[K]) error
  • func (p *ProjectionMock[K]) Name() string

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 Balance

type Balance struct {
	Name   string
	Amount int64
}

type KV

type KV struct {
	Key, Value string
}

type MockKVStore

type MockKVStore struct {
	// contains filtered or unexported fields
}

func (*MockKVStore) Data

func (s *MockKVStore) Data() map[string]string

func (*MockKVStore) Get

func (s *MockKVStore) Get(_ context.Context, key string) (_ string, er error)

func (*MockKVStore) Put

func (s *MockKVStore) Put(_ context.Context, key, token string) (er error)

func (*MockKVStore) Puts

func (s *MockKVStore) Puts() []KV

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]) Handle

func (p *ProjectionMock[K]) Handle(ctx context.Context, msg projection.Message[K]) error

func (*ProjectionMock[K]) Name

func (p *ProjectionMock[K]) Name() string