/dports/textproc/miller/miller-5.10.2/go/src/transformers/utils/ |
H A D | stats1-accumulators.go | 18 Ingest(value *types.Mlrval) methodSpec 123 func (this *Stats1NamedAccumulator) Ingest(value *types.Mlrval) { func 124 this.accumulator.Ingest(value) 281 func (this *Stats1CountAccumulator) Ingest(value *types.Mlrval) { func 300 func (this *Stats1ModeAccumulator) Ingest(value *types.Mlrval) { func 374 func (this *Stats1SumAccumulator) Ingest(value *types.Mlrval) { func 395 func (this *Stats1MeanAccumulator) Ingest(value *types.Mlrval) { func 420 func (this *Stats1MinAccumulator) Ingest(value *types.Mlrval) { func 437 func (this *Stats1MaxAccumulator) Ingest(value *types.Mlrval) { func 458 func (this *Stats1VarAccumulator) Ingest(value *types.Mlrval) { func [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/cast_channel/ |
H A D | cast_framer_unittest.cc | 57 EXPECT_EQ(nullptr, framer_->Ingest(1, &message_length, &error).get()); in TEST_F() 63 EXPECT_EQ(nullptr, framer_->Ingest(3, &message_length, &error).get()); in TEST_F() 71 message = framer_->Ingest(framer_->BytesRequested(), &message_length, &error); in TEST_F() 100 EXPECT_EQ(nullptr, framer_->Ingest(4, &bytes_ingested, &error).get()); in TEST_F() 107 EXPECT_EQ(nullptr, framer_->Ingest(4, &bytes_ingested, &error).get()); in TEST_F() 124 EXPECT_EQ(nullptr, framer_->Ingest(4, &bytes_ingested, &error).get()); in TEST_F() 131 EXPECT_EQ(nullptr, framer_->Ingest(4, &bytes_ingested, &error).get()); in TEST_F() 151 EXPECT_EQ(nullptr, framer_->Ingest(4, &message_length, &error).get()); in TEST_F() 158 framer_->Ingest(framer_->BytesRequested(), &message_length, &error) in TEST_F()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/cast_channel/ |
H A D | cast_framer_unittest.cc | 57 EXPECT_EQ(nullptr, framer_->Ingest(1, &message_length, &error).get()); in TEST_F() 63 EXPECT_EQ(nullptr, framer_->Ingest(3, &message_length, &error).get()); in TEST_F() 71 message = framer_->Ingest(framer_->BytesRequested(), &message_length, &error); in TEST_F() 100 EXPECT_EQ(nullptr, framer_->Ingest(4, &bytes_ingested, &error).get()); in TEST_F() 107 EXPECT_EQ(nullptr, framer_->Ingest(4, &bytes_ingested, &error).get()); in TEST_F() 124 EXPECT_EQ(nullptr, framer_->Ingest(4, &bytes_ingested, &error).get()); in TEST_F() 131 EXPECT_EQ(nullptr, framer_->Ingest(4, &bytes_ingested, &error).get()); in TEST_F() 151 EXPECT_EQ(nullptr, framer_->Ingest(4, &message_length, &error).get()); in TEST_F() 158 framer_->Ingest(framer_->BytesRequested(), &message_length, &error) in TEST_F()
|
/dports/textproc/sonic/sonic-1.3.0/src/channel/ |
H A D | mode.rs | 9 Ingest, enumerator 17 "ingest" => Ok(ChannelMode::Ingest), in from_str() 26 ChannelMode::Ingest => "ingest", in to_str()
|
/dports/net-mgmt/promscale/promscale-0.6.2/pkg/tests/end_to_end_tests/ |
H A D | insert_compressed_chunks_test.go | 30 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) 63 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) 73 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(sample))) 92 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) 102 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(sample)))
|
H A D | metadata_test.go | 35 numSamples, numMetadata, err := ingestor.Ingest(wr) 42 numSamples, numMetadata, err = ingestor.Ingest(wr) 54 numSamples, numMetadata, err = ingestor.Ingest(wr) 78 numSamples, numMetadata, err := ingestor.Ingest(wr)
|
H A D | db_connections_test.go | 52 ingested, _, err := pgClient.Ingest(newWriteRequestWithTs(copyMetrics(metrics[:2]))) 82 _, _, err = pgClient.Ingest(newWriteRequestWithTs(copyMetrics(metrics[2:]))) 102 ingested, _, err = pgClient.Ingest(newWriteRequestWithTs(copyMetrics(metrics[2:])))
|
H A D | zlast_test.go | 38 if _, _, err := ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))); err != nil { 47 if _, _, err := ingestor.Ingest(newWriteRequestWithTs(copyMetrics(tts))); err != nil {
|
H A D | create_test.go | 176 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) 532 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) 563 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) 666 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) 729 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) 753 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) 832 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) 964 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) 1070 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) 1158 _, _, err = ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))) [all …]
|
/dports/textproc/p5-Search-Elasticsearch/Search-Elasticsearch-6.00/lib/Search/Elasticsearch/Client/6_0/Direct/ |
H A D | Ingest.pm | 1 package Search::Elasticsearch::Client::6_0::Direct::Ingest; 2 $Search::Elasticsearch::Client::6_0::Direct::Ingest::VERSION = '6.00';
|
/dports/textproc/p5-Search-Elasticsearch-Client-5_0/Search-Elasticsearch-Client-5_0-6.00/lib/Search/Elasticsearch/Client/5_0/Direct/ |
H A D | Ingest.pm | 1 package Search::Elasticsearch::Client::5_0::Direct::Ingest; 2 $Search::Elasticsearch::Client::5_0::Direct::Ingest::VERSION = '6.00';
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/distributor/ |
H A D | http_admin.go | 33 <th>Total Ingest Rate</th> 34 <th>API Ingest Rate</th> 35 <th>Rule Ingest Rate</th>
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/distributor/ |
H A D | http_admin.go | 33 <th>Total Ingest Rate</th> 34 <th>API Ingest Rate</th> 35 <th>Rule Ingest Rate</th>
|
/dports/editors/calligra/calligra-3.2.1/plugins/stencilsdocker/stencils/LST/ |
H A D | ingestor_subsystem.desktop | 20 Name[pt]=Ingestão 21 Name[pt_BR]=Ingestão
|
/dports/net-mgmt/observium/observium/mibs/cisco/ |
H A D | CISCO-CDSTV-INGESTMGR-MIB | 2 -- CISCO-CDSTV-INGESTMGR-MIB: Cisco CDS-TV Ingest Manager Configuration 82 Content Ingest: Acquisition of content from a source such as a 86 Ingest Manager: CDS module that takes care of provisioned 127 -- Ingest Manager General Settings 132 -- Ingest Manager Ingest Settings 137 -- Ingest Manager Back-office Settings 142 -- Ingest Manager Content Store Settings 147 -- Ingest Manager Encryption Settings 159 cdstvIngestMgrHostAddress) of the Ingest Manager." 209 "This object specifies the maximum period the Ingest Manager [all …]
|
/dports/net-mgmt/netdisco-mibs/netdisco-mibs-4.010/cisco/ |
H A D | CISCO-CDSTV-INGESTMGR-MIB.my | 2 -- CISCO-CDSTV-INGESTMGR-MIB: Cisco CDS-TV Ingest Manager Configuration 82 Content Ingest: Acquisition of content from a source such as a 86 Ingest Manager: CDS module that takes care of provisioned 127 -- Ingest Manager General Settings 132 -- Ingest Manager Ingest Settings 137 -- Ingest Manager Back-office Settings 142 -- Ingest Manager Content Store Settings 147 -- Ingest Manager Encryption Settings 159 cdstvIngestMgrHostAddress) of the Ingest Manager." 209 "This object specifies the maximum period the Ingest Manager [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/docker/vendor/github.com/armon/go-metrics/ |
H A D | inmem.go | 94 func (a *AggregateSample) Ingest(v float64) { func 160 agg.Ingest(float64(val)) 175 agg.Ingest(float64(val))
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/armon/go-metrics/ |
H A D | inmem.go | 94 func (a *AggregateSample) Ingest(v float64) { func 160 agg.Ingest(float64(val)) 175 agg.Ingest(float64(val))
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/armon/go-metrics/ |
H A D | inmem.go | 94 func (a *AggregateSample) Ingest(v float64) { func 160 agg.Ingest(float64(val)) 175 agg.Ingest(float64(val))
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/armon/go-metrics/ |
H A D | inmem.go | 94 func (a *AggregateSample) Ingest(v float64) { func 160 agg.Ingest(float64(val)) 175 agg.Ingest(float64(val))
|
/dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/armon/go-metrics/ |
H A D | inmem.go | 94 func (a *AggregateSample) Ingest(v float64) { func 160 agg.Ingest(float64(val)) 175 agg.Ingest(float64(val))
|
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/github.com/armon/go-metrics/ |
H A D | inmem.go | 94 func (a *AggregateSample) Ingest(v float64) { func 160 agg.Ingest(float64(val)) 175 agg.Ingest(float64(val))
|
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/libnetwork/vendor/github.com/armon/go-metrics/ |
H A D | inmem.go | 94 func (a *AggregateSample) Ingest(v float64) { func 160 agg.Ingest(float64(val)) 175 agg.Ingest(float64(val))
|
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/armon/go-metrics/ |
H A D | inmem.go | 94 func (a *AggregateSample) Ingest(v float64) { func 160 agg.Ingest(float64(val)) 175 agg.Ingest(float64(val))
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/armon/go-metrics/ |
H A D | inmem.go | 94 func (a *AggregateSample) Ingest(v float64) { func 160 agg.Ingest(float64(val)) 175 agg.Ingest(float64(val))
|