integration/cluster.go
func NewClusterV3(t testing.TB, cfg *ClusterConfig) *ClusterV3 {
	cfg.UseGRPC = true
	if os.Getenv("CLIENT_DEBUG") != "" {
		clientv3.SetLogger(grpclog.NewLoggerV2WithVerbosity(os.Stderr, os.Stderr, os.Stderr, 4))
	}
	clus := &ClusterV3{
		cluster: NewClusterByConfig(t, cfg),
	}
	clus.Launch(t)

	if !cfg.SkipCreatingClient {
		for _, m := range clus.Members {
			client, err := NewClientV3(m)
			if err != nil {
				t.Fatalf("cannot create client: %v", err)
			}
			clus.clients = append(clus.clients, client)
		}
	}

	return clus
}
func NewClusterV3(t testing.TB, cfg *ClusterConfig) *ClusterV3 {
	cfg.UseGRPC = true
	if os.Getenv("CLIENT_DEBUG") != "" {
		clientv3.SetLogger(grpclog.NewLoggerV2WithVerbosity(os.Stderr, os.Stderr, os.Stderr, 4))
	}
	clus := &ClusterV3{
		cluster: NewClusterByConfig(t, cfg),
	}
	clus.Launch(t)

	if !cfg.SkipCreatingClient {
		for _, m := range clus.Members {
			client, err := NewClientV3(m)
			if err != nil {
				t.Fatalf("cannot create client: %v", err)
			}
			clus.clients = append(clus.clients, client)
		}
	}

	return clus
}
func NewClusterV3 ( t testing . TB , cfg * ClusterConfig ) * ClusterV3 { cfg . UseGRPC = true if os . Getenv ( " " ) != " " { clientv3 . SetLogger ( grpclog . NewLoggerV2WithVerbosity ( os . Stderr , os . Stderr , os . Stderr , 4 ) ) } clus := & ClusterV3 { cluster : NewClusterByConfig ( t , cfg ) , } clus . Launch ( t ) if ! cfg . SkipCreatingClient { for _ , m := range clus . Members { client , err := NewClientV3 ( m ) if err != nil { t . Fatalf ( " " , err ) } clus . clients = append ( clus . clients , client ) } } return clus }
// NewClusterV3 returns a launched cluster with a grpc client connection
// for each cluster member.
NewClusterV3 returns a launched cluster with a grpc client connection for each cluster member .