testinfra

Documentation

Index

• func DeclareTestAWSInfrastructure(ctx context.Context, cfg *mqs.AWSSQSConfig, attributes map[string]string) (string, error)
• func DeclareTestGCPInfrastructure(ctx context.Context, cfg *mqs.GCPPubSubConfig, endpoint string) error
• func EnsureGCP() string
• func EnsureLocalStack() string
• func EnsureRabbitMQ() string
• func GetAzureSBConnString() string
• func GetMQAzureConfig(t *testing.T, testName string) mqs.QueueConfig
• func GetMockServer(t *testing.T) string
• func NewClickHouseConfig(t *testing.T) clickhouse.ClickHouseConfig
• func NewMQAWSConfig(t *testing.T, attributes map[string]string) mqs.QueueConfig
• func NewMQGCPConfig(t *testing.T, attributes map[string]string) mqs.QueueConfig
• func NewMQRabbitMQConfig(t *testing.T) mqs.QueueConfig
• func NewPostgresConfig(t *testing.T) string
• func Start(t *testing.T) func()
• func TeardownTestAWSInfrastructure(ctx context.Context, cfg *mqs.AWSSQSConfig) error
• func TeardownTestGCPInfrastructure(ctx context.Context, cfg *mqs.GCPPubSubConfig, endpoint string) error
• type Config
  • func ReadConfig() *Config
• type MockServerInfra
  • func NewMockServerInfra(baseURL string) *MockServerInfra
  • func (mock *MockServerInfra) NewMockDestination(t *testing.T, destination models.Destination)
• type PGDB

Functions

func DeclareTestAWSInfrastructure

func DeclareTestAWSInfrastructure(ctx context.Context, cfg *mqs.AWSSQSConfig, attributes map[string]string) (string, error)

func DeclareTestGCPInfrastructure

func DeclareTestGCPInfrastructure(ctx context.Context, cfg *mqs.GCPPubSubConfig, endpoint string) error

func EnsureGCP

func EnsureGCP() string

func EnsureLocalStack

func EnsureLocalStack() string

func EnsureRabbitMQ

func EnsureRabbitMQ() string

func GetAzureSBConnString

func GetAzureSBConnString() string

func GetMQAzureConfig

func GetMQAzureConfig(t *testing.T, testName string) mqs.QueueConfig

func GetMockServer

func GetMockServer(t *testing.T) string

func NewClickHouseConfig

func NewClickHouseConfig(t *testing.T) clickhouse.ClickHouseConfig

func NewMQAWSConfig

func NewMQAWSConfig(t *testing.T, attributes map[string]string) mqs.QueueConfig

func NewMQGCPConfig

func NewMQGCPConfig(t *testing.T, attributes map[string]string) mqs.QueueConfig

func NewMQRabbitMQConfig

func NewMQRabbitMQConfig(t *testing.T) mqs.QueueConfig

func NewPostgresConfig

func NewPostgresConfig(t *testing.T) string

func Start

func Start(t *testing.T) func()

func TeardownTestAWSInfrastructure

func TeardownTestAWSInfrastructure(ctx context.Context, cfg *mqs.AWSSQSConfig) error

func TeardownTestGCPInfrastructure

func TeardownTestGCPInfrastructure(ctx context.Context, cfg *mqs.GCPPubSubConfig, endpoint string) error

Types

type Config

type Config struct {
	TestInfra         bool
	TestAzure         bool
	ClickHouseURL     string
	PostgresURL       string
	LocalStackURL     string
	RabbitMQURL       string
	MockServerURL     string
	GCPURL            string
	AzureSBConnString string
	// contains filtered or unexported fields
}

func ReadConfig

func ReadConfig() *Config

type MockServerInfra

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

func NewMockServerInfra

func NewMockServerInfra(baseURL string) *MockServerInfra

func (*MockServerInfra) NewMockDestination

func (mock *MockServerInfra) NewMockDestination(t *testing.T, destination models.Destination)

type PGDB

type PGDB struct{}