ehreader

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

type DynamoSnapshotItem struct {
	Stream  string `json:"s"` // stream + context form the composite key
	Context string `json:"c"` // different software can read the same stream,
	Version int64  `json:"v"` // we conditionally put updates into DynamoDB as not to overwrite advanced state
	Data    []byte `json:"d"` // actual snapshot data
}

type EventProcessorHandler func(
	cur ehclient.Cursor,
	handleEvent func(ehevent.Event) error,
	commit func(ehclient.Cursor) error,
) error

type EventsProcessor interface {
	/*	returns error if:

		- failed to start a tx (user code)
		- failed to resolve the version (user code)
		- handle (infra code) failed which itself contains:
		  * error for handleEvent()
		  * commit()
		  * etc.
	*/
	ProcessEvents(ctx context.Context, handle EventProcessorHandler) error
	GetEventTypes() ehevent.Allocators
}

type EventsProcessorSnapshotCapability interface {
	InstallSnapshot(*Snapshot) error
	Snapshot() (*Snapshot, error)
}

type EventsProcessorWithSnapshots interface {
	EventsProcessor
	EventsProcessorSnapshotCapability
}

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

type Snapshot struct {
	Cursor ehclient.Cursor
	Data   []byte
}

type SnapshotStore interface {
	// NOTE: returns os.ErrNotExist if snapshot is not found (which MUST not be
	//       considered an actual error)
	LoadSnapshot(ctx context.Context, cursor ehclient.Cursor) (*Snapshot, error)
	StoreSnapshot(ctx context.Context, snapshot Snapshot) error
}

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

type TenantCtx struct {
	Tenant
	Client ehclient.ReaderWriter
}

type TenantCtxWithSnapshots struct {
	Tenant
	Client        ehclient.ReaderWriter
	SnapshotStore SnapshotStore
}