MCPcopy Create free account

hub / github.com/SumoLogic/sumologic-otel-collector / functions

Functions1,154 in github.com/SumoLogic/sumologic-otel-collector

↓ 215 callersMethodErrorf
(_ context.Context, fmt string, v ...interface{})
pkg/extension/opampextension/opamp_agent.go:123
↓ 133 callersMethodLen
()
pkg/processor/metricfrequencyprocessor/pdata.go:13
↓ 92 callersMethodRun
(stopCh <-chan struct{})
pkg/processor/k8sprocessor/kube/fake_informer.go:93
↓ 88 callersMethodString
()
pkg/processor/k8sprocessor/processor_test.go:318
↓ 71 callersMethodGet
(key string)
pkg/processor/lookupprocessor/lookupsource/cache.go:70
↓ 65 callersMethodType
()
pkg/processor/lookupprocessor/lookupsource/source.go:30
↓ 52 callersMethodRun
Run the command. May only be invoked once.
pkg/receiver/jobreceiver/command/command.go:97
↓ 50 callersMethodShutdown
(ctx context.Context)
pkg/processor/lookupprocessor/lookupsource/source.go:32
↓ 45 callersMethodCreateDefaultConfig
()
pkg/processor/lookupprocessor/lookupsource/factory.go:32
↓ 45 callersMethodName
()
pkg/receiver/jobreceiver/asset/expander.go:31
↓ 36 callersMethodLookup
(ctx context.Context, key string)
pkg/processor/lookupprocessor/lookupsource/source.go:29
↓ 31 callersFunctionassertAttribute
(t *testing.T, attributes pcommon.Map, attributeName string, expectedValue string)
pkg/processor/sourceprocessor/source_processor_test.go:661
↓ 31 callersFunctionnewSourceProcessor
(set processor.Settings, cfg *Config)
pkg/processor/sourceprocessor/source_processor.go:92
↓ 28 callersMethodClose
Close builds a new log entry based off the exeuction summary and contents of the buffer. Writes the entry to the pipeline.
pkg/receiver/jobreceiver/output/event/handler.go:78
↓ 28 callersFunctionWithName
WithName returns a MetricOpt which will set the returned metric name.
pkg/receiver/telegrafreceiver/metric_opt.go:29
↓ 28 callersFunctionnewOpampAgent
(cfg *Config, logger *zap.Logger, build component.BuildInfo, res pcommon.Resource)
pkg/extension/opampextension/opamp_agent.go:355
↓ 28 callersFunctionnewProcessorCreateSettings
()
pkg/processor/sourceprocessor/source_processor_test.go:762
↓ 27 callersFunctionWithTime
WithTime returns a MetricOpt which will set the returned metric's timestamp.
pkg/receiver/telegrafreceiver/metric_opt.go:42
↓ 26 callersMethodCreateSource
(ctx context.Context, settings CreateSettings, cfg SourceConfig)
pkg/processor/lookupprocessor/lookupsource/factory.go:34
↓ 25 callersMethodProcessTraces
ProcessTraces processes traces
pkg/processor/sourceprocessor/source_processor.go:185
↓ 25 callersFunctionmakeFlagSet
(fv *flagValues)
pkg/tools/otelcol-config/flag.go:84
↓ 25 callersFunctionnewFlagValues
()
pkg/tools/otelcol-config/flag.go:80
↓ 23 callersMethodConsumeTraces
ConsumeTraces is required by the SpanProcessor interface.
pkg/processor/cascadingfilterprocessor/processor.go:313
↓ 22 callersFunctionNewFactory
NewFactory returns a new factory for the k8s processor.
pkg/processor/k8sprocessor/factory.go:42
↓ 22 callersFunctionnewTraceData
(labels map[string]string)
pkg/processor/sourceprocessor/source_processor_test.go:106
↓ 21 callersMethodTimestamp
()
pkg/receiver/telegrafreceiver/converter_test.go:659
↓ 20 callersFunctionReadConfigDir
ReadConfigDir reads the files in /etc/otelcol-sumo according to an expected layout. It produces a ConfDir that contains the data read from the files.
pkg/tools/otelcol-config/conf_loader.go:35
↓ 19 callersFunctionNewExtractionFieldTags
NewExtractionFieldTags builds a new instance of tags with default values
pkg/processor/k8sprocessor/kube/kube.go:189
↓ 18 callersMethodStart
()
pkg/processor/k8sprocessor/kube/kube.go:61
↓ 18 callersFunctioncreateK8sLabels
()
pkg/processor/sourceprocessor/source_processor_test.go:47
↓ 18 callersFunctiondefaultSetup
()
pkg/extension/opampextension/opamp_agent_test.go:47
↓ 17 callersMethodStart
(ctx context.Context, host component.Host)
pkg/processor/lookupprocessor/lookupsource/source.go:31
↓ 17 callersMethodValidate
()
pkg/processor/lookupprocessor/lookupsource/factory.go:13
↓ 17 callersFunctioncreateDefaultConfig
createDefaultConfig creates the default configuration for processor.
pkg/processor/sourceprocessor/factory.go:64
↓ 17 callersFunctioncreateTrace
(c *cascade, numSpans int, durationMicros int64)
pkg/processor/cascadingfilterprocessor/cascade_test.go:112
↓ 17 callersFunctionnewTestWriter
(exp []byte)
pkg/tools/otelcol-config/action_context_test.go:74
↓ 16 callersMethodhandlePodAdd
(obj interface{})
pkg/processor/k8sprocessor/kube/client.go:171
↓ 16 callersFunctionmkList
Makes platform compliant list of values
pkg/receiver/jobreceiver/asset/environment_test.go:13
↓ 15 callersMethodStop
()
pkg/processor/k8sprocessor/kube/kube.go:62
↓ 15 callersFunctionnewTraceDataWithSpans
(_resourceLabels map[string]string, _spanLabels map[string]string)
pkg/processor/sourceprocessor/source_processor_test.go:116
↓ 15 callersMethodsamplingPolicyOnTick
()
pkg/processor/cascadingfilterprocessor/processor.go:306
↓ 14 callersFunctionassertResourceHasStringAttribute
(t *testing.T, r pcommon.Resource, k, v string)
pkg/processor/k8sprocessor/processor_test.go:1023
↓ 14 callersFunctionnewIntGauge
( value int64, opts ...MetricOpt, )
pkg/receiver/telegrafreceiver/converter.go:282
↓ 14 callersFunctionnewMultiTest
( t *testing.T, cfg component.Config, errFunc func(err error), options ...Option, )
pkg/processor/k8sprocessor/processor_test.go:113
↓ 13 callersMethodRetrieve
(ctx context.Context, uri string, _ confmap.WatcherFunc)
pkg/configprovider/globprovider/provider.go:51
↓ 13 callersMethodString
()
pkg/receiver/jobreceiver/output/event/handler.go:118
↓ 13 callersMethodfill
fill takes a collection of attributes for a record and adds to it a new attribute with the source category for the record. The source category is ret
pkg/processor/sourceprocessor/source_category_filler.go:74
↓ 13 callersFunctiongenerateMetrics
(resourceFunc ...generateResourceFunc)
pkg/processor/k8sprocessor/processor_test.go:268
↓ 13 callersMethodgetPod
getPod takes an IP address or Pod UID and returns the pod the identifier is associated with.
pkg/processor/k8sprocessor/kube/client.go:268
↓ 13 callersMethodmakeProvisionalDecision
(id pcommon.TraceID, trace *sampling.TraceData)
pkg/processor/cascadingfilterprocessor/cascade.go:204
↓ 13 callersFunctionnewRateLimitter
(maxSpansPerSecond int32)
pkg/processor/cascadingfilterprocessor/rate_limitter.go:25
↓ 13 callersFunctionnewRawK8sEventsReceiver
create a new receiver
pkg/receiver/rawk8seventsreceiver/receiver.go:84
↓ 13 callersFunctionnewTestClient
(t *testing.T)
pkg/processor/k8sprocessor/kube/client_test.go:1332
↓ 12 callersMethodEvaluate
Evaluate looks at the trace data and returns a corresponding SamplingDecision.
pkg/processor/cascadingfilterprocessor/sampling/policy.go:72
↓ 12 callersFunctionNewFactory
NewFactory creates a factory for rawk8sevents receiver.
pkg/receiver/rawk8seventsreceiver/factory.go:38
↓ 12 callersMethodassertBatchesLen
(batchesLen int)
pkg/processor/k8sprocessor/processor_test.go:185
↓ 12 callersFunctionbuildBasicCFSP
(t *testing.T, numTraces uint64, spansPerSecond int32, collectorInstances uint)
pkg/processor/cascadingfilterprocessor/processor_test.go:61
↓ 12 callersFunctiongenerateIdsAndBatches
(numIds int)
pkg/processor/cascadingfilterprocessor/processor_test.go:732
↓ 12 callersFunctiongenerateLogs
(resourceFunc ...generateResourceFunc)
pkg/processor/k8sprocessor/processor_test.go:280
↓ 12 callersFunctionnewFakeAPIClientset
(_ k8sconfig.APIConfig)
pkg/processor/k8sprocessor/kube/client_test.go:44
↓ 12 callersFunctionnewSourceCategoryFiller
newSourceCategoryFiller creates a new sourceCategoryFiller.
pkg/processor/sourceprocessor/source_category_filler.go:40
↓ 12 callersMethodshouldBeDropped
(id pcommon.TraceID, trace *sampling.TraceData)
pkg/processor/cascadingfilterprocessor/cascade.go:193
↓ 12 callersMethodtestConsume
( ctx context.Context, traces ptrace.Traces, metrics pmetric.Metrics, logs plog.Logs, errFunc func(err er
pkg/processor/k8sprocessor/processor_test.go:159
↓ 11 callersMethodCleanup
()
pkg/processor/metricfrequencyprocessor/metriccache.go:72
↓ 11 callersFunctionNewFactory
NewFactory creates a factory for the DNS source.
pkg/processor/lookupprocessor/internal/source/dns/dns.go:81
↓ 11 callersFunctionNewWithSettings
(_ confmap.ProviderSettings)
pkg/configprovider/globprovider/provider.go:39
↓ 11 callersMethodSet
(key string, value any)
pkg/processor/lookupprocessor/lookupsource/cache.go:101
↓ 11 callersMethodStart
(operator.Persister)
pkg/receiver/jobreceiver/builder/config.go:18
↓ 11 callersFunctioncreateDefaultConfig
()
pkg/receiver/rawk8seventsreceiver/factory.go:45
↓ 11 callersFunctiongenerateTraces
(resourceFunc ...generateResourceFunc)
pkg/processor/k8sprocessor/processor_test.go:256
↓ 11 callersFunctiongetEvent
()
pkg/receiver/rawk8seventsreceiver/receiver_test.go:469
↓ 11 callersMethodhandlePodDelete
(obj interface{})
pkg/processor/k8sprocessor/kube/client.go:198
↓ 11 callersFunctionnewIntSum
( value int64, opts ...MetricOpt, )
pkg/receiver/telegrafreceiver/converter.go:244
↓ 10 callersMethodCreateDefaultConfig
()
pkg/receiver/jobreceiver/output/config.go:30
↓ 10 callersFunctionNewFactory
()
pkg/processor/lookupprocessor/factory.go:64
↓ 10 callersMethodUnmarshal
Unmarshal dynamic Builder underlying Config
pkg/receiver/jobreceiver/output/config.go:50
↓ 10 callersFunctionWithField
WithField returns a MetricOpt which will set the returned metric's field tag to the specified one.
pkg/receiver/telegrafreceiver/metric_opt.go:65
↓ 10 callersFunctionevaluate
(t *testing.T, evaluator policyEvaluator, traces *TraceData, expectedDecision Decision)
pkg/processor/cascadingfilterprocessor/sampling/span_properties_filter_test.go:55
↓ 10 callersFunctionwaitForWatchToBeEstablished
waitForWatchToBeEstablished tries to solve an issue with a data race when using a fake client with informers. Basically there is a small amount of ti
pkg/processor/k8sprocessor/kube/owner_test.go:34
↓ 9 callersFunctionNewWithSettings
New creates a new Provider, with its GlobProvider set to the result of globprovider.New().
pkg/configprovider/opampprovider/provider.go:70
↓ 9 callersMethodRegister
(name string, dataPoint pmetric.NumberDataPoint)
pkg/processor/metricfrequencyprocessor/metriccache.go:42
↓ 9 callersFunctionWithExtractMetadata
WithExtractMetadata allows specifying options to control extraction of pod metadata. If no fields explicitly provided, all metadata extracted by defau
pkg/processor/k8sprocessor/options.go:90
↓ 9 callersMethodWrite
(ctx context.Context, e *entry.Entry)
pkg/receiver/jobreceiver/output/consumer/consumer.go:35
↓ 9 callersMethodassertResourceObjectLen
(batchNo int)
pkg/processor/k8sprocessor/processor_test.go:191
↓ 9 callersMethodkubernetesProcessorOperation
(kpOp func(kp *kubernetesprocessor))
pkg/processor/k8sprocessor/processor_test.go:179
↓ 8 callersMethodGetOwners
(pod *Pod)
pkg/processor/k8sprocessor/kube/owner.go:62
↓ 8 callersFunctionNewCache
(cfg CacheConfig)
pkg/processor/lookupprocessor/lookupsource/cache.go:48
↓ 8 callersMethodRetrieve
(ctx context.Context, configPath string, fn confmap.WatcherFunc)
pkg/configprovider/opampprovider/provider.go:78
↓ 8 callersMethodassertResource
(batchNum int, resourceFunc func(res pcommon.Resource))
pkg/processor/k8sprocessor/processor_test.go:203
↓ 8 callersFunctionnewOwnerProvider
( logger *zap.Logger, client kubernetes.Interface, labelSelector labels.Selector, fieldSelector fields.Sel
pkg/processor/k8sprocessor/kube/owner.go:112
↓ 8 callersFunctionnewSyncIDBatcher
(numBatches uint64)
pkg/processor/cascadingfilterprocessor/processor_test.go:820
↓ 8 callersFunctionnewTraceStringAttrs
(nodeAttrs map[string]interface{}, spanAttrKey string, spanAttrValue string)
pkg/processor/cascadingfilterprocessor/sampling/string_tag_filter_test.go:103
↓ 7 callersMethodConsumeLogs
(context.Context, plog.Logs)
pkg/processor/lookupprocessor/processor_benchmark_test.go:192
↓ 7 callersMethodGetNamespace
()
pkg/processor/k8sprocessor/kube/client.go:580
↓ 7 callersMethodList
(metricName string)
pkg/processor/metricfrequencyprocessor/metriccache.go:56
↓ 7 callersMethodProcessMetrics
ProcessMetrics applies metricSieve to incoming metrics. It mutates the argument.
pkg/processor/metricfrequencyprocessor/processor.go:17
↓ 7 callersMethodaddOwnerInformer
( kind string, informer cache.SharedIndexInformer, addFunc func(kind string, obj interface{}), deleteFunc
pkg/processor/k8sprocessor/kube/owner.go:354
↓ 7 callersMethodapplyRemoteConfig
(config *protobufs.AgentRemoteConfig)
pkg/extension/opampextension/opamp_agent.go:591
↓ 7 callersFunctioncreateConfig
()
pkg/processor/sourceprocessor/source_processor_test.go:33
↓ 7 callersFunctioncreateDefaultConfig
()
pkg/extension/opampextension/factory.go:35
next →1–100 of 1,154, ranked by callers