mirror of
https://github.com/etcd-io/etcd.git
synced 2024-09-27 06:25:44 +00:00
client: pass httpActionDo into NewMembersAPI
This commit is contained in:
parent
0ef270c25c
commit
f6e8b677cf
@ -34,18 +34,11 @@ var (
|
||||
DefaultV2MembersPrefix = "/v2/members"
|
||||
)
|
||||
|
||||
func NewMembersAPI(tr *http.Transport, eps []string, to time.Duration) (MembersAPI, error) {
|
||||
c, err := NewHTTPClient(tr, eps)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
mAPI := httpMembersAPI{
|
||||
func NewMembersAPI(c httpActionDo, to time.Duration) MembersAPI {
|
||||
return &httpMembersAPI{
|
||||
client: c,
|
||||
timeout: to,
|
||||
}
|
||||
|
||||
return &mAPI, nil
|
||||
}
|
||||
|
||||
type MembersAPI interface {
|
||||
|
@ -42,13 +42,13 @@ func mustNewMembersAPI(c *cli.Context) client.MembersAPI {
|
||||
}
|
||||
}
|
||||
|
||||
mAPI, err := client.NewMembersAPI(&http.Transport{}, peers, client.DefaultRequestTimeout)
|
||||
hc, err := client.NewHTTPClient(&http.Transport{}, peers)
|
||||
if err != nil {
|
||||
fmt.Fprintln(os.Stderr, err.Error())
|
||||
os.Exit(1)
|
||||
}
|
||||
|
||||
return mAPI
|
||||
return client.NewMembersAPI(hc, client.DefaultRequestTimeout)
|
||||
}
|
||||
|
||||
func actionMemberList(c *cli.Context) {
|
||||
|
Loading…
x
Reference in New Issue
Block a user