INNER CODE UNIT · Go

NewKVClient

m3db/m3 · scripts/development/m3_consumer_service/bootstrap/main.go:284

func NewKVClient(env string, zone string, endpoints []string) *kvClient {
	etcdClientCfg := etcdcfg.Configuration{
		Zone:    zone,
		Env:     env,
		Service: "local-consumer-service-bootstrap",
		ETCDClusters: []etcdcfg.ClusterConfig{
			{Zone: zone, Endpoints: endpoints},
		},
	}
	csClient, err := etcdClientCfg.NewClient(instrument.NewOptions())
	if err != nil {
		fatalf("create etcd config service client: %v", err)
	}
	servicesClient, err := csClient.Services(nil)
	if err != nil {
		fatalf("create services client: %v", err)
	}
	return &kvClient{servicesClient: servicesClient, env: env, zone: zone}

View source record →