eventflow

type Aggregator interface {
	Apply(Event) error
}

type Bus interface {
	Publisher
	Subscriber
}

type Commander interface {
	Command(interface{}) (Event, error)
}

type Event struct {
	// primary identifier for aggregate, like "SomeAggregate" or narrowed "<userId>:SomeAggregate"
	// should be indexed
	RowID string
	// additional columns for aggregate, should be used for segregation/grouping
	// Example: "entity_name" => "foo", "other_id" => "abcd123"
	// should be indexed because most queries would sort/group on them
	Columns map[string]interface{}
	// type of the event, used by aggregators on subscribe
	Type EventType
	// should be indexed because most queries would sort by timestamp
	Timestamp int64
	// serialized event payload
	Data []byte
	// serializer/mapper used to encode data
	Mapper string
}

type EventType string

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

type Publisher interface {
	Publish(Event) error
}

type Snapshot struct {
	// primary identifier for aggregate, like "SomeAggregate" or narrowed "<userId>:SomeAggregate"
	// should be indexed
	RowID string
	// should be indexed because most queries would sort by timestamp
	Timestamp int64
	// serialized state of aggregates
	Data []byte
	// serializer/mapper used to encode data
	Mapper string
}

type Store interface {
	Save(event Event) error
}

type Subscriber interface {
	Subscribe(Aggregator, ...EventType)
}