(s string, key string)
| 69 | } |
| 70 | |
| 71 | func getParamByKey(s string, key string) string { |
| 72 | params := strings.Split(s, "&") |
| 73 | for _, p := range params { |
| 74 | kv := strings.Split(p, "=") |
| 75 | if len(kv) == 2 && kv[0] == key { |
| 76 | return kv[1] |
| 77 | } |
| 78 | } |
| 79 | return "" |
| 80 | } |
| 81 | |
| 82 | func (task *Task) InitConnectRpcClient() (err error) { |
| 83 | etcdConfigOption := &store.Config{ |