store

Documentation

Index

• type Event
• type ReadEvent
• type StreamPosition
• type WriteEvent

Types

type Event

type Event struct {
	Id       uuid.UUID  `json:"id"`
	Type     event.Type `json:"type"`
	Data     []byte     `json:"data"`
	Metadata []byte     `json:"metadata"`
}

type ReadEvent

type ReadEvent struct {
	Event

	Position uint64    `json:"position"`
	Created  time.Time `json:"created"`
}

type StreamPosition

type StreamPosition uint64

const (
	STREAM_START StreamPosition = 0
	STREAM_END   StreamPosition = math.MaxUint64
)

type WriteEvent

type WriteEvent struct {
	Event

	Status chan<- event.WriteStatus
}