testx

package

v2.5.10 Latest Latest Go to latest Published: Jun 3, 2026 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func MockClock(t *testing.T) *clock.Mock

func MockEventsGetAll[T events.Event](t *testing.T, m *MockEvents, predicates ...func(T) bool) []T

func MockEventsGetSingle[T events.Event](t *testing.T, m *MockEvents, predicates ...func(T) bool) T

func MockEventsHasNone[T events.Event](t *testing.T, m *MockEvents, predicates ...func(T) bool)

func MockEventsHasSome[T events.Event](t *testing.T, m *MockEvents, predicates ...func(T) bool) []T

func MustTransact(t *testing.T, db *sqlx.DB, fn func(ctx ql.TxContext))

func MustTransactErr(t *testing.T, db *sqlx.DB, fn func(ctx ql.TxContext) error)

func NewConnection(t *testing.T, schemaTable string) *sqlx.DB

NewConnection creates a temporary postgres database and applies schema files from the ./sql directory.

type MockEvents struct {
	Events []events.Event
}

func CaptureEvents(t *testing.T) *MockEvents

func (m *MockEvents) Close() error

func (m *MockEvents) SendAsync(ctx context.Context, event events.Event)

func (m *MockEvents) SendAsyncCh() chan<- events.Event

func (m *MockEvents) SendInTx(ctx context.Context, tx sqlx.ExecerContext, event events.Event) error