Searched refs:allocUpdates (Results 1 – 10 of 10) sorted by relevance
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/client/allochealth/ |
H A D | tracker.go | 52 allocUpdates *cstructs.AllocListener member 88 allocUpdates *cstructs.AllocListener, consulClient cconsul.ConsulServiceAPI, 101 allocUpdates: allocUpdates, 297 case newAlloc, ok := <-t.allocUpdates.Ch():
|
/dports/sysutils/nomad/nomad-1.1.0/client/allochealth/ |
H A D | tracker.go | 56 allocUpdates *cstructs.AllocListener member 96 allocUpdates *cstructs.AllocListener, consulClient cconsul.ConsulServiceAPI, 109 allocUpdates: allocUpdates, 336 case newAlloc, ok := <-t.allocUpdates.Ch():
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/nomad/deploymentwatcher/ |
H A D | deployment_watcher.go | 408 var updates *allocUpdates 818 type allocUpdates struct { struct 828 func (w *deploymentWatcher) getAllocsCh(index uint64) <-chan *allocUpdates { 829 out := make(chan *allocUpdates, 1) 832 out <- &allocUpdates{
|
/dports/sysutils/nomad/nomad-1.1.0/nomad/deploymentwatcher/ |
H A D | deployment_watcher.go | 419 var updates *allocUpdates 853 type allocUpdates struct { struct 863 func (w *deploymentWatcher) getAllocsCh(index uint64) <-chan *allocUpdates { 864 out := make(chan *allocUpdates, 1) 867 out <- &allocUpdates{
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/client/ |
H A D | client.go | 214 allocUpdates chan *structs.Allocation member 321 allocUpdates: make(chan *structs.Allocation, 64), 1130 case c.allocUpdates <- failed: 1557 allocUpdates := make(chan *allocUpdates, 8) 1558 go c.watchAllocations(allocUpdates) 1562 case update := <-allocUpdates: 1800 case c.allocUpdates <- stripped: 1816 case alloc := <-c.allocUpdates: 1856 type allocUpdates struct { struct 2034 update := &allocUpdates{ [all …]
|
H A D | util.go | 26 func diffAllocs(existing map[string]uint64, allocs *allocUpdates) *diffResult { argument
|
H A D | client_test.go | 700 allocUpdates := &allocUpdates{ 705 c1.runAllocs(allocUpdates)
|
/dports/sysutils/nomad/nomad-1.1.0/client/ |
H A D | util.go | 26 func diffAllocs(existing map[string]uint64, allocs *allocUpdates) *diffResult { argument
|
H A D | client.go | 222 allocUpdates chan *structs.Allocation member 355 allocUpdates: make(chan *structs.Allocation, 64), 1230 case c.allocUpdates <- failed: 1678 allocUpdates := make(chan *allocUpdates, 8) 1679 go c.watchAllocations(allocUpdates) 1683 case update := <-allocUpdates: 1923 case c.allocUpdates <- stripped: 1938 case alloc := <-c.allocUpdates: 1983 type allocUpdates struct { struct 2162 update := &allocUpdates{ [all …]
|
H A D | client_test.go | 700 allocUpdates := &allocUpdates{ 705 c1.runAllocs(allocUpdates)
|