(subject string, config *MySQLDriverConfig)
| 259 | } |
| 260 | |
| 261 | func (sm *StoreManager) PutConfig(subject string, config *MySQLDriverConfig) error { |
| 262 | url := fmt.Sprintf("dtle/%v/Config", subject) |
| 263 | bs, err := json.Marshal(config) |
| 264 | if err != nil { |
| 265 | return err |
| 266 | } |
| 267 | return sm.consulStore.Put(url, bs, nil) |
| 268 | } |
| 269 | |
| 270 | func (sm *StoreManager) WaitKv(subject string, key string, stopCh chan struct{}) ([]byte, error) { |
| 271 | url := fmt.Sprintf("dtle/%v/%v", subject, key) |