Method GetGtidForJob

driver/common/store.go:92–102

(jobName string)

	}, nil
}
func (sm *StoreManager) GetGtidForJob(jobName string) (string, error) {
	key := fmt.Sprintf("dtle/%v/Gtid", jobName)
	p, err := sm.consulStore.Get(key)
	if err == store.ErrKeyNotFound {
		return "", nil
	} else if err != nil {
		return "", err
	}
	// Get a non-existing KV
	return string(p.Value), nil
}

func (sm *StoreManager) GetConfig(jobName string) (*MySQLDriverConfig, error) {
	key := fmt.Sprintf("dtle/%v/Config", jobName)