Function setupClient

tests/integration/grpc_test.go:129–140

(t *testing.T, endpointPattern string, clus *integration.Cluster, tlsConfig *tls.Config)

}

func setupClient(t *testing.T, endpointPattern string, clus *integration.Cluster, tlsConfig *tls.Config) *clientv3.Client {
	t.Helper()
	endpoints := templateEndpoints(t, endpointPattern, clus)
	kv, err := clientv3.New(clientv3.Config{
		Endpoints:   endpoints,
		DialTimeout: 5 * time.Second,
		DialOptions: []grpc.DialOption{grpc.WithBlock()},
		TLS:         tlsConfig,
	})
	require.NoError(t, err)
	return kv
}

func templateEndpoints(t *testing.T, pattern string, clus *integration.Cluster) []string {
	t.Helper()