Michael McGuinness
7ce7c9df4d
Feature/ecr * nosave * repo * awscli * unzip * ignore * moreram * 14k * ref * deployment * 12k * uselocal * go * dockercomd * reorder * iamgename * installs * tart * cli * clideps * y * dockerce * nodock * multi * rmecr * dev
45 lines
956 B
Go
45 lines
956 B
Go
package test
|
|
|
|
import (
|
|
"fmt"
|
|
"log/slog"
|
|
"sync"
|
|
"testing"
|
|
|
|
"github.com/docker/docker/api/types/network"
|
|
"github.com/docker/docker/client"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
const (
|
|
networkName = "queryorchestration_test"
|
|
)
|
|
|
|
var networkOnce sync.Once
|
|
|
|
func GetNetwork(t testing.TB) string {
|
|
networkOnce.Do(func() {
|
|
cli := getDockerClient(t)
|
|
defer cli.Close()
|
|
|
|
_, err := cli.NetworkCreate(t.Context(), networkName, network.CreateOptions{
|
|
Driver: network.NetworkBridge,
|
|
})
|
|
conflictErrorMsg := fmt.Sprintf("Error response from daemon: network with name %s already exists", networkName)
|
|
if err != nil && err.Error() != conflictErrorMsg {
|
|
require.NoError(t, err)
|
|
}
|
|
|
|
slog.Info("created network", "name", networkName)
|
|
})
|
|
|
|
return networkName
|
|
}
|
|
|
|
func getDockerClient(t testing.TB) *client.Client {
|
|
cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
|
|
require.NoError(t, err)
|
|
|
|
return cli
|
|
}
|