|
|
@@ -18,9 +18,9 @@ func NewClient(address string, version string) (client.Client, error) {
|
|
|
clientMap = make(map[string]client.Client)
|
|
|
}
|
|
|
|
|
|
- client, ok := clientMap[version]
|
|
|
+ c, ok := clientMap[version]
|
|
|
if ok {
|
|
|
- return client, nil
|
|
|
+ return c, nil
|
|
|
}
|
|
|
|
|
|
switch version {
|
|
|
@@ -30,28 +30,28 @@ func NewClient(address string, version string) (client.Client, error) {
|
|
|
return nil, err
|
|
|
}
|
|
|
|
|
|
- client = innerClient
|
|
|
+ c = innerClient
|
|
|
default:
|
|
|
return nil, errors.New("不支持的版本")
|
|
|
}
|
|
|
|
|
|
- clientMap[version] = client
|
|
|
+ clientMap[version] = c
|
|
|
|
|
|
- return client, nil
|
|
|
+ return c, nil
|
|
|
}
|
|
|
|
|
|
func DestroyClient(version string) error {
|
|
|
clientMapMutex.Lock()
|
|
|
defer clientMapMutex.Unlock()
|
|
|
|
|
|
- client, ok := clientMap[version]
|
|
|
+ c, ok := clientMap[version]
|
|
|
if !ok {
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
switch version {
|
|
|
case "v1":
|
|
|
- err := dpsv1.DestroyClient(client.(*dpsv1.Client))
|
|
|
+ err := dpsv1.DestroyClient(c.(*dpsv1.Client))
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|