es

type Error string

type Event interface{}

type Identity struct {
	UserID    string `json:"_au"`
	UserOrgID string `json:"_ao"`
	UserRole  string `json:"_ar"`
}

type Model struct {
	EventID  string    `json:"_e"`
	Version  int       `json:"_v"`
	At       time.Time `json:"_t"`
	Identity Identity  `json:"_i"`
}

type PublisherOption func() error

type Record struct {
	At   time.Time
	Type string
	Data string
}

type Streamer interface {
	Commit(partitionKey string, event Event) error
	Push(ctx context.Context) error
	Clear()
}

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