(workerID string)
| 151 | } |
| 152 | |
| 153 | func (b *kvDBAdapter) DeleteWorker(workerID string) error { |
| 154 | v, _ := b.db.Get(_workerBucketKey, workerID) |
| 155 | if v == nil { |
| 156 | return fmt.Errorf("invalid workerID %s", workerID) |
| 157 | } |
| 158 | return b.db.Delete(_workerBucketKey, workerID) |
| 159 | } |
| 160 | |
| 161 | func (b *kvDBAdapter) CreateWorker(w WorkerStatus) (WorkerStatus, error) { |
| 162 | v, err := json.Marshal(w) |