integration_tests

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 1, 2025 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source
const DBname = "test_db"

Variables

This section is empty.

Functions

func DisableProxi

func DisableProxi() error

func EnableProxi

func EnableProxi() error

func EnsureStarted

func EnsureStarted(ctx context.Context) (*mq.MQ, <-chan struct{})

func GetConfig

func GetConfig() config.Config

func GetCreekConn

func GetCreekConn() *creek.Client

func GetDBConn

func GetDBConn() *pgxpool.Pool

func GetDBURL

func GetDBURL() string

func GetNATSURL

func GetNATSURL() string

func GetPgContainer

func GetPgContainer() *dbc.Container

func LoadSql

func LoadSql(files ...string)

func ResetContainer

func ResetContainer() error

func StartNatsContainer

func StartNatsContainer(ctx context.Context) error

func StopNatsContainer

func StopNatsContainer(ctx context.Context) error

func TimeoutContext

func TimeoutContext(timeout time.Duration) context.Context

Types

type LogMsgCounter

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

func (*LogMsgCounter) Fire

func (l *LogMsgCounter) Fire(*logrus.Entry) error

func (*LogMsgCounter) Levels

func (l *LogMsgCounter) Levels() []logrus.Level

func (*LogMsgCounter) Msgs

func (l *LogMsgCounter) Msgs() int

func (*LogMsgCounter) Reset

func (l *LogMsgCounter) Reset()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL