eventStore

Documentation

Index

• type MongoEventStore
  • func NewMongoEventStore(config *config.Configuration) (eventStore *MongoEventStore)
  • func (s *MongoEventStore) Append(events []domain.Event, aggregateType string) (err error)
  • func (s *MongoEventStore) EventsOf(aggregateId string, aggregateType string) (err error, events []map[string]interface{})

Types

type MongoEventStore

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

MongoEventStore is the anchor struct for mongoDB repository implementation methods.

func NewMongoEventStore

func NewMongoEventStore(config *config.Configuration) (eventStore *MongoEventStore)

func (*MongoEventStore) Append

func (s *MongoEventStore) Append(events []domain.Event, aggregateType string) (err error)

Appends to events of a company

func (*MongoEventStore) EventsOf

func (s *MongoEventStore) EventsOf(aggregateId string, aggregateType string) (err error, events []map[string]interface{})

GetEvent retrieves the most recent event for a given drone.