Versions in this module Expand all Collapse all v0 v0.3.6 Oct 7, 2021 Changes in this version + type EventBus struct + func NewEventBus() *EventBus + func (bus *EventBus) PublishEvents(events []*goengine.DomainMessage) error + func (bus *EventBus) ReceiveEvents(options goengine.VersionedEventReceiverOptions) error + type EventStore struct + func NewEventStore() *EventStore + func (s *EventStore) Append(events *goengine.EventStream) error + func (s *EventStore) CountEventsFor(streamName goengine.StreamName, id string) (int64, error) + func (s *EventStore) FromVersion(streamName goengine.StreamName, id string, version int) (*goengine.EventStream, error) + func (s *EventStore) GetEventsFor(streamName goengine.StreamName, id string) (*goengine.EventStream, error)
Go to main page