store

type Event struct {
	Type      string         `json:"type"`
	Data      []byte         `json:"data"`
	Metadata  []byte         `json:"metadata"`
	ID        uuid.UUID      `json:"id"`
	Shard     string         `json:"shard_key"`
	GlobalPos StreamPosition `json:"global_pos"`
}

type ReadEvent struct {
	Created time.Time `json:"created"`
	Event
	Position StreamPosition `json:"position"`
}

type StreamPosition uint64

type WriteEvent struct {
	Status chan<- WriteStatus
	Event
}

type WriteStatus struct {
	Time     time.Time
	Error    error
	Position StreamPosition
}