eventstore

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

type EventStore interface {
	// Register a type for deserialization
	Register(t interface{})
	// Append append an event to the event store for the fact
	Append(aggregate string, content interface{}) error
	// Read the events for a fact from the beginning
	Read(aggregate string) ([]interface{}, error)
	// ListKeys will list all keys in the store
	ListKeys() ([]string, error)
	// ListKeysForAggregate will list all keys with the aggregate prefix
	ListKeysForAggregate(aggregate string) ([]string, error)
	// Close the event store
	Close() error
}

type Record struct {
	Id        ulid.ULID
	Timestamp time.Time
	Content   interface{}
}