inmemes

package

v1.8.0 Latest Latest Go to latest Published: Jun 7, 2017 License: Apache-2.0 Imports: 3 Imported by: 0

Details

InMem provides a simple in memory implementation of an event store.

This section is empty.

This section is empty.

This section is empty.

type InMemoryEventStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

InMemoryEventStore implements the

func NewInMemoryEventStore() *InMemoryEventStore

NewInMemoryEventStore is a factory method for creating InMemoryEventStore instances.

func (im *InMemoryEventStore) RepublishAllEvents() error

RepublishAllEvents republishers events to subscribers.

func (im *InMemoryEventStore) RetrieveEvents(aggregateID string) ([]goes.Event, error)

RetrieveEvents retrieves the events in the event store assocaited with the given aggregate id.

func (im *InMemoryEventStore) StoreEvents(agg *goes.Aggregate) error

StoreEvents stores the events for the given aggregate in the event store.

func (im *InMemoryEventStore) SubscribeEvents(callback goes.EventPublishedCallback) goes.SubscriptionID

SubscribeEvents registers the provided callback as an event subscriber.

func (im *InMemoryEventStore) Unsubscribe(subscriptionID goes.SubscriptionID)

Unsubscribe removes the event subscription associated with the provided subscription id.