postgres

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 15, 2023 License: MIT Imports: 13 Imported by: 0

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 FromEvent added in v0.3.0

func FromEvent(event eventsource.Event) (*Event, error)

func (*Event) ToReadModel

func (e *Event) ToReadModel() eventsource.EventReadModel

type Options

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

func DefaultOptions

func DefaultOptions() *Options

func (*Options) IsZero

func (o *Options) IsZero() bool

func (*Options) Validate

func (o *Options) Validate() error

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL