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 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
- type MockServerInfra
- type PGDB
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnsureLocalStack ¶
func EnsureLocalStack() string
func EnsureRabbitMQ ¶
func EnsureRabbitMQ() string
func GetMockServer ¶
func NewClickHouseConfig ¶
func NewClickHouseConfig(t *testing.T) clickhouse.ClickHouseConfig
func NewMQAWSConfig ¶
func NewMQGCPConfig ¶
func NewMQRabbitMQConfig ¶
func NewMQRabbitMQConfig(t *testing.T) mqs.QueueConfig
func NewPostgresConfig ¶
func TeardownTestAWSInfrastructure ¶
func TeardownTestAWSInfrastructure(ctx context.Context, cfg *mqs.AWSSQSConfig) error
Types ¶
type Config ¶
type Config struct { TestInfra bool ClickHouseURL string PostgresURL string LocalStackURL string RabbitMQURL string MockServerURL string GCPURL 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)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.