integration_tests

Documentation

Index

• Constants
• func DisableProxi() error
• func EnableProxi() error
• func EnsureStarted()
• func GetConfig() config.Config
• func GetCreekConn() *creek.Conn
• func GetDBConn() *pgxpool.Pool
• func GetDBURL() string
• func GetNATSURL() string
• func GetPgContainer() *dbc.Container
• func LoadSql(files ...string)
• func ResetContainer() error
• func TimeoutContext(timeout time.Duration) context.Context
• type LogMsgCounter
  • func (l *LogMsgCounter) Fire(*logrus.Entry) error
  • func (l *LogMsgCounter) Levels() []logrus.Level
  • func (l *LogMsgCounter) Msgs() int
  • func (l *LogMsgCounter) Reset()

Constants

const DBname = "test_db"

Functions

func DisableProxi

func DisableProxi() error

func EnableProxi

func EnableProxi() error

func EnsureStarted

func EnsureStarted()

func GetConfig

func GetConfig() config.Config

func GetCreekConn

func GetCreekConn() *creek.Conn

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 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()