Function TestRun_ConfigFileWithInvalidPeer

proxy/run_test.go:374–413

(t *testing.T)

}

func TestRun_ConfigFileWithInvalidPeer(t *testing.T) {
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()

	proxy1Addr := testAddr
	clusterPort, clusterAddr, proxy1BindAddr, _ := generateTestAddrs(proxy1Addr)

	cluster := proxycore.NewMockCluster(net.ParseIP(testStartAddr), clusterPort)

	err := cluster.Add(ctx, 1)
	require.NoError(t, err)

	defer cluster.Shutdown()

	configFileName, err := writeTempYaml(struct {
		Bind          string
		Port          int
		RPCAddr       string   `yaml:"rpc-address"`
		DataCenter    string   `yaml:"data-center"`
		ContactPoints []string `yaml:"contact-points"`
		HealthCheck   bool     `yaml:"health-check"`
		HttpBind      string   `yaml:"http-bind"`
		Peers         []PeerConfig
	}{
		ContactPoints: []string{clusterAddr},
		Bind:          proxy1BindAddr,
		RPCAddr:       proxy1Addr,
		Port:          clusterPort,
		Peers: []PeerConfig{{
			RPCAddr: "", // Empty
			DC:      "dc-2",
		}},
	})
	require.NoError(t, err)

	rc := Run(ctx, []string{
		"--config", configFileName,
	})
	require.Equal(t, 1, rc)
}

func TestRun_ProxyTLS(t *testing.T) {
	ctx, cancel := context.WithCancel(context.Background())