domain

type Aggregate interface {
	Events() []Event
}

type Company struct {
	Id   string
	Name string
	// contains filtered or unexported fields
}

type CompanyCreated struct {
	EventRoot   `bson:",inline"`
	CompanyName string `bson:"companyName" json:"companyName"`
}

type CompanyNameChanged struct {
	EventRoot   `bson:",inline"`
	CompanyName string `bson:"companyName" json:"companyName"`
}

type Event interface {
	Root() EventRoot
	FromMap(mapEvent map[string]interface{}) Event
}

type EventPublisher interface {
	Dispatch(events []Event) (err error)
}

type EventRoot struct {
	EventType   string  `bson:"eventType" json:"eventType"`
	Version     float32 `bson:"eventVersrsionion" json:"eventVe"`
	Timestamp   int64   `bson:"eventTimestamp" json:"eventTimestamp"`
	AggregateId string  `bson:"aggregateId" json:"aggregateId"`
}

type EventStore interface {
	Append(events []Event, aggregateType string) (err error)
	EventsOf(aggregateId string, aggregateType string) (err error, events []map[string]interface{})
}