inmemory

Documentation

Index

• type InMemoryEventBus
  • func NewInMemoryEventBus() *InMemoryEventBus
  • func (bus *InMemoryEventBus) PublishEvents(events []*goengine.DomainMessage) error
  • func (bus *InMemoryEventBus) ReceiveEvents(options goengine.VersionedEventReceiverOptions) error
• type InMemoryEventStore
  • func NewEventStore() *InMemoryEventStore
  • func (s *InMemoryEventStore) Append(events *goengine.EventStream) error
  • func (s *InMemoryEventStore) CountEventsFor(streamName goengine.StreamName, id string) (int, error)
  • func (s *InMemoryEventStore) FromVersion(streamName goengine.StreamName, id string, version int) (*goengine.EventStream, error)
  • func (s *InMemoryEventStore) GetEventsFor(streamName goengine.StreamName, id string) (*goengine.EventStream, error)

Types

type InMemoryEventBus

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

InMemoryEventBus provides an inmemory implementation of the VersionedEventPublisher VersionedEventReceiver interfaces

func NewInMemoryEventBus

func NewInMemoryEventBus() *InMemoryEventBus

NewInMemoryEventBus constructor

func (*InMemoryEventBus) PublishEvents

func (bus *InMemoryEventBus) PublishEvents(events []*goengine.DomainMessage) error

PublishEvents publishes events to the event bus

func (*InMemoryEventBus) ReceiveEvents

func (bus *InMemoryEventBus) ReceiveEvents(options goengine.VersionedEventReceiverOptions) error

ReceiveEvents starts a go routine that monitors incoming events and routes them to a receiver channel specified within the options

type InMemoryEventStore

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

func NewEventStore

func NewEventStore() *InMemoryEventStore

func (*InMemoryEventStore) Append

func (s *InMemoryEventStore) Append(events *goengine.EventStream) error

func (*InMemoryEventStore) CountEventsFor

func (s *InMemoryEventStore) CountEventsFor(streamName goengine.StreamName, id string) (int, error)

func (*InMemoryEventStore) FromVersion

func (s *InMemoryEventStore) FromVersion(streamName goengine.StreamName, id string, version int) (*goengine.EventStream, error)

func (*InMemoryEventStore) GetEventsFor

func (s *InMemoryEventStore) GetEventsFor(streamName goengine.StreamName, id string) (*goengine.EventStream, error)