Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/GoogleCloudPlatform/appengine-sidecars-docker
/ functions
Functions
128 in github.com/GoogleCloudPlatform/appengine-sidecars-docker
⨍
Functions
128
◇
Types & classes
19
↓ 12 callers
Function
verifyContainerMetricInt64Value
(t *testing.T, data []*mpb.Metric, name, label string, value int64)
opentelemetry_collector/receiver/dockerstats/scraper_test.go:211
↓ 10 callers
Method
checkConsistency
(bounds []float64)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector.go:172
↓ 10 callers
Function
fakeNow
()
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:24
↓ 9 callers
Function
verifyContainerMetricAbsent
(t *testing.T, data []*mpb.Metric, name, label string)
opentelemetry_collector/receiver/dockerstats/scraper_test.go:239
↓ 6 callers
Function
NewVMAgeCollector
NewVMAgeCollector creates a new VMAgeCollector that generates metrics based on the buildDate and vmImageName.
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector.go:49
↓ 6 callers
Method
scrapeNginxStats
Get the stats from the nginx latency status module and parse them into the NginxStats struct.
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector.go:101
↓ 6 callers
Method
setupCollection
()
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector.go:101
↓ 5 callers
Function
MakeBuckets
MakeBuckets generates a proto representation of a distribution containing a single value. bounds defines the bucket boundaries of the distribution.
opentelemetry_collector/receiver/metricgenerator/metric_generator.go:66
↓ 4 callers
Function
NewFactory
NewFactory creates and returns a factory for the docker stats receiver.
opentelemetry_collector/receiver/dockerstats/factory.go:39
↓ 4 callers
Method
appendDistributionMetric
( stats *LatencyStats, bucketOptions *metricspb.DistributionValue_BucketOptions, metrics []*metricspb.Metri
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector.go:147
↓ 4 callers
Function
calculateImageAge
(buildDate time.Time, now time.Time)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector.go:73
↓ 4 callers
Function
getBucketIndex
(val float64, bounds []float64)
opentelemetry_collector/receiver/metricgenerator/metric_generator.go:78
↓ 4 callers
Function
getResponseFromJSON
(json string, status int)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:71
↓ 3 callers
Function
GetSumOfSquaredDeviationsFromIntDist
GetSumOfSquaredDeviationsFromIntDist calculates the sum of squared deviations from the mean. For values x_i this is: Sum[i=1..n]((x_i - mean)^2) C
opentelemetry_collector/receiver/metricgenerator/metric_generator.go:133
↓ 3 callers
Function
MakeLabelValue
MakeLabelValue generates a proto representation of a metric label with value as its value.
opentelemetry_collector/receiver/metricgenerator/metric_generator.go:102
↓ 3 callers
Function
NewFactory
NewFactory creates and returns a factory for the nginx receiver.
opentelemetry_collector/receiver/nginxreceiver/factory.go:47
↓ 3 callers
Function
NewFactory
NewFactory creates and returns a factory for the vm age receiver.
opentelemetry_collector/receiver/vmagereceiver/factory.go:40
↓ 3 callers
Function
appendError
(err error, newerr error)
opentelemetry_collector/components.go:31
↓ 3 callers
Function
checkDistributionMetricValue
(t *testing.T, data []*metricspb.Metric, name string, stats *LatencyStats)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:382
↓ 3 callers
Method
parseDate
(date string)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector.go:69
↓ 3 callers
Method
scrapeAndExport
()
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector.go:201
↓ 3 callers
Method
scrapeAndExportVMImageAge
()
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector.go:153
↓ 3 callers
Function
verifyContainerMetricDoubleValue
(t *testing.T, data []*mpb.Metric, name, label string, value float64)
opentelemetry_collector/receiver/dockerstats/scraper_test.go:225
↓ 2 callers
Function
MakeExponentialBucketOptions
MakeExponentialBucketOptions generates a proto representation of a config which, defines a distribution's bounds. This defines maxExponent + 2 buckets
opentelemetry_collector/receiver/metricgenerator/metric_generator.go:37
↓ 2 callers
Function
assertMetricGreaterThan0Double
(t *testing.T, expectedMetricDescriptor *metricspb.MetricDescriptor, metrics pdata.Metrics)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector_test.go:207
↓ 2 callers
Method
export
()
opentelemetry_collector/receiver/dockerstats/scraper.go:144
↓ 2 callers
Method
export
(metrics []*metricspb.Metric, errorKey string)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector.go:145
↓ 2 callers
Function
formatBuckets
(distribution []int64)
opentelemetry_collector/receiver/metricgenerator/metric_generator.go:90
↓ 2 callers
Method
makeErrorMetrics
()
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector.go:128
↓ 2 callers
Function
makeMetrics
(metricDescriptor *metricspb.MetricDescriptor, timeseries *metricspb.TimeSeries)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector.go:136
↓ 2 callers
Function
makeTimeseriesFromDistribution
makeTimeseriesFromDistribution formats a distribution proto as a TimeSeries.
opentelemetry_collector/receiver/metricgenerator/metric_generator.go:167
↓ 2 callers
Method
scrapeAndExportVMReadyTime
(readyTime float64)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector.go:171
↓ 2 callers
Method
start
()
opentelemetry_collector/receiver/dockerstats/scraper.go:123
↓ 2 callers
Method
stop
()
opentelemetry_collector/receiver/dockerstats/scraper.go:140
↓ 1 callers
Method
ConsumeMetrics
(ctx context.Context, md pdata.Metrics)
opentelemetry_collector/receiver/dockerstats/scraper_test.go:161
↓ 1 callers
Method
ConsumeMetrics
(ctx context.Context, metrics pdata.Metrics)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:89
↓ 1 callers
Method
ConsumeMetrics
(ctx context.Context, metrics pdata.Metrics)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector_test.go:128
↓ 1 callers
Method
ContainerInspect
(ctx context.Context, id string)
opentelemetry_collector/receiver/dockerstats/scraper_test.go:113
↓ 1 callers
Method
ContainerList
(ctx context.Context, opts types.ContainerListOptions)
opentelemetry_collector/receiver/dockerstats/scraper_test.go:29
↓ 1 callers
Method
ContainerStats
(ctx context.Context, id string, stream bool)
opentelemetry_collector/receiver/dockerstats/scraper_test.go:46
↓ 1 callers
Function
FormatBucketOptions
FormatBucketOptions formats a []float64 bounds as a DistributionValue_BucketOptions proto. bounds should list the upper boundaries of the distribution
opentelemetry_collector/receiver/metricgenerator/metric_generator.go:54
↓ 1 callers
Function
MakeDoubleTimeSeries
MakeDoubleTimeSeries generates a proto representation of a timeseries containing a single point for an double metric.
opentelemetry_collector/receiver/metricgenerator/metric_generator.go:22
↓ 1 callers
Function
MakeInt64TimeSeries
MakeInt64TimeSeries generates a proto representation of a timeseries containing a single point for an int64 metric.
opentelemetry_collector/receiver/metricgenerator/metric_generator.go:13
↓ 1 callers
Function
MakeSingleValueDistributionTimeSeries
MakeSingleValueDistributionTimeSeries generates a proto representation of a timeseries containing a single point consisting of a distribution containi
opentelemetry_collector/receiver/metricgenerator/metric_generator.go:112
↓ 1 callers
Function
NewNginxStatsCollector
NewNginxStatsCollector creates a new NginxStatsCollector that generates metrics based on nginx stats found by polling the url
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector.go:54
↓ 1 callers
Method
StartCollection
StartCollection starts a go routine that periodically polls nginx for stats and exports metrics based on them.
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector.go:77
↓ 1 callers
Method
StartCollection
StartCollection starts a go routine with a ticker that periodically generates and exports the metrics.
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector.go:83
↓ 1 callers
Method
StopCollection
StopCollection stops the polling for nginx stats and the export of the metrics.
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector.go:96
↓ 1 callers
Method
StopCollection
StopCollection stops the generation and export of the metrics.
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector.go:124
↓ 1 callers
Function
components
()
opentelemetry_collector/components.go:38
↓ 1 callers
Method
containerInfoToMetrics
(info containerInfo, labelValues []*mpb.LabelValue)
opentelemetry_collector/receiver/dockerstats/scraper.go:272
↓ 1 callers
Function
fakeNow
()
opentelemetry_collector/receiver/dockerstats/scraper_test.go:166
↓ 1 callers
Function
newScraper
(scrapeInterval time.Duration, metricConsumer consumer.Metrics, logger *zap.Logger)
opentelemetry_collector/receiver/dockerstats/scraper.go:107
↓ 1 callers
Method
readContainerInfo
(ctx context.Context, id string)
opentelemetry_collector/receiver/dockerstats/scraper.go:249
↓ 1 callers
Method
readResourceUsageStats
(ctx context.Context, id string)
opentelemetry_collector/receiver/dockerstats/scraper.go:187
↓ 1 callers
Function
readStatsJSON
readStatsJSON parses the stats JSON and sets defaults.
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector.go:121
↓ 1 callers
Method
storeMetric
(toStore pdata.Metrics)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector_test.go:124
↓ 1 callers
Method
usageStatsToMetrics
(stats *types.StatsJSON, labelValues []*mpb.LabelValue)
opentelemetry_collector/receiver/dockerstats/scraper.go:206
Method
Capabilities
()
opentelemetry_collector/receiver/dockerstats/scraper_test.go:155
Method
Capabilities
()
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:83
Method
Capabilities
()
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector_test.go:114
Method
ContainerList
(_ context.Context, _ types.ContainerListOptions)
opentelemetry_collector/receiver/dockerstats/scraper_test.go:252
Function
MakeDistributionTimeSeries
MakeDistributionTimeSeries formats a distribution and its metadata as a TimeSeries.
opentelemetry_collector/receiver/metricgenerator/metric_generator.go:143
Method
Shutdown
Shutdown tells this receiver to stop.
opentelemetry_collector/receiver/dockerstats/metrics_receiver.go:28
Method
Shutdown
Shutdown stops and cancels the underlying nginx metrics generator.
opentelemetry_collector/receiver/nginxreceiver/metrics_receiver.go:27
Method
Shutdown
Shutdown stops and cancels the underlying VM metrics generator.
opentelemetry_collector/receiver/vmagereceiver/metrics_receiver.go:27
Method
Start
Start tells this receiver to start.
opentelemetry_collector/receiver/dockerstats/metrics_receiver.go:20
Method
Start
Start starts the underlying nginx metrics generator.
opentelemetry_collector/receiver/nginxreceiver/metrics_receiver.go:19
Method
Start
Start starts the underlying VM metrics generator.
opentelemetry_collector/receiver/vmagereceiver/metrics_receiver.go:19
Function
TestAppendDistributionMetric
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:321
Function
TestCalculateImageAge
(t *testing.T)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector_test.go:24
Function
TestCalculateImageAgeWith0Age
(t *testing.T)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector_test.go:41
Function
TestCalculateImageAgeWithNegativeAge
(t *testing.T)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector_test.go:33
Function
TestCheckConsistency
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:223
Function
TestCheckConsistencyDistributionLengthErr
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:236
Function
TestCheckConsistencyNegativeDistribution
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:293
Function
TestCheckConsistencyNegativeRequest
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:251
Function
TestCheckConsistencyNegativeSum
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:279
Function
TestCheckConsistencyNegativeSumSquares
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:265
Function
TestCheckConsistencyUnsetDistribution
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:307
Function
TestCreateDefaultConfig
(t *testing.T)
opentelemetry_collector/receiver/dockerstats/factory_test.go:14
Function
TestCreateDefaultConfig
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/factory_test.go:14
Function
TestCreateDefaultConfig
(t *testing.T)
opentelemetry_collector/receiver/vmagereceiver/factory_test.go:14
Function
TestCreateMetricsReceiver
(t *testing.T)
opentelemetry_collector/receiver/dockerstats/factory_test.go:37
Function
TestCreateReceiver
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/factory_test.go:21
Function
TestCreateReceiver
(t *testing.T)
opentelemetry_collector/receiver/vmagereceiver/factory_test.go:21
Function
TestCreateTracesReceiver
(t *testing.T)
opentelemetry_collector/receiver/dockerstats/factory_test.go:23
Function
TestLoadConfig
(t *testing.T)
opentelemetry_collector/receiver/dockerstats/config_test.go:14
Function
TestLoadConfig
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/config_test.go:15
Function
TestLoadConfig
(t *testing.T)
opentelemetry_collector/receiver/vmagereceiver/config_test.go:15
Function
TestParseInputTimes
(t *testing.T)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector_test.go:50
Function
TestParseInputTimesError
(t *testing.T)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector_test.go:62
Function
TestScrapeAndExport
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:403
Function
TestScrapeAndExportError
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:441
Function
TestScrapeAndExportVMImageAge
(t *testing.T)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector_test.go:133
Function
TestScrapeAndExportVMImageAgeWithError
(t *testing.T)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector_test.go:171
Function
TestScrapeAndExportVMReadyTime
(t *testing.T)
opentelemetry_collector/receiver/vmagereceiver/vm_age_collector_test.go:152
Function
TestScrapeNginxStats
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:94
Function
TestScrapeNginxStatsError
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:206
Function
TestScrapeNginxStatsMalformatted
(t *testing.T)
opentelemetry_collector/receiver/nginxreceiver/nginx_stats_collector_test.go:189
next →
1–100 of 128, ranked by callers