Function TestFinalAdvertiseAddr

kv/memberlist/tcp_transport_test.go:158–191

(t *testing.T)

}

func TestFinalAdvertiseAddr(t *testing.T) {
	tests := map[string]struct {
		advertiseAddr string
		bindAddrs     []string
		bindPort      int
	}{
		"should not fail with local address specified": {
			advertiseAddr: "127.0.0.1",
			bindAddrs:     []string{"127.0.0.1"},
			bindPort:      0,
		},
	}

	for testName, testData := range tests {
		t.Run(testName, func(t *testing.T) {
			logs := &concurrency.SyncBuffer{}
			logger := log.NewLogfmtLogger(logs)

			cfg := TCPTransportConfig{}
			flagext.DefaultValues(&cfg)
			cfg.BindAddrs = testData.bindAddrs
			cfg.BindPort = testData.bindPort

			transport, err := NewTCPTransport(cfg, logger, prometheus.NewPedanticRegistry())
			require.NoError(t, err)

			ip, port, err := transport.FinalAdvertiseAddr(testData.advertiseAddr, testData.bindPort)
			require.NoError(t, err)
			require.Equal(t, testData.advertiseAddr, ip.String())
			require.Equal(t, testData.bindPort, port)

		})
	}
}

func TestNonIPsAreRejected(t *testing.T) {
	cfg := TCPTransportConfig{BindAddrs: flagext.StringSlice{"localhost"}}