Home
last modified time | relevance | path

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 Dtracker.go52 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 Dtracker.go56 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 Ddeployment_watcher.go408 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 Ddeployment_watcher.go419 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 Dclient.go214 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 Dutil.go26 func diffAllocs(existing map[string]uint64, allocs *allocUpdates) *diffResult { argument
H A Dclient_test.go700 allocUpdates := &allocUpdates{
705 c1.runAllocs(allocUpdates)
/dports/sysutils/nomad/nomad-1.1.0/client/
H A Dutil.go26 func diffAllocs(existing map[string]uint64, allocs *allocUpdates) *diffResult { argument
H A Dclient.go222 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 Dclient_test.go700 allocUpdates := &allocUpdates{
705 c1.runAllocs(allocUpdates)