Skip to content

Instantly share code, notes, and snippets.

func setupProtectedEMQXContainer(ctx context.Context) (*MQTTContainer, error) {
_, err := testcontainers.GenericNetwork(ctx, testcontainers.GenericNetworkRequest{
NetworkRequest: testcontainers.NetworkRequest{
Name: "emqx-test-network",
},
})
if err != nil {
return nil, fmt.Errorf("failed to create network: %w", err)
}