diff --git a/client/http.go b/client/http.go index af87187b5..0549b0b8f 100644 --- a/client/http.go +++ b/client/http.go @@ -53,7 +53,7 @@ type Config struct { Transport CancelableTransport } -func New(cfg Config) (SyncableHTTPClient, error) { +func New(cfg Config) (Client, error) { c := &httpClusterClient{clientFactory: newHTTPClientFactory(cfg.Transport)} if err := c.reset(cfg.Endpoints); err != nil { return nil, err @@ -61,7 +61,7 @@ func New(cfg Config) (SyncableHTTPClient, error) { return c, nil } -type SyncableHTTPClient interface { +type Client interface { Sync(context.Context) error Endpoints() []string diff --git a/client/keys.go b/client/keys.go index 8ac130359..c155404da 100644 --- a/client/keys.go +++ b/client/keys.go @@ -47,14 +47,14 @@ var ( ErrKeyExists = errors.New("client: key already exists") ) -func NewKeysAPI(c SyncableHTTPClient) KeysAPI { +func NewKeysAPI(c Client) KeysAPI { return &httpKeysAPI{ client: c, prefix: DefaultV2KeysPrefix, } } -func NewDiscoveryKeysAPI(c SyncableHTTPClient) KeysAPI { +func NewDiscoveryKeysAPI(c Client) KeysAPI { return &httpKeysAPI{ client: c, prefix: "", diff --git a/client/members.go b/client/members.go index f824c5141..b47dca2a8 100644 --- a/client/members.go +++ b/client/members.go @@ -31,7 +31,7 @@ var ( DefaultV2MembersPrefix = "/v2/members" ) -func NewMembersAPI(c SyncableHTTPClient) MembersAPI { +func NewMembersAPI(c Client) MembersAPI { return &httpMembersAPI{ client: c, } diff --git a/integration/cluster_test.go b/integration/cluster_test.go index 2150a0df9..2effd1070 100644 --- a/integration/cluster_test.go +++ b/integration/cluster_test.go @@ -614,7 +614,7 @@ func (m *member) Terminate(t *testing.T) { } } -func mustNewHTTPClient(t *testing.T, eps []string) client.SyncableHTTPClient { +func mustNewHTTPClient(t *testing.T, eps []string) client.Client { cfg := client.Config{Transport: mustNewTransport(t), Endpoints: eps} c, err := client.New(cfg) if err != nil {