cockroachdb

Documentation

Index

• func WithFilterAppName(name string) storageOpt
• func WithLogger(l *slog.Logger) storageOpt
• func WithPushAppName(name string) storageOpt
• type CockroachDB
  • func New(config *Config, opts ...storageOpt) *CockroachDB
  • func (store *CockroachDB) Filter(ctx context.Context, filter *eventstore.Filter, reducer eventstore.Reducer) (err error)
  • func (store *CockroachDB) Push(ctx context.Context, aggregates ...eventstore.Aggregate) (err error)
  • func (store *CockroachDB) Ready(ctx context.Context) error
  • func (store *CockroachDB) Setup(ctx context.Context) error
• type Config

Functions

func WithFilterAppName

func WithFilterAppName(name string) storageOpt

func WithLogger

func WithLogger(l *slog.Logger) storageOpt

func WithPushAppName

func WithPushAppName(name string) storageOpt

Types

type CockroachDB

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

func New

func New(config *Config, opts ...storageOpt) *CockroachDB

func (*CockroachDB) Filter

func (store *CockroachDB) Filter(ctx context.Context, filter *eventstore.Filter, reducer eventstore.Reducer) (err error)

Filter implements eventstore.Eventstore

func (*CockroachDB) Push

func (store *CockroachDB) Push(ctx context.Context, aggregates ...eventstore.Aggregate) (err error)

Push implements eventstore.Eventstore

func (*CockroachDB) Ready

func (store *CockroachDB) Ready(ctx context.Context) error

Ready implements eventstore.Eventstore

func (*CockroachDB) Setup

func (store *CockroachDB) Setup(ctx context.Context) error

type Config

type Config struct {
	Pool *pgxpool.Pool
}