Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/SumoLogic/sumologic-otel-collector
/ functions
Functions
1,154 in github.com/SumoLogic/sumologic-otel-collector
⨍
Functions
1,154
◇
Types & classes
221
↓ 215 callers
Method
Errorf
(_ context.Context, fmt string, v ...interface{})
pkg/extension/opampextension/opamp_agent.go:123
↓ 133 callers
Method
Len
()
pkg/processor/metricfrequencyprocessor/pdata.go:13
↓ 92 callers
Method
Run
(stopCh <-chan struct{})
pkg/processor/k8sprocessor/kube/fake_informer.go:93
↓ 88 callers
Method
String
()
pkg/processor/k8sprocessor/processor_test.go:318
↓ 71 callers
Method
Get
(key string)
pkg/processor/lookupprocessor/lookupsource/cache.go:70
↓ 65 callers
Method
Type
()
pkg/processor/lookupprocessor/lookupsource/source.go:30
↓ 52 callers
Method
Run
Run the command. May only be invoked once.
pkg/receiver/jobreceiver/command/command.go:97
↓ 50 callers
Method
Shutdown
(ctx context.Context)
pkg/processor/lookupprocessor/lookupsource/source.go:32
↓ 45 callers
Method
CreateDefaultConfig
()
pkg/processor/lookupprocessor/lookupsource/factory.go:32
↓ 45 callers
Method
Name
()
pkg/receiver/jobreceiver/asset/expander.go:31
↓ 36 callers
Method
Lookup
(ctx context.Context, key string)
pkg/processor/lookupprocessor/lookupsource/source.go:29
↓ 31 callers
Function
assertAttribute
(t *testing.T, attributes pcommon.Map, attributeName string, expectedValue string)
pkg/processor/sourceprocessor/source_processor_test.go:661
↓ 31 callers
Function
newSourceProcessor
(set processor.Settings, cfg *Config)
pkg/processor/sourceprocessor/source_processor.go:92
↓ 28 callers
Method
Close
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 callers
Function
WithName
WithName returns a MetricOpt which will set the returned metric name.
pkg/receiver/telegrafreceiver/metric_opt.go:29
↓ 28 callers
Function
newOpampAgent
(cfg *Config, logger *zap.Logger, build component.BuildInfo, res pcommon.Resource)
pkg/extension/opampextension/opamp_agent.go:355
↓ 28 callers
Function
newProcessorCreateSettings
()
pkg/processor/sourceprocessor/source_processor_test.go:762
↓ 27 callers
Function
WithTime
WithTime returns a MetricOpt which will set the returned metric's timestamp.
pkg/receiver/telegrafreceiver/metric_opt.go:42
↓ 26 callers
Method
CreateSource
(ctx context.Context, settings CreateSettings, cfg SourceConfig)
pkg/processor/lookupprocessor/lookupsource/factory.go:34
↓ 25 callers
Method
ProcessTraces
ProcessTraces processes traces
pkg/processor/sourceprocessor/source_processor.go:185
↓ 25 callers
Function
makeFlagSet
(fv *flagValues)
pkg/tools/otelcol-config/flag.go:84
↓ 25 callers
Function
newFlagValues
()
pkg/tools/otelcol-config/flag.go:80
↓ 23 callers
Method
ConsumeTraces
ConsumeTraces is required by the SpanProcessor interface.
pkg/processor/cascadingfilterprocessor/processor.go:313
↓ 22 callers
Function
NewFactory
NewFactory returns a new factory for the k8s processor.
pkg/processor/k8sprocessor/factory.go:42
↓ 22 callers
Function
newTraceData
(labels map[string]string)
pkg/processor/sourceprocessor/source_processor_test.go:106
↓ 21 callers
Method
Timestamp
()
pkg/receiver/telegrafreceiver/converter_test.go:659
↓ 20 callers
Function
ReadConfigDir
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 callers
Function
NewExtractionFieldTags
NewExtractionFieldTags builds a new instance of tags with default values
pkg/processor/k8sprocessor/kube/kube.go:189
↓ 18 callers
Method
Start
()
pkg/processor/k8sprocessor/kube/kube.go:61
↓ 18 callers
Function
createK8sLabels
()
pkg/processor/sourceprocessor/source_processor_test.go:47
↓ 18 callers
Function
defaultSetup
()
pkg/extension/opampextension/opamp_agent_test.go:47
↓ 17 callers
Method
Start
(ctx context.Context, host component.Host)
pkg/processor/lookupprocessor/lookupsource/source.go:31
↓ 17 callers
Method
Validate
()
pkg/processor/lookupprocessor/lookupsource/factory.go:13
↓ 17 callers
Function
createDefaultConfig
createDefaultConfig creates the default configuration for processor.
pkg/processor/sourceprocessor/factory.go:64
↓ 17 callers
Function
createTrace
(c *cascade, numSpans int, durationMicros int64)
pkg/processor/cascadingfilterprocessor/cascade_test.go:112
↓ 17 callers
Function
newTestWriter
(exp []byte)
pkg/tools/otelcol-config/action_context_test.go:74
↓ 16 callers
Method
handlePodAdd
(obj interface{})
pkg/processor/k8sprocessor/kube/client.go:171
↓ 16 callers
Function
mkList
Makes platform compliant list of values
pkg/receiver/jobreceiver/asset/environment_test.go:13
↓ 15 callers
Method
Stop
()
pkg/processor/k8sprocessor/kube/kube.go:62
↓ 15 callers
Function
newTraceDataWithSpans
(_resourceLabels map[string]string, _spanLabels map[string]string)
pkg/processor/sourceprocessor/source_processor_test.go:116
↓ 15 callers
Method
samplingPolicyOnTick
()
pkg/processor/cascadingfilterprocessor/processor.go:306
↓ 14 callers
Function
assertResourceHasStringAttribute
(t *testing.T, r pcommon.Resource, k, v string)
pkg/processor/k8sprocessor/processor_test.go:1023
↓ 14 callers
Function
newIntGauge
( value int64, opts ...MetricOpt, )
pkg/receiver/telegrafreceiver/converter.go:282
↓ 14 callers
Function
newMultiTest
( t *testing.T, cfg component.Config, errFunc func(err error), options ...Option, )
pkg/processor/k8sprocessor/processor_test.go:113
↓ 13 callers
Method
Retrieve
(ctx context.Context, uri string, _ confmap.WatcherFunc)
pkg/configprovider/globprovider/provider.go:51
↓ 13 callers
Method
String
()
pkg/receiver/jobreceiver/output/event/handler.go:118
↓ 13 callers
Method
fill
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 callers
Function
generateMetrics
(resourceFunc ...generateResourceFunc)
pkg/processor/k8sprocessor/processor_test.go:268
↓ 13 callers
Method
getPod
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 callers
Method
makeProvisionalDecision
(id pcommon.TraceID, trace *sampling.TraceData)
pkg/processor/cascadingfilterprocessor/cascade.go:204
↓ 13 callers
Function
newRateLimitter
(maxSpansPerSecond int32)
pkg/processor/cascadingfilterprocessor/rate_limitter.go:25
↓ 13 callers
Function
newRawK8sEventsReceiver
create a new receiver
pkg/receiver/rawk8seventsreceiver/receiver.go:84
↓ 13 callers
Function
newTestClient
(t *testing.T)
pkg/processor/k8sprocessor/kube/client_test.go:1332
↓ 12 callers
Method
Evaluate
Evaluate looks at the trace data and returns a corresponding SamplingDecision.
pkg/processor/cascadingfilterprocessor/sampling/policy.go:72
↓ 12 callers
Function
NewFactory
NewFactory creates a factory for rawk8sevents receiver.
pkg/receiver/rawk8seventsreceiver/factory.go:38
↓ 12 callers
Method
assertBatchesLen
(batchesLen int)
pkg/processor/k8sprocessor/processor_test.go:185
↓ 12 callers
Function
buildBasicCFSP
(t *testing.T, numTraces uint64, spansPerSecond int32, collectorInstances uint)
pkg/processor/cascadingfilterprocessor/processor_test.go:61
↓ 12 callers
Function
generateIdsAndBatches
(numIds int)
pkg/processor/cascadingfilterprocessor/processor_test.go:732
↓ 12 callers
Function
generateLogs
(resourceFunc ...generateResourceFunc)
pkg/processor/k8sprocessor/processor_test.go:280
↓ 12 callers
Function
newFakeAPIClientset
(_ k8sconfig.APIConfig)
pkg/processor/k8sprocessor/kube/client_test.go:44
↓ 12 callers
Function
newSourceCategoryFiller
newSourceCategoryFiller creates a new sourceCategoryFiller.
pkg/processor/sourceprocessor/source_category_filler.go:40
↓ 12 callers
Method
shouldBeDropped
(id pcommon.TraceID, trace *sampling.TraceData)
pkg/processor/cascadingfilterprocessor/cascade.go:193
↓ 12 callers
Method
testConsume
( ctx context.Context, traces ptrace.Traces, metrics pmetric.Metrics, logs plog.Logs, errFunc func(err er
pkg/processor/k8sprocessor/processor_test.go:159
↓ 11 callers
Method
Cleanup
()
pkg/processor/metricfrequencyprocessor/metriccache.go:72
↓ 11 callers
Function
NewFactory
NewFactory creates a factory for the DNS source.
pkg/processor/lookupprocessor/internal/source/dns/dns.go:81
↓ 11 callers
Function
NewWithSettings
(_ confmap.ProviderSettings)
pkg/configprovider/globprovider/provider.go:39
↓ 11 callers
Method
Set
(key string, value any)
pkg/processor/lookupprocessor/lookupsource/cache.go:101
↓ 11 callers
Method
Start
(operator.Persister)
pkg/receiver/jobreceiver/builder/config.go:18
↓ 11 callers
Function
createDefaultConfig
()
pkg/receiver/rawk8seventsreceiver/factory.go:45
↓ 11 callers
Function
generateTraces
(resourceFunc ...generateResourceFunc)
pkg/processor/k8sprocessor/processor_test.go:256
↓ 11 callers
Function
getEvent
()
pkg/receiver/rawk8seventsreceiver/receiver_test.go:469
↓ 11 callers
Method
handlePodDelete
(obj interface{})
pkg/processor/k8sprocessor/kube/client.go:198
↓ 11 callers
Function
newIntSum
( value int64, opts ...MetricOpt, )
pkg/receiver/telegrafreceiver/converter.go:244
↓ 10 callers
Method
CreateDefaultConfig
()
pkg/receiver/jobreceiver/output/config.go:30
↓ 10 callers
Function
NewFactory
()
pkg/processor/lookupprocessor/factory.go:64
↓ 10 callers
Method
Unmarshal
Unmarshal dynamic Builder underlying Config
pkg/receiver/jobreceiver/output/config.go:50
↓ 10 callers
Function
WithField
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 callers
Function
evaluate
(t *testing.T, evaluator policyEvaluator, traces *TraceData, expectedDecision Decision)
pkg/processor/cascadingfilterprocessor/sampling/span_properties_filter_test.go:55
↓ 10 callers
Function
waitForWatchToBeEstablished
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 callers
Function
NewWithSettings
New creates a new Provider, with its GlobProvider set to the result of globprovider.New().
pkg/configprovider/opampprovider/provider.go:70
↓ 9 callers
Method
Register
(name string, dataPoint pmetric.NumberDataPoint)
pkg/processor/metricfrequencyprocessor/metriccache.go:42
↓ 9 callers
Function
WithExtractMetadata
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 callers
Method
Write
(ctx context.Context, e *entry.Entry)
pkg/receiver/jobreceiver/output/consumer/consumer.go:35
↓ 9 callers
Method
assertResourceObjectLen
(batchNo int)
pkg/processor/k8sprocessor/processor_test.go:191
↓ 9 callers
Method
kubernetesProcessorOperation
(kpOp func(kp *kubernetesprocessor))
pkg/processor/k8sprocessor/processor_test.go:179
↓ 8 callers
Method
GetOwners
(pod *Pod)
pkg/processor/k8sprocessor/kube/owner.go:62
↓ 8 callers
Function
NewCache
(cfg CacheConfig)
pkg/processor/lookupprocessor/lookupsource/cache.go:48
↓ 8 callers
Method
Retrieve
(ctx context.Context, configPath string, fn confmap.WatcherFunc)
pkg/configprovider/opampprovider/provider.go:78
↓ 8 callers
Method
assertResource
(batchNum int, resourceFunc func(res pcommon.Resource))
pkg/processor/k8sprocessor/processor_test.go:203
↓ 8 callers
Function
newOwnerProvider
( logger *zap.Logger, client kubernetes.Interface, labelSelector labels.Selector, fieldSelector fields.Sel
pkg/processor/k8sprocessor/kube/owner.go:112
↓ 8 callers
Function
newSyncIDBatcher
(numBatches uint64)
pkg/processor/cascadingfilterprocessor/processor_test.go:820
↓ 8 callers
Function
newTraceStringAttrs
(nodeAttrs map[string]interface{}, spanAttrKey string, spanAttrValue string)
pkg/processor/cascadingfilterprocessor/sampling/string_tag_filter_test.go:103
↓ 7 callers
Method
ConsumeLogs
(context.Context, plog.Logs)
pkg/processor/lookupprocessor/processor_benchmark_test.go:192
↓ 7 callers
Method
GetNamespace
()
pkg/processor/k8sprocessor/kube/client.go:580
↓ 7 callers
Method
List
(metricName string)
pkg/processor/metricfrequencyprocessor/metriccache.go:56
↓ 7 callers
Method
ProcessMetrics
ProcessMetrics applies metricSieve to incoming metrics. It mutates the argument.
pkg/processor/metricfrequencyprocessor/processor.go:17
↓ 7 callers
Method
addOwnerInformer
( kind string, informer cache.SharedIndexInformer, addFunc func(kind string, obj interface{}), deleteFunc
pkg/processor/k8sprocessor/kube/owner.go:354
↓ 7 callers
Method
applyRemoteConfig
(config *protobufs.AgentRemoteConfig)
pkg/extension/opampextension/opamp_agent.go:591
↓ 7 callers
Function
createConfig
()
pkg/processor/sourceprocessor/source_processor_test.go:33
↓ 7 callers
Function
createDefaultConfig
()
pkg/extension/opampextension/factory.go:35
next →
1–100 of 1,154, ranked by callers