sqlstore

README

Running tests towards local database

To run the tests locally, you have to spin up a local postgres database, and set environment variables to let the test connect to the database.

Get postgres docker image

docker pull postgres

Run postgres image and forward port to localhost

docker run --name postgres -e POSTGRES_PASSWORD=your_password -p 5432:5432 postgres

Run tests

env PGUSER="postgres" PGPASSWORD="your_password" PGSSLMODE="disable" go test -v

Documentation

Index

• func BySequenceID(value string) eventsource.QueryOption
• func ByTimestamp(value int64) eventsource.QueryOption
• func ByType(value string) eventsource.QueryOption
• func New(db *sql.DB, tableName string) eventsource.Store
• func WithAscending() eventsource.QueryOption
• func WithDescending() eventsource.QueryOption
• func WithLimit(limit int) eventsource.QueryOption
• func WithOffset(offset int) eventsource.QueryOption
• type EventDB
• type PGXStore
  • func NewPgx(db driver.PgxPool, tableName string) PGXStore

Functions

func BySequenceID

func BySequenceID(value string) eventsource.QueryOption

func ByTimestamp

func ByTimestamp(value int64) eventsource.QueryOption

func ByType

func ByType(value string) eventsource.QueryOption

func New

func New(db *sql.DB, tableName string) eventsource.Store

New creates a new event source store.

func WithAscending

func WithAscending() eventsource.QueryOption

WithAscending will set the sorting order to ascending.

func WithDescending

func WithDescending() eventsource.QueryOption

WithDescending will set the sorting order to descending.

func WithLimit

func WithLimit(limit int) eventsource.QueryOption

WithLimit will limit the result.

func WithOffset

func WithOffset(offset int) eventsource.QueryOption

WithOffset will offset the result.

Types

type EventDB

type EventDB interface {
	Load(ctx context.Context, query string, args []interface{}) ([]eventsource.Record, error)
	NewTransaction(ctx context.Context, query string, records ...eventsource.Record) (eventsource.StoreTransaction, error)
}

type PGXStore

type PGXStore interface {
	eventsource.Store
	WithPostgresNotify() PGXStore
}

func NewPgx

func NewPgx(db driver.PgxPool, tableName string) PGXStore

NewPgx creates a new event source store.