Documentation ¶
Index ¶
Constants ¶
View Source
const ( EVENTS_BUCKET = "EVENTS" EVENT_METADATA_BUCKET = "EVENT_METADATA" AGGREGATES_BUCKET = "AGGREGATES_BUCKET" )
View Source
const OFFSET_BUCKET = "OFFSETS"
Variables ¶
This section is empty.
Functions ¶
Types ¶
type BoltEventStore ¶
type BoltEventStore struct {
// contains filtered or unexported fields
}
InMemory implementation of the event store
func NewBoltStore ¶
func NewBoltStore(path string) *BoltEventStore
func (*BoltEventStore) GetEvent ¶
func (store *BoltEventStore) GetEvent(id string) Event
func (*BoltEventStore) GetEventMetaDataFrom ¶
func (store *BoltEventStore) GetEventMetaDataFrom(offset, count int) []EventMetaData
func (*BoltEventStore) GetEvents ¶
func (store *BoltEventStore) GetEvents(aggregateId string) []Event
func (*BoltEventStore) SaveEvents ¶
func (store *BoltEventStore) SaveEvents(aggregateId string, events []Event) error
type BoltOffsetStore ¶
type BoltOffsetStore struct {
// contains filtered or unexported fields
}
func (*BoltOffsetStore) GetLastOffset ¶
func (store *BoltOffsetStore) GetLastOffset() (int, error)
func (*BoltOffsetStore) SaveOffset ¶
func (store *BoltOffsetStore) SaveOffset(value int) error
Click to show internal directories.
Click to hide internal directories.