postgreswrapper

Documentation

Index

• func CleanUp(t testing.TB, wrapper Wrapper)
• func CleanUpBookEvents(wrapper Wrapper, bookID uuid.UUID) (rowsAffected int64, err error)
• func GetGreatestOccurredAtTimeFromDB(t testing.TB, wrapper Wrapper) time.Time
• func GetLatestBookIDFromDB(t testing.TB, wrapper Wrapper) uuid.UUID
• func GuardThatThereAreEnoughFixtureEventsInStore(wrapper Wrapper, expectedNumEvents int)
• func OptimizeDBWhileBenchmarking(wrapper Wrapper) error
• func TryCreateEventStoreWithTableName(t testing.TB, options ...Option) error
• type PGXPoolWrapper
  • func (e *PGXPoolWrapper) Close()
  • func (e *PGXPoolWrapper) GetEventStore() EventStore
• type SQLDBWrapper
  • func (e *SQLDBWrapper) Close()
  • func (e *SQLDBWrapper) GetEventStore() EventStore
• type SQLXWrapper
  • func (e *SQLXWrapper) Close()
  • func (e *SQLXWrapper) GetEventStore() EventStore
• type Wrapper
  • func CreateWrapperWithBenchmarkConfig(t testing.TB) Wrapper
  • func CreateWrapperWithTestConfig(t testing.TB, options ...Option) Wrapper

Functions

func CleanUp

func CleanUp(t testing.TB, wrapper Wrapper)

func CleanUpBookEvents

func CleanUpBookEvents(wrapper Wrapper, bookID uuid.UUID) (rowsAffected int64, err error)

func GetGreatestOccurredAtTimeFromDB

func GetGreatestOccurredAtTimeFromDB(t testing.TB, wrapper Wrapper) time.Time

func GetLatestBookIDFromDB

func GetLatestBookIDFromDB(t testing.TB, wrapper Wrapper) uuid.UUID

func GuardThatThereAreEnoughFixtureEventsInStore

func GuardThatThereAreEnoughFixtureEventsInStore(wrapper Wrapper, expectedNumEvents int)

func OptimizeDBWhileBenchmarking

func OptimizeDBWhileBenchmarking(wrapper Wrapper) error

func TryCreateEventStoreWithTableName

func TryCreateEventStoreWithTableName(t testing.TB, options ...Option) error

Types

type PGXPoolWrapper

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

PGXPoolWrapper wraps pgxpool-based testing

func (*PGXPoolWrapper) Close

func (e *PGXPoolWrapper) Close()

func (*PGXPoolWrapper) GetEventStore

func (e *PGXPoolWrapper) GetEventStore() EventStore

type SQLDBWrapper

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

SQLDBWrapper wraps sql.DB-based testing

func (*SQLDBWrapper) Close

func (e *SQLDBWrapper) Close()

func (*SQLDBWrapper) GetEventStore

func (e *SQLDBWrapper) GetEventStore() EventStore

type SQLXWrapper

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

SQLXWrapper wraps sqlx.DB-based testing

func (*SQLXWrapper) Close

func (e *SQLXWrapper) Close()

func (*SQLXWrapper) GetEventStore

func (e *SQLXWrapper) GetEventStore() EventStore

type Wrapper

type Wrapper interface {
	GetEventStore() EventStore
	Close()
}

Wrapper interface to abstract over different engine types

func CreateWrapperWithBenchmarkConfig

func CreateWrapperWithBenchmarkConfig(t testing.TB) Wrapper

func CreateWrapperWithTestConfig

func CreateWrapperWithTestConfig(t testing.TB, options ...Option) Wrapper