| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 160 type QueueManager struct { struct
161 logger log.Logger
162 flushDeadline time.Duration
164 externalLabels labels.Labels
167 watcher *WALWatcher
173 shards *shards
174 numShards int
175 reshardChan chan int
176 quit chan struct{}
177 wg sync.WaitGroup
[all …]
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 193 type QueueManager struct { struct
195 lastSendTimestamp int64
197 logger log.Logger
198 flushDeadline time.Duration
203 watcher *wal.Watcher
210 shards *shards
211 numShards int
212 reshardChan chan int
213 quit chan struct{}
214 wg sync.WaitGroup
[all …]
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 141 type QueueManager struct { struct
142 logger log.Logger
144 flushDeadline time.Duration
149 queueName string
152 shardsMtx sync.RWMutex
153 shards *shards
154 numShards int
155 reshardChan chan int
156 quit chan struct{}
157 wg sync.WaitGroup
[all …]
|
| /dports/net-mgmt/prometheus1/prometheus-1.8.2/storage/remote/ |
| H A D | queue_manager.go | 137 type QueueManager struct { struct
141 client StorageClient
142 queueName string
143 logLimiter *rate.Limiter
145 shardsMtx sync.Mutex
146 shards *shards
147 numShards int
148 reshardChan chan int
149 quit chan struct{}
150 wg sync.WaitGroup
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 339 type QueueManager struct { struct
342 logger log.Logger
348 sendExemplars bool
352 clientMtx sync.RWMutex
353 storeClient WriteClient
362 shards *shards
363 numShards int
364 reshardChan chan int
365 quit chan struct{}
366 wg sync.WaitGroup
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 339 type QueueManager struct { struct
342 logger log.Logger
348 sendExemplars bool
352 clientMtx sync.RWMutex
353 storeClient WriteClient
362 shards *shards
363 numShards int
364 reshardChan chan int
365 quit chan struct{}
366 wg sync.WaitGroup
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 339 type QueueManager struct { struct
342 logger log.Logger
348 sendExemplars bool
352 clientMtx sync.RWMutex
353 storeClient WriteClient
362 shards *shards
363 numShards int
364 reshardChan chan int
365 quit chan struct{}
366 wg sync.WaitGroup
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/storage/remote/ |
| H A D | queue_manager.go | 339 type QueueManager struct { struct
342 logger log.Logger
348 sendExemplars bool
352 clientMtx sync.RWMutex
353 storeClient WriteClient
362 shards *shards
363 numShards int
364 reshardChan chan int
365 quit chan struct{}
366 wg sync.WaitGroup
[all …]
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/prometheus/prometheus/storage/remote/ |
| H A D | queue_manager.go | 339 type QueueManager struct { struct
342 logger log.Logger
348 sendExemplars bool
352 clientMtx sync.RWMutex
353 storeClient WriteClient
360 shards *shards
361 numShards int
362 reshardChan chan int
363 quit chan struct{}
364 wg sync.WaitGroup
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/ |
| H A D | QueueManager.java | 83 public class QueueManager { class
148 QueueManager() {// acls are disabled in QueueManager() method in QueueManager
152 QueueManager(boolean areAclsEnabled) { in QueueManager() method in QueueManager
168 public QueueManager(Configuration clusterConf) { in QueueManager() method in QueueManager
182 QueueManager(String confFile, boolean areAclsEnabled) { in QueueManager() method in QueueManager
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/System.Web/System.Web/ |
| H A D | QueueManager.cs | 40 sealed class QueueManager class
51 public QueueManager () in QueueManager() method in System.Web.QueueManager
|
| /dports/net-p2p/ktorrent/ktorrent-21.12.3/libktcore/groups/ |
| H A D | torrentgroup.h | 15 class QueueManager; variable
|
| H A D | groupmanager.h | 22 class QueueManager; variable
|
| /dports/misc/molequeue/molequeue-0.9.0/molequeue/app/ |
| H A D | importqueuedialog.h | 27 class QueueManager; variable
|
| H A D | addqueuedialog.h | 28 class QueueManager; variable
|
| H A D | queuemanagerdialog.h | 30 class QueueManager; variable
|
| H A D | queuemanageritemmodel.h | 24 class QueueManager; variable
|
| /dports/misc/py-molequeue/molequeue-0.9.0/molequeue/app/ |
| H A D | addqueuedialog.h | 28 class QueueManager; variable
|
| H A D | importqueuedialog.h | 27 class QueueManager; variable
|
| H A D | queuemanagerdialog.h | 30 class QueueManager; variable
|
| H A D | queuemanageritemmodel.h | 24 class QueueManager; variable
|
| /dports/www/kanboard/kanboard-1.2.21/app/ServiceProvider/ |
| H A D | QueueProvider.php | 5 use Kanboard\Core\Queue\QueueManager; alias
|
| /dports/misc/molequeue/molequeue-0.9.0/molequeue/app/queues/ |
| H A D | local.h | 29 class QueueManager; variable
|
| /dports/misc/py-molequeue/molequeue-0.9.0/molequeue/app/queues/ |
| H A D | local.h | 29 class QueueManager; variable
|
| /dports/www/kanboard/kanboard-1.2.21/app/Core/Queue/ |
| H A D | QueueManager.php | 16 class QueueManager extends Base class
|