test

Documentation

Index

• type EntityCreatedEvent
  • func (e *EntityCreatedEvent) GetType() string
• type MockEntity
  • func (e *MockEntity) GetId() string
• type MockProvider
  • func (p *MockProvider) Close()
  • func (p *MockProvider) FetchAllEvents(batch int) (<-chan []goeh.Event, error)
  • func (p *MockProvider) SendEvents(events []goeh.Event) error
  • func (p *MockProvider) SetInitEvents(events []goeh.Event)
• type MockRepository
  • func (r *MockRepository) CreateFakeEvent()
  • func (r *MockRepository) Replay(events []goeh.Event) error

Types

type EntityCreatedEvent

type EntityCreatedEvent struct {
	goeh.EventData
	CreateTime string `json:"createTime"`
	Version    int32  `json:"version"`
	Message    string `json:"message"`
}

EntityCreatedEvent ...

func (*EntityCreatedEvent) GetType

func (e *EntityCreatedEvent) GetType() string

GetType ...

type MockEntity

type MockEntity struct {
	ID string

	Message string
}

MockEntity ,,,

func (*MockEntity) GetId

func (e *MockEntity) GetId() string

GetId ...

type MockProvider

type MockProvider struct {
	Events []goeh.Event
	// contains filtered or unexported fields
}

MockProvider ...

func (*MockProvider) Close

func (p *MockProvider) Close()

Close ...

func (*MockProvider) FetchAllEvents

func (p *MockProvider) FetchAllEvents(batch int) (<-chan []goeh.Event, error)

FetchAllEvents ...

func (*MockProvider) SendEvents

func (p *MockProvider) SendEvents(events []goeh.Event) error

SendEvents ...

func (*MockProvider) SetInitEvents

func (p *MockProvider) SetInitEvents(events []goeh.Event)

SetInitEvents ...

type MockRepository

type MockRepository struct {
	*cerk.MemoryRepository
}

MockRepository ...

func (*MockRepository) CreateFakeEvent

func (r *MockRepository) CreateFakeEvent()

CreateFakeEvent

func (*MockRepository) Replay

func (r *MockRepository) Replay(events []goeh.Event) error

Replay ...