storagepostgres

Documentation

Index

• Constants
• func CreateSchema(ctx context.Context, pool *pgxpool.Pool) error
• func DropSchema(ctx context.Context, pool *pgxpool.Pool) error
• type Storage
  • func New(pool *pgxpool.Pool, streamName string, blankStream func() *stream.Stream, ...) Storage
  • func (s Storage) Drop(ctx context.Context, streamID uuid.UUID) error
  • func (s Storage) Load(ctx context.Context, streamID uuid.UUID) (*stream.Stream, error)
  • func (s Storage) NewStream() *stream.Stream
  • func (s Storage) Persist(ctx context.Context, ss *stream.Stream) (err error)
  • func (s Storage) StreamName() string
• type StorageOption
  • func WithCodec(c event.Encoding) StorageOption
  • func WithJournal() StorageOption

Constants

const Schema = `` /* 1036-byte string literal not displayed */

Functions

func CreateSchema

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

func DropSchema

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

Types

type Storage

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

func New

func New(
	pool *pgxpool.Pool,
	streamName string,
	blankStream func() *stream.Stream,
	opts ...StorageOption,
) Storage

func (Storage) Drop

func (s Storage) Drop(ctx context.Context, streamID uuid.UUID) error

func (Storage) Load

func (s Storage) Load(ctx context.Context, streamID uuid.UUID) (*stream.Stream, error)

func (Storage) NewStream

func (s Storage) NewStream() *stream.Stream

func (Storage) Persist

func (s Storage) Persist(ctx context.Context, ss *stream.Stream) (err error)

func (Storage) StreamName

func (s Storage) StreamName() string

type StorageOption

type StorageOption func(*Storage)

func WithCodec

func WithCodec(c event.Encoding) StorageOption

func WithJournal

func WithJournal() StorageOption