MCPcopy Create free account

hub / github.com/alibaba/loongcollector / functions

Functions13,853 in github.com/alibaba/loongcollector

⨍ Functions 13,853◇ Types & classes 2,558
↓ 6 callersMethodSendAndClose
(*v3.Commands)
plugins/input/skywalkingv3/skywalking/network/logging/v3/Logging_grpc.pb.go:106
↓ 6 callersMethodSerializeWithStr
(log *protocol.Log, metricName, metricValueStr string)
pkg/selfmonitor/metrics_imp_v2.go:413
↓ 6 callersMethodSetAutoComplete
core/unittest/flusher/MockKafkaProducer.h:85
↓ 6 callersMethodSetBody
(body []byte)
pkg/models/logs.go:156
↓ 6 callersMethodSetContainerBaseDirForPath
计算单个配置路径在容器中的映射路径（不修改 containerInfo）
core/plugin/input/InputFile.cpp:296
↓ 6 callersMethodSetContainerDiscoveryOptions
core/file_server/FileDiscoveryOptions.h:70
↓ 6 callersMethodSetSigTermSignalFlag
core/application/Application.h:41
↓ 6 callersMethodSetUpDiffContainersMeta
core/unittest/pipeline/LogtailPluginMock.h:36
↓ 6 callersFunctionSplitRegexFromMap
core/container_manager/ContainerDiscoveryOptions.cpp:148
↓ 6 callersMethodStart
()
pkg/helper/k8smeta/k8s_meta_deferred_deletion_meta_store.go:76
↓ 6 callersMethodStop
core/common/timer/Timer.cpp:43
↓ 6 callersMethodSuspendPlugin
core/ebpf/EBPFServer.cpp:542
↓ 6 callersMethodUpdateMetrics
core/monitor/MetricManager.cpp:167
↓ 6 callersMethodUpdateProcessResult
(readN, processedN int)
pkg/helper/log_file_reader.go:217
↓ 6 callersMethodUpdateRawContainerInfo
core/file_server/FileDiscoveryOptions.cpp:799
↓ 6 callersMethodUpdateScrapeInput
@brief receive scrape jobs from input plugins and update scrape jobs
core/prometheus/PrometheusInputRunner.cpp:71
↓ 6 callersMethodWaitAndPop
core/common/SafeQueue.h:35
↓ 6 callersMethodWithParent
(key, parentID, parentName string)
pkg/helper/meta_helper.go:76
↓ 6 callersFunctionXXH3_mergeAccs
core/common/xxhash/xxhash.h:4845
↓ 6 callersFunctionXXH_xorshift64
! Seems to produce slightly better code on GCC for some reason. */
core/common/xxhash/xxhash.h:3740
↓ 6 callersFunction_EvtRender
(context EvtHandle, fragment EvtHandle, flags EvtRenderFlag, bufferSize uint32, buffer *byte, bufferUsed *uint
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/zsyscall_windows.go:171
↓ 6 callersFunctionapplyPluginConfig
(plugin interface{}, pluginConfig interface{})
pluginmanager/logstore_config.go:764
↓ 6 callersFunctionattrs2Labels
(labels *helper.MetricLabels, attrs pcommon.Map)
pkg/protocol/decoder/opentelemetry/otlpDataToSLSProto.go:72
↓ 6 callersFunctionattrsToLabels
(labels *helper.MetricLabels, attrs []*v1Common.KeyValue)
pkg/protocol/decoder/opentelemetry/otlp_metric_parser.go:20
↓ 6 callersMethodcolumnValueToString
(column *schema.TableColumn, rowVal interface{})
plugins/input/canal/input_canal.go:298
↓ 6 callersMethoddequeue
core/common/queue/concurrentqueue.h:1714
↓ 6 callersMethoddesensitize
(val string)
plugins/processor/desensitize/processor_desensitize.go:147
↓ 6 callersFunctionencodeVarintMetricEvent
(dAtA []byte, offset int, v uint64)
pkg/protocol/metric_event.pb.go:312
↓ 6 callersMethodfetchAll
()
pkg/helper/containercenter/cri_adapter.go:237
↓ 6 callersFunctionfile_common_JVM_proto_rawDescGZIP
()
plugins/input/skywalkingv2/skywalking/apm/network/language/agent/JVM.pb.go:512
↓ 6 callersFunctionfile_common_common_proto_rawDescGZIP
()
plugins/input/skywalkingv2/skywalking/apm/network/common/common.pb.go:395
↓ 6 callersFunctionfile_language_agent_Meter_proto_rawDescGZIP
()
plugins/input/skywalkingv3/skywalking/network/language/agent/v3/Meter.pb.go:524
↓ 6 callersMethodfindApplicationInstanceRegistryInfo
(int32)
plugins/input/skywalkingv2/application_cache.go:66
↓ 6 callersFunctionfind_string
core/common/Strptime.cpp:585
↓ 6 callersFunctionformatSize
core/unittest/spl/SplBenchmark.cpp:37
↓ 6 callersFunctiongenerateLogs
(agg *AggregatorContext, logNum int, withCtx bool, logNo []int, isShort bool)
plugins/aggregator/context/aggregator_context_test.go:176
↓ 6 callersFunctiongetLog
()
plugins/processor/drop/processor_drop_test.go:42
↓ 6 callersFunctiongetPluginMeta
core/unittest/spl/SplBenchmark.cpp:32
↓ 6 callersMethodincrementallyUpdateContainersSnapshot
core/container_manager/ContainerManager.cpp:377
↓ 6 callersFunctioninitMetricAttributes2
(dest pcommon.Map)
plugins/input/opentelemetry/service_otlp_test.go:665
↓ 6 callersMethodkeyMatch
(key []byte)
pluginmanager/checkpoint_manager.go:148
↓ 6 callersMethodloadContainerInfoFromDetailFormat
core/container_manager/ContainerManager.cpp:924
↓ 6 callersMethodmalloc
core/common/queue/concurrentqueue.h:402
↓ 6 callersMethodmarkRemove
We mark container removed if it is exited or its metadata cannot be accessed e.g. cannot docker inspect / crictl inspect it.
pkg/helper/containercenter/container_center.go:1345
↓ 6 callersFunctionnewAggregatorContext
()
plugins/aggregator/context/aggregator_context_test.go:70
↓ 6 callersFunctionnewInputV2
()
plugins/input/snmp/input_snmp_test.go:137
↓ 6 callersFunctionnewParseResult
()
plugins/input/syslog/parser.go:42
↓ 6 callersFunctionnewProcessor
(idxs ...int)
plugins/processor/drop/processor_drop_test.go:28
↓ 6 callersFunctionnewProcessor
()
plugins/processor/grok/processor_grok_test.go:43
↓ 6 callersFunctionnewProcessor
()
plugins/processor/desensitize/processor_desensitize_test.go:30
↓ 6 callersMethodreadVarint32
core/protobuf/models/ManualPBParser.cpp:184
↓ 6 callersFunctionregex
(args, logger, faker)
test/engine/trigger/log/remote_file.py:93
↓ 6 callersFunctionsearchPair
(contents []*protocol.Log_Content, key string, value string)
plugins/processor/split/keyvalue/key_value_splitter_test.go:27
↓ 6 callersMethodselectShardAgg
(sourceValue string)
plugins/aggregator/shardhash/aggregator_shardhash.go:158
↓ 6 callersFunctionsendRequest
(bodyToSend string, port int)
plugins/input/httpserver/input_http_server_test.go:199
↓ 6 callersMethodsetLastError
(err error, msg string)
pkg/helper/containercenter/container_center.go:928
↓ 6 callersMethodshouldDropDNSEvent
(fields map[string]string)
plugins/input/input_etw/dns_enrichment.go:51
↓ 6 callersFunctionskipPipelineEventGroup
(dAtA []byte)
pkg/protocol/pipeline_event_group.pb.go:1356
↓ 6 callersFunctionvalidate
(expectedResultPath string, result []*protocol.Log, t *testing.T)
plugins/input/skywalkingv3/jvm_metric_handle_test.go:47
↓ 6 callersMethodwait
core/common/WaitObject.h:48
↓ 6 callersMethodzapLevel
()
external/github.com/elastic/beats/v7/libbeat/logp/level.go:85
↓ 5 callersFunctionAbsolutePath
core/common/FileSystemUtil.cpp:96
↓ 5 callersMethodAcceptNetDataEvent
core/ebpf/plugin/network_observer/ConnectionManager.cpp:75
↓ 5 callersFunctionAddExtensionCreator
(name string, creator ExtensionCreator)
pkg/pipeline/plugin.go:84
↓ 5 callersMethodAddPlugin
(name string)
pluginmanager/context_imp.go:91
↓ 5 callersMethodAddRawLogWithContext
(log *protocol.Log, ctx map[string]interface{})
pkg/pipeline/collector.go:57
↓ 5 callersFunctionAtomicStoreFloat64
(dst *float64, n float64)
pkg/helper/math/math_helper.go:63
↓ 5 callersMethodBlockProcess
core/unittest/pipeline/LogtailPluginMock.h:31
↓ 5 callersFunctionCheckFileSignature
core/common/HashUtil.cpp:359
↓ 5 callersMethodClearContainerInfo
core/file_server/FileDiscoveryOptions.cpp:847
↓ 5 callersMethodClearFilePipelineMatchCache
core/file_server/ConfigManager.cpp:948
↓ 5 callersMethodClone
()
pkg/helper/log_helper.go:157
↓ 5 callersMethodClose
Close closes the subscription handle and any unread event handles.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/iterator.go:199
↓ 5 callersFunctionCompileKeys
(in string)
pkg/fmtstr/formatstring.go:133
↓ 5 callersFunctionContainerProcessAlive
(pid int)
pkg/helper/containercenter/process_helper_linux.go:29
↓ 5 callersMethodContainerStatus
(ctx context.Context, containerID string, verbose bool)
pkg/helper/containercenter/cri_runtime_api_interface.go:154
↓ 5 callersFunctionCreateAgentDir
core/app_config/AppConfig.cpp:185
↓ 5 callersMethodCreateFlushTimeoutEvent
core/file_server/reader/LogFileReader.cpp:2155
↓ 5 callersFunctionCreateStubProc
core/unittest/ebpf/ProcFsStub.h:30
↓ 5 callersMethodData
(buf []byte)
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/syscall_windows.go:402
↓ 5 callersMethodDataGetAndRemove
core/ebpf/plugin/ProcessDataMap.cpp:86
↓ 5 callersMethodDebugw
(msg string, keysAndValues ...interface{})
external/github.com/elastic/beats/v7/libbeat/common/file/rotator.go:72
↓ 5 callersMethodDecodeV2
DecodeV2 impl
pkg/protocol/decoder/opentelemetry/decoder.go:80
↓ 5 callersMethodDecreaseConcurrencyLimiterInSendingCnt
core/collection_pipeline/queue/SenderQueueManager.cpp:153
↓ 5 callersMethodDecreaseHttpSendingCnt
core/runner/FlusherRunner.cpp:112
↓ 5 callersFunctionDeletePerfBuffers
core/ebpf/driver/eBPFDriver.cpp:134
↓ 5 callersMethodDisablePlugin
core/ebpf/EBPFServer.cpp:479
↓ 5 callersMethodDownRetryTimes
core/forward/loongsuite/LoongSuiteForwardService.h:63
↓ 5 callersMethodDynamicAttachBPFObject
* attach bpf programs */
core/ebpf/driver/BPFWrapper.h:97
↓ 5 callersMethodDynamicDetachBPFObject
* detach bpf programs */
core/ebpf/driver/BPFWrapper.h:122
↓ 5 callersMethodEnablePopProcessQueue
core/collection_pipeline/queue/ExactlyOnceQueueManager.cpp:161
↓ 5 callersMethodEncodeV2
(*models.PipelineGroupEvents)
pkg/pipeline/extensions/encoder.go:46
↓ 5 callersMethodError
Error uses fmt.Sprint to construct and log a message.
external/github.com/elastic/beats/v7/libbeat/logp/logger.go:79
↓ 5 callersFunctionEvtGetObjectArraySize
(handle EvtObjectArrayPropertyHandle)
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/syscall_windows.go:564
↓ 5 callersMethodExecDone
core/prometheus/schedulers/BaseScheduler.cpp:9
↓ 5 callersMethodExportMetricRecords
()
pkg/pipeline/context.go:46
↓ 5 callersFunctionFileAppendOpen
core/common/FileSystemUtil.cpp:371
↓ 5 callersMethodFindAllSubDirAndHandler
core/file_server/EventDispatcher.cpp:828
↓ 5 callersMethodFinish
()
pkg/fmtstr/formatstring.go:444
↓ 5 callersMethodFlush
(projectName string, logstoreName string, configName string, logGroupList []*protocol.LogGroup)
plugins/flusher/http/flusher_http.go:194
← previousnext →1,101–1,200 of 13,853, ranked by callers