example

package

v1.1.0 Latest Latest Go to latest Published: Dec 27, 2020 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/go-event-store/pg

Documentation ¶

Index ¶

Constants
Variables
func CreateAggregate(ctx context.Context, pool *pgxpool.Pool)
func CreateProjection(ctx context.Context, pool *pgxpool.Pool)
func CreateQuery(ctx context.Context, pool *pgxpool.Pool)
func CreateReadModelProjection(ctx context.Context, pool *pgxpool.Pool)
func Logger(_ context.Context, event eventstore.DomainEvent) (eventstore.DomainEvent, error)
func Transform(_ context.Context, event eventstore.DomainEvent) (eventstore.DomainEvent, error)
type BarEvent
type FooAggregate
- func NewFooAggregate() *FooAggregate
- func NewFooAggregateFromHistory(events eventstore.DomainEventIterator) *FooAggregate
- func (f *FooAggregate) WhenFooEvent(e FooEvent)
type FooEvent
type FooReadModel
- func NewFooReadModel(client *pg.Client) *FooReadModel
type FooRepository
- func NewFooRepository(streamName string, eventStore *eventstore.EventStore) *FooRepository
- func (r FooRepository) Get(ctx context.Context, fooID uuid.UUID) (*FooAggregate, error)
- func (r FooRepository) Save(ctx context.Context, foo *FooAggregate) error

Constants ¶

View Source

const (
	DatabaseURL = "postgres://user:password@localhost/event-store?sslmode=disable"

	FooStream    = "foo-stream"
	FooEventName = "FooEvent"
	BarEventName = "BarEvent"
)

View Source

const FooReadmodelTable = "app_foo"

Variables ¶

View Source

var ErrFooNotFound = errors.New("Foo not found")

Functions ¶

func CreateAggregate ¶

func CreateAggregate(ctx context.Context, pool *pgxpool.Pool)

func CreateProjection ¶

func CreateProjection(ctx context.Context, pool *pgxpool.Pool)

func CreateQuery ¶

func CreateQuery(ctx context.Context, pool *pgxpool.Pool)

func CreateReadModelProjection ¶

func CreateReadModelProjection(ctx context.Context, pool *pgxpool.Pool)

func Logger ¶

func Logger(_ context.Context, event eventstore.DomainEvent) (eventstore.DomainEvent, error)

func Transform ¶

func Transform(_ context.Context, event eventstore.DomainEvent) (eventstore.DomainEvent, error)

Types ¶

type BarEvent ¶

type BarEvent struct {
	Bar string
}

type FooAggregate ¶

type FooAggregate struct {
	eventstore.BaseAggregate

	Foo string
}

func NewFooAggregate ¶

func NewFooAggregate() *FooAggregate

func NewFooAggregateFromHistory ¶

func NewFooAggregateFromHistory(events eventstore.DomainEventIterator) *FooAggregate

func (*FooAggregate) WhenFooEvent ¶

func (f *FooAggregate) WhenFooEvent(e FooEvent)

type FooEvent ¶

type FooEvent struct {
	Foo string
}

type FooReadModel ¶

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

func NewFooReadModel ¶

func NewFooReadModel(client *pg.Client) *FooReadModel

func (*FooReadModel) Delete ¶

func (f *FooReadModel) Delete(ctx context.Context) error

func (*FooReadModel) Init ¶

func (f *FooReadModel) Init(ctx context.Context) error

func (*FooReadModel) IsInitialized ¶

func (f *FooReadModel) IsInitialized(ctx context.Context) (bool, error)

func (*FooReadModel) Persist ¶

func (f *FooReadModel) Persist(ctx context.Context) error

func (*FooReadModel) Reset ¶

func (f *FooReadModel) Reset(ctx context.Context) error

func (*FooReadModel) Stack ¶

func (f *FooReadModel) Stack(method string, args ...map[string]interface{})

type FooRepository ¶

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

func NewFooRepository ¶

func NewFooRepository(streamName string, eventStore *eventstore.EventStore) *FooRepository

func (FooRepository) Get ¶

func (r FooRepository) Get(ctx context.Context, fooID uuid.UUID) (*FooAggregate, error)

func (FooRepository) Save ¶

func (r FooRepository) Save(ctx context.Context, foo *FooAggregate) error

Source Files ¶

View all Source files

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