postgres

Documentation

Index

• type ErrUnknownTx
  • func (err ErrUnknownTx) Error() string
• type Storage
  • func NewFromConn(conn *sql.DB) (*Storage, error)
  • func NewFromUrl(databaseUrl string) (*Storage, error)
  • func (store *Storage) Begin(ctx context.Context) (store.Tx, error)
  • func (store *Storage) DeleteSnapshot(ctx context.Context, id streams.Id, snapshotId string) error
  • func (store *Storage) ReadRecords(ctx context.Context, id streams.Id, from int64, to, limit int64) ([]record.Record, error)
  • func (store *Storage) ReadSnapshot(ctx context.Context, id streams.Id, snapshotId string) (record.Snapshot, error)
  • func (store *Storage) SetSubscriptionPosition(storeTx store.Tx, id streams.Id, position store.SubscriptionPosition) error
  • func (store *Storage) SubscriptionPositionLock(storeTx store.Tx, id streams.Id, subscriptionIds ...string) ([]store.SubscriptionPosition, error)
  • func (store *Storage) UpdateSnapshot(ctx context.Context, id streams.Id, snapshotId string, ...) error
  • func (store *Storage) WriteRecords(ctx context.Context, id streams.Id, data ...record.Data) ([]record.Record, error)
  • func (store *Storage) WriteRecordsFrom(ctx context.Context, id streams.Id, position int64, data ...record.Data) ([]record.Record, error)

Types

type ErrUnknownTx

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

func (ErrUnknownTx) Error

func (err ErrUnknownTx) Error() string

type Storage

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

func NewFromConn

func NewFromConn(conn *sql.DB) (*Storage, error)

func NewFromUrl

func NewFromUrl(databaseUrl string) (*Storage, error)

func (*Storage) Begin

func (store *Storage) Begin(ctx context.Context) (store.Tx, error)

func (*Storage) DeleteSnapshot

func (store *Storage) DeleteSnapshot(ctx context.Context, id streams.Id, snapshotId string) error

func (*Storage) ReadRecords

func (store *Storage) ReadRecords(ctx context.Context, id streams.Id, from int64, to, limit int64) ([]record.Record, error)

func (*Storage) ReadSnapshot

func (store *Storage) ReadSnapshot(ctx context.Context, id streams.Id, snapshotId string) (record.Snapshot, error)

func (*Storage) SetSubscriptionPosition

func (store *Storage) SetSubscriptionPosition(storeTx store.Tx, id streams.Id, position store.SubscriptionPosition) error

func (*Storage) SubscriptionPositionLock

func (store *Storage) SubscriptionPositionLock(storeTx store.Tx, id streams.Id, subscriptionIds ...string) ([]store.SubscriptionPosition, error)

func (*Storage) UpdateSnapshot

func (store *Storage) UpdateSnapshot(ctx context.Context, id streams.Id, snapshotId string, snapshot record.Snapshot) error

func (*Storage) WriteRecords

func (store *Storage) WriteRecords(ctx context.Context, id streams.Id, data ...record.Data) ([]record.Record, error)

func (*Storage) WriteRecordsFrom

func (store *Storage) WriteRecordsFrom(ctx context.Context, id streams.Id, position int64, data ...record.Data) ([]record.Record, error)