Function NewStoreManager

driver/common/store.go:30–39

(consulAddr []string, logger g.LoggerType)

}

func NewStoreManager(consulAddr []string, logger g.LoggerType) (*StoreManager, error) {
	consulStore, err := libkv.NewStore(store.CONSUL, consulAddr, nil)
	if err != nil {
		return nil, err
	}
	return &StoreManager{
		consulStore: consulStore,
		logger:      logger,
	}, nil
}
func (sm *StoreManager) DestroyJob(jobId string) error {
	key := fmt.Sprintf("dtle/%v", jobId)
	err := sm.consulStore.DeleteTree(key)