event

type Byter interface {
	Bytes() []byte
}

type ConcreteEvent struct {
	Kind string    `json:"kind"`
	ID   uint64    `json:"id"`
	At   time.Time `json:"at"`
	Data any       `json:"data"`
}

type ContextSetter interface {
	SetContext(ctx context.Context)
}

type Event struct {
	// Kind can be either "patch" or "event".
	// A patch is a change to the cluster dataset.
	//
	// Event subscribers can maintain a clone of the
	// cluster dataset by:
	// installing a full dataset with received full dataset
	// or
	// patching a full dataset with received patch events
	Kind string `json:"kind"`

	// ID is a unique event id
	ID uint64 `json:"id"`

	// At is the time the event was published
	At time.Time `json:"at"`

	// Data is the free-format dataset of the event
	Data json.RawMessage `json:"data"`
}

type Kinder interface {
	Kind() string
}

type ReadCloser interface {
	Reader
	Close() error
}

type Reader interface {
	Read() (*Event, error)
}

type Stringer interface {
	String() string
}

type Timer interface {
	Time() time.Time
}