remotetest

Documentation

Index

• func SetupPostgresClient(t *testing.T, runMigration bool) *pgxpool.Pool
• func SetupRedisClient(t *testing.T) *redis.Client
• type KafkaContainer
  • func CreateKafkaContainer() (*KafkaContainer, error)
  • func (k *KafkaContainer) CreateTopic(topic string) error
  • func (k *KafkaContainer) Purge() error
• type PostgresContainer
  • func CreatePostgres() (*PostgresContainer, error)
  • func (pg *PostgresContainer) CreateConnPool() (*pgxpool.Pool, error)
  • func (pg *PostgresContainer) Purge() error
  • func (pg *PostgresContainer) RunMigrations() error
• type RedisServer
  • func SetupRedisServer() (*RedisServer, error)
  • func (rs *RedisServer) FastForward(d time.Duration)
  • func (rs *RedisServer) Purge()
  • func (rs *RedisServer) SetupRedisClient() *redis.Client

Functions

func SetupPostgresClient

func SetupPostgresClient(t *testing.T, runMigration bool) *pgxpool.Pool

func SetupRedisClient

func SetupRedisClient(t *testing.T) *redis.Client

Types

type KafkaContainer

type KafkaContainer struct {
	Address string
	Topics  sync.Map
}

func CreateKafkaContainer

func CreateKafkaContainer() (*KafkaContainer, error)

func (*KafkaContainer) CreateTopic

func (k *KafkaContainer) CreateTopic(topic string) error

func (*KafkaContainer) Purge

func (k *KafkaContainer) Purge() error

type PostgresContainer

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

func CreatePostgres

func CreatePostgres() (*PostgresContainer, error)

func (*PostgresContainer) CreateConnPool

func (pg *PostgresContainer) CreateConnPool() (*pgxpool.Pool, error)

func (*PostgresContainer) Purge

func (pg *PostgresContainer) Purge() error

func (*PostgresContainer) RunMigrations

func (pg *PostgresContainer) RunMigrations() error

type RedisServer

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

func SetupRedisServer

func SetupRedisServer() (*RedisServer, error)

func (*RedisServer) FastForward

func (rs *RedisServer) FastForward(d time.Duration)

func (*RedisServer) Purge

func (rs *RedisServer) Purge()

func (*RedisServer) SetupRedisClient

func (rs *RedisServer) SetupRedisClient() *redis.Client