The highest tagged major version is v2.

inmemory

package

v0.3.6 Latest Latest Go to latest Published: Oct 7, 2021 License: MIT Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

EventBus provides an in memory implementation of the VersionedEventPublisher VersionedEventReceiver interfaces

func NewEventBus() *EventBus

NewEventBus ...

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

PublishEvents publishes events to the event bus

func (bus *EventBus) 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 EventStore struct {
	// contains filtered or unexported fields
}

EventStore ...

func NewEventStore() *EventStore

NewEventStore ...

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

Append ...

func (s *EventStore) CountEventsFor(streamName goengine.StreamName, id string) (int64, error)

CountEventsFor ...

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

FromVersion ...

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

GetEventsFor ...