(jobName string)
| 627 | } |
| 628 | |
| 629 | func (sm *StoreManager) GetJobStage(jobName string) (string, error) { |
| 630 | key := fmt.Sprintf("dtle/%v/JobStage", jobName) |
| 631 | kv, err := sm.consulStore.Get(key) |
| 632 | if err == store.ErrKeyNotFound { |
| 633 | return "", nil |
| 634 | } else if err != nil { |
| 635 | return "", err |
| 636 | } |
| 637 | |
| 638 | return string(kv.Value), nil |
| 639 | } |
| 640 | |
| 641 | func (sm *StoreManager) PutDumpProgress(jobName string, exec int64, total int64) error { |
| 642 | key := fmt.Sprintf("dtle/%v/DumpProgress", jobName) |