store

type EventStore ¶

type EventStore struct {
	Filename          string
	UseCompression    bool
	SnapshotDirectory string
	// contains filtered or unexported fields
}

func (es *EventStore) PersistEvent(e core.Event) error

func (es *EventStore) PersistSnapshot(zoneID uuid.UUID, seqNum uint64, snapEvents []core.Event) error

func (es *EventStore) RetrieveAll() (<-chan rpc.Response, error)

func (es *EventStore) RetrieveAllEventsForZone(zoneID uuid.UUID) (<-chan rpc.Response, error)

func (es *EventStore) RetrieveEventsUpToSequenceNumForZone(endNum uint64, zoneID uuid.UUID) (<-chan rpc.Response, error)

type FromDomainer ¶

type FromDomainer interface {
	FromDomain(core.Event)
	Header() eventHeader
}

type IntentLogger ¶

type IntentLogger struct {
	Filename string
	// contains filtered or unexported fields
}

IntentLogger is a change-intent-log, useful for implementing transactional semantics for a higher-level store. By first making a record of the changes you intend to make (and optionally a record of how to un-do those changes), and later making a record of the successful completion of those changes, IntentLogger has enough information to later detect and give you context for any changes that weren't complete at the time of a crash.

Normal use works like this:

1- create a new log using IntentLogger.Open()

2- write an intent using IntentLogger.WriteIntent(); this returns a transaction ID you must store

3- execute your intended changes as usual

4- confirm the original intent has been completed using IntentLogger.ConfirmIntentCompletion()

5- (optional) close the log using IntentLogger.Close()

6- on re-start, call IntentLogger.Open() again; this time, the callback func you provide will be called for each intent that was successfully written to the log but never marked as complete later on

Some notes on semantics:

* WriteIntent() and ConfirmIntentCompletion() call io.Sync() before returning.

* After each successful call to the handler provided to Open(), it automatically calls ConfirmIntentCompletion().

* Open() will truncate any trailing+incomplete entries it finds while reading the input stream.

func (il *IntentLogger) Close()

func (il IntentLogger) ConfirmIntentCompletion(transactionID uuid.UUID) error

func (il *IntentLogger) Open(handler func(redo, undo []core.Event) error) error

func (il IntentLogger) WriteIntent(redo, undo []core.Event) (uuid.UUID, error)

type ToDomainer ¶

type ToDomainer interface {
	ToDomain() core.Event
	SetHeader(eventHeader)
}