Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewEventStore ¶
func NewEventStore(tracer trace.Tracer, options *Options) (eventsource.EventStore, error)
Types ¶
type Event ¶
type Event struct { ID sql.NullString Type sql.NullString OccurredAt sql.NullTime RegisteredAt sql.NullTime AggregateID sql.NullString AggregateType sql.NullString AggregateVersion sql.NullInt64 Data json.RawMessage Metadata json.RawMessage }
func (*Event) ToReadModel ¶
func (e *Event) ToReadModel() eventsource.EventReadModel
type Options ¶
type Options struct {
// contains filtered or unexported fields
}
func DefaultOptions ¶
func DefaultOptions() *Options
type OptionsBuilder ¶
type OptionsBuilder struct {
// contains filtered or unexported fields
}
func NewOptionsBuilder ¶
func NewOptionsBuilder() *OptionsBuilder
func (*OptionsBuilder) Build ¶
func (b *OptionsBuilder) Build() *Options
func (*OptionsBuilder) WithEventStorageTableName ¶
func (b *OptionsBuilder) WithEventStorageTableName(name string) *OptionsBuilder
func (*OptionsBuilder) WithSchemaName ¶
func (b *OptionsBuilder) WithSchemaName(s string) *OptionsBuilder
func (*OptionsBuilder) WithSnapshotStorageTableName ¶
func (b *OptionsBuilder) WithSnapshotStorageTableName(name string) *OptionsBuilder
type Snapshot ¶
type Snapshot struct { AggregateID sql.NullString AggregateType sql.NullString AggregateVersion sql.NullInt64 TakenAt sql.NullTime Data json.RawMessage }
func FromSnapshot ¶ added in v0.3.0
func FromSnapshot(s eventsource.Snapshot) *Snapshot
func (*Snapshot) ToSnapshot ¶
func (s *Snapshot) ToSnapshot() *eventsource.Snapshot
Click to show internal directories.
Click to hide internal directories.