Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
4f27976fbb |
BIN
broker/exec-truckstop
Normal file
BIN
broker/exec-truckstop
Normal file
Binary file not shown.
3
main.go
3
main.go
@@ -316,11 +316,14 @@ func getJobs() ([]broker.Job, error) {
|
|||||||
states := config.AllStates()
|
states := config.AllStates()
|
||||||
brokers := []broker.Broker{}
|
brokers := []broker.Broker{}
|
||||||
if config.Get().Brokers.NTG.Enabled {
|
if config.Get().Brokers.NTG.Enabled {
|
||||||
|
logtr.Debugf("NTG enabled")
|
||||||
brokers = append(brokers, broker.NewNTGVision())
|
brokers = append(brokers, broker.NewNTGVision())
|
||||||
}
|
}
|
||||||
if config.Get().Brokers.FastExact.Enabled {
|
if config.Get().Brokers.FastExact.Enabled {
|
||||||
|
logtr.Debugf("FastExact enabled")
|
||||||
brokers = append(brokers, broker.NewFastExact())
|
brokers = append(brokers, broker.NewFastExact())
|
||||||
}
|
}
|
||||||
|
logtr.Debugf("brokers=%+v", brokers)
|
||||||
jobs := []broker.Job{}
|
jobs := []broker.Job{}
|
||||||
for _, broker := range brokers {
|
for _, broker := range brokers {
|
||||||
somejobs, err := broker.Search(states)
|
somejobs, err := broker.Search(states)
|
||||||
|
|||||||
Reference in New Issue
Block a user