Home
last modified time | relevance | path

Searched refs:Ingest (Results 1 – 25 of 430) sorted by relevance

12345678910>>...18

/dports/textproc/miller/miller-5.10.2/go/src/transformers/utils/
H A Dstats1-accumulators.go18 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 Dcast_framer_unittest.cc57 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 Dcast_framer_unittest.cc57 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 Dmode.rs9 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 Dinsert_compressed_chunks_test.go30 _, _, 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 Dmetadata_test.go35 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 Ddb_connections_test.go52 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 Dzlast_test.go38 if _, _, err := ingestor.Ingest(newWriteRequestWithTs(copyMetrics(ts))); err != nil {
47 if _, _, err := ingestor.Ingest(newWriteRequestWithTs(copyMetrics(tts))); err != nil {
H A Dcreate_test.go176 _, _, 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 DIngest.pm1 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 DIngest.pm1 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 Dhttp_admin.go33 <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 Dhttp_admin.go33 <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 Dingestor_subsystem.desktop20 Name[pt]=Ingestão
21 Name[pt_BR]=Ingestão
/dports/net-mgmt/observium/observium/mibs/cisco/
H A DCISCO-CDSTV-INGESTMGR-MIB2 -- 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 DCISCO-CDSTV-INGESTMGR-MIB.my2 -- 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 Dinmem.go94 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 Dinmem.go94 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 Dinmem.go94 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 Dinmem.go94 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 Dinmem.go94 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 Dinmem.go94 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 Dinmem.go94 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 Dinmem.go94 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 Dinmem.go94 func (a *AggregateSample) Ingest(v float64) { func
160 agg.Ingest(float64(val))
175 agg.Ingest(float64(val))

12345678910>>...18