| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/containerd/containerd/metrics/cgroups/v1/ |
| H A D | metrics.go | 74 type Collector struct { struct
75 mu sync.RWMutex
77 tasks map[string]Statable
78 ns *metrics.Namespace
79 metrics []*metric
80 storedMetrics chan prometheus.Metric
84 func (c *Collector) Describe(ch chan<- *prometheus.Desc) {
91 func (c *Collector) Collect(ch chan<- prometheus.Metric) {
138 func (c *Collector) Add(t Statable) error {
153 func (c *Collector) Remove(t Statable) {
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/containerd/containerd/metrics/cgroups/v1/ |
| H A D | metrics.go | 74 type Collector struct { struct
75 mu sync.RWMutex
77 tasks map[string]Statable
78 ns *metrics.Namespace
79 metrics []*metric
80 storedMetrics chan prometheus.Metric
84 func (c *Collector) Describe(ch chan<- *prometheus.Desc) {
91 func (c *Collector) Collect(ch chan<- prometheus.Metric) {
138 func (c *Collector) Add(t Statable) error {
153 func (c *Collector) Remove(t Statable) {
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/daemon/stats/ |
| H A D | collector.go | 15 type Collector struct { struct
16 m sync.Mutex
17 cond *sync.Cond
18 supervisor supervisor
19 interval time.Duration
20 publishers map[*container.Container]*pubsub.Publisher
21 bufReader *bufio.Reader
44 func (s *Collector) Collect(c *container.Container) chan interface{} {
60 func (s *Collector) StopCollection(c *container.Container) {
70 func (s *Collector) Unsubscribe(c *container.Container, ch chan interface{}) {
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/daemon/stats/ |
| H A D | collector.go | 15 type Collector struct { struct
16 m sync.Mutex
17 supervisor supervisor
18 interval time.Duration
19 publishers map[*container.Container]*pubsub.Publisher
20 bufReader *bufio.Reader
23 clockTicksPerSecond uint64
48 func (s *Collector) Collect(c *container.Container) chan interface{} {
61 func (s *Collector) StopCollection(c *container.Container) {
71 func (s *Collector) Unsubscribe(c *container.Container, ch chan interface{}) {
[all …]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/daemon/stats/ |
| H A D | collector.go | 15 type Collector struct { struct
16 m sync.Mutex
17 supervisor supervisor
18 interval time.Duration
19 publishers map[*container.Container]*pubsub.Publisher
20 bufReader *bufio.Reader
23 clockTicksPerSecond uint64
48 func (s *Collector) Collect(c *container.Container) chan interface{} {
61 func (s *Collector) StopCollection(c *container.Container) {
71 func (s *Collector) Unsubscribe(c *container.Container, ch chan interface{}) {
[all …]
|
| /dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/daemon/stats/ |
| H A D | collector.go | 15 type Collector struct { struct
16 m sync.Mutex
17 supervisor supervisor
18 interval time.Duration
19 publishers map[*container.Container]*pubsub.Publisher
20 bufReader *bufio.Reader
23 clockTicksPerSecond uint64
48 func (s *Collector) Collect(c *container.Container) chan interface{} {
61 func (s *Collector) StopCollection(c *container.Container) {
71 func (s *Collector) Unsubscribe(c *container.Container, ch chan interface{}) {
[all …]
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/daemon/stats/ |
| H A D | collector.go | 15 type Collector struct { struct
16 m sync.Mutex
17 cond *sync.Cond
18 supervisor supervisor
19 interval time.Duration
20 publishers map[*container.Container]*pubsub.Publisher
21 bufReader *bufio.Reader
44 func (s *Collector) Collect(c *container.Container) chan interface{} {
60 func (s *Collector) StopCollection(c *container.Container) {
70 func (s *Collector) Unsubscribe(c *container.Container, ch chan interface{}) {
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/daemon/stats/ |
| H A D | collector.go | 15 type Collector struct { struct
16 m sync.Mutex
17 cond *sync.Cond
18 supervisor supervisor
19 interval time.Duration
20 publishers map[*container.Container]*pubsub.Publisher
21 bufReader *bufio.Reader
44 func (s *Collector) Collect(c *container.Container) chan interface{} {
60 func (s *Collector) StopCollection(c *container.Container) {
70 func (s *Collector) Unsubscribe(c *container.Container, ch chan interface{}) {
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/daemon/stats/ |
| H A D | collector.go | 15 type Collector struct { struct
16 m sync.Mutex
17 cond *sync.Cond
18 supervisor supervisor
19 interval time.Duration
20 publishers map[*container.Container]*pubsub.Publisher
21 bufReader *bufio.Reader
44 func (s *Collector) Collect(c *container.Container) chan interface{} {
60 func (s *Collector) StopCollection(c *container.Container) {
70 func (s *Collector) Unsubscribe(c *container.Container, ch chan interface{}) {
[all …]
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/daemon/stats/ |
| H A D | collector.go | 15 type Collector struct { struct
16 m sync.Mutex
17 supervisor supervisor
18 interval time.Duration
19 publishers map[*container.Container]*pubsub.Publisher
20 bufReader *bufio.Reader
23 clockTicksPerSecond uint64
48 func (s *Collector) Collect(c *container.Container) chan interface{} {
61 func (s *Collector) StopCollection(c *container.Container) {
71 func (s *Collector) Unsubscribe(c *container.Container, ch chan interface{}) {
[all …]
|
| /dports/sysutils/docker/docker-ce-18.09.5/components/engine/daemon/stats/ |
| H A D | collector.go | 15 type Collector struct { struct
16 m sync.Mutex
17 supervisor supervisor
18 interval time.Duration
19 publishers map[*container.Container]*pubsub.Publisher
20 bufReader *bufio.Reader
23 clockTicksPerSecond uint64
48 func (s *Collector) Collect(c *container.Container) chan interface{} {
61 func (s *Collector) StopCollection(c *container.Container) {
71 func (s *Collector) Unsubscribe(c *container.Container, ch chan interface{}) {
[all …]
|
| /dports/devel/php-ice37/ice-3.7.2/csharp/test/Ice/servantLocator/ |
| H A D | ServerAMD.cs | 22 … communicator.getProperties().setProperty("TestAdapter.Endpoints", getTestEndpoint(0));
23 communicator.getProperties().setProperty("Ice.Warn.Dispatch", "0");
26 adapter.addServantLocator(new ServantLocatorI("category"), "category");
27 adapter.addServantLocator(new ServantLocatorI(""), "");
29 … adapter.add(new TestActivationI(), Ice.Util.stringToIdentity("test/activation"));
37 {
|
| /dports/net/storj/storj-1.45.3/satellite/audit/ |
| H A D | collector.go | 17 type Collector struct { struct
18 Reservoirs map[storj.NodeID]*Reservoir
19 slotCount int
20 rand *rand.Rand
33 func (collector *Collector) LoopStarted(context.Context, segmentloop.LoopInfo) (err error) {
38 …ollector *Collector) RemoteSegment(ctx context.Context, segment *segmentloop.Segment) (err error) {
51 …ollector *Collector) InlineSegment(ctx context.Context, segment *segmentloop.Segment) (err error) {
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/swarmkit/cmd/swarm-bench/ |
| H A D | collector.go | 16 type Collector struct { struct
17 t metrics.Timer
18 ln net.Listener
23 func (c *Collector) Listen(port int) error {
33 func (c *Collector) Collect(ctx context.Context, count uint64) {
47 func (c *Collector) Stats(w io.Writer, unit time.Duration) {
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/metrics/ |
| H A D | collector.go | 27 type Collector struct { struct
28 store *store.MemoryStore
31 stopChan chan struct{}
33 doneChan chan struct{}
45 func (c *Collector) updateNodeState(prevNode, newNode *api.Node) {
60 func (c *Collector) Run(ctx context.Context) error {
96 func (c *Collector) Stop() {
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/daemon/stats/ |
| H A D | types.go | 33 type Collector struct { struct
34 m sync.Mutex
35 supervisor supervisor
36 interval time.Duration
37 publishers map[*container.Container]*pubsub.Publisher
38 bufReader *bufio.Reader
41 clockTicksPerSecond uint64
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/daemon/stats/ |
| H A D | types.go | 33 type Collector struct { struct
34 m sync.Mutex
35 supervisor supervisor
36 interval time.Duration
37 publishers map[*container.Container]*pubsub.Publisher
38 bufReader *bufio.Reader
41 clockTicksPerSecond uint64
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/metrics/ |
| H A D | collector.go | 27 type Collector struct { struct
28 store *store.MemoryStore
31 stopChan chan struct{}
33 doneChan chan struct{}
45 func (c *Collector) updateNodeState(prevNode, newNode *api.Node) {
60 func (c *Collector) Run(ctx context.Context) error {
96 func (c *Collector) Stop() {
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/metrics/ |
| H A D | collector.go | 27 type Collector struct { struct
28 store *store.MemoryStore
31 stopChan chan struct{}
33 doneChan chan struct{}
45 func (c *Collector) updateNodeState(prevNode, newNode *api.Node) {
60 func (c *Collector) Run(ctx context.Context) error {
96 func (c *Collector) Stop() {
|
| /dports/www/gitea/gitea-1.16.5/vendor/gopkg.in/warnings.v0/ |
| H A D | warnings.go | 116 type Collector struct { struct
141 panic("warnings.Collector already done")
159 func (c *Collector) Done() error {
164 func (c *Collector) erorr() error {
|
| /dports/sysutils/chezmoi/chezmoi-2.9.3/vendor/gopkg.in/warnings.v0/ |
| H A D | warnings.go | 116 type Collector struct { struct
141 panic("warnings.Collector already done")
159 func (c *Collector) Done() error {
164 func (c *Collector) erorr() error {
|
| /dports/net/cloudquery/cloudquery-0.16.0/vendor/gopkg.in/warnings.v0/ |
| H A D | warnings.go | 116 type Collector struct { struct
141 panic("warnings.Collector already done")
159 func (c *Collector) Done() error {
164 func (c *Collector) erorr() error {
|
| /dports/devel/awless/awless-0.1.11/vendor/gopkg.in/warnings.v0/ |
| H A D | warnings.go | 116 type Collector struct { struct
141 panic("warnings.Collector already done")
159 func (c *Collector) Done() error {
164 func (c *Collector) erorr() error {
|
| /dports/devel/lazygit/lazygit-0.31.4/vendor/gopkg.in/warnings.v0/ |
| H A D | warnings.go | 116 type Collector struct { struct
141 panic("warnings.Collector already done")
159 func (c *Collector) Done() error {
164 func (c *Collector) erorr() error {
|
| /dports/devel/lazygit/lazygit-0.31.4/vendor/gopkg.in/warnings.v0/warnings-0.1.2/ |
| H A D | warnings.go | 116 type Collector struct { struct
141 panic("warnings.Collector already done")
159 func (c *Collector) Done() error {
164 func (c *Collector) erorr() error {
|