ehclient

type AppendResult struct {
	Cursor Cursor
}

type ChildStreamCreated struct {
	Stream string
	// contains filtered or unexported fields
}

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

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

type DynamoDbOptions struct {
	AccessKeyId     string
	AccessKeySecret string
	RegionId        string
	TableName       string
}

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

type LogEntry struct {
	Stream    string   `json:"s"` // stream + version form the composite key
	Version   int64    `json:"v"`
	MetaEvent *string  `json:"meta_event"` // StreamStarted | ChildStreamCreated created | ...
	Events    []string `json:"e"`
}

type ReadResult struct {
	Entries   []LogEntry
	LastEntry Cursor // Entries[last].Version (use only if you handled all entries) or if no entries, the "after" in Read()
	More      bool   // whether there is more data to fetch
}

type Reader interface {
	Read(ctx context.Context, lastKnown Cursor) (*ReadResult, error)
}

type ReaderWriter interface {
	Reader
	Writer
}

type StreamStarted struct {
	Parent string
	// contains filtered or unexported fields
}

type Writer interface {
	Append(ctx context.Context, stream string, events []string) (*AppendResult, error)
	// used for transactional writes
	// returns *ErrOptimisticLockingFailed if stream had writes after you read it
	AppendAfter(ctx context.Context, after Cursor, events []string) (*AppendResult, error)
}