MCPcopy Create free account

hub / github.com/alibaba/loongcollector / functions

Functions13,853 in github.com/alibaba/loongcollector

↓ 37 callersMethodGetProcessQueueKey
core/collection_pipeline/CollectionPipelineContext.h:54
↓ 37 callersMethodGetSource
()
pkg/protocol/sls_logs.pb.go:264
↓ 37 callersMethodHandleEvent
core/ebpf/plugin/agentsight/AgentsightManager.cpp:535
↓ 37 callersMethodPostPop
core/collection_pipeline/limiter/RateLimiter.cpp:37
↓ 37 callersMethodSendAlarmError
core/monitor/AlarmManager.h:152
↓ 36 callersMethodDestroy
* Destroy skel and release resources. */
core/ebpf/driver/BPFWrapper.h:390
↓ 36 callersMethodLoadMethod
LoadMethod loads method named @methodName from opened lib. If error is found, @error param will be set, otherwise empty.
core/common/DynamicLibHelper.cpp:86
↓ 36 callersMethodRemove
(key string)
pkg/helper/k8smeta/k8s_meta_deferred_deletion_meta_store.go:27
↓ 36 callersMethodReset
Reset resets the state of backoff.
plugins/input/syslog/backoff.go:25
↓ 35 callersFunctionGetErrno
core/common/ErrorUtil.h:38
↓ 35 callersMethodGetField
core/host_monitor/common/FastFieldParser.cpp:24
↓ 35 callersMethodGetSize
()
pkg/models/pipeline.go:32
↓ 35 callersMethodLoadCheckpointFile
core/config/OnetimeConfigInfoManager.cpp:160
↓ 35 callersFunctionNewGroup
(meta Metadata, tags Tags)
pkg/models/factory.go:65
↓ 35 callersMethodOnSendDone
core/unittest/plugin/PluginMock.h:278
↓ 35 callersMethodSetPipeline
core/collection_pipeline/CollectionPipelineContext.h:59
↓ 34 callersFunctionBoostRegexSearch
core/common/StringTools.cpp:154
↓ 34 callersMethodCount
core/ebpf/util/FrequencyManager.h:33
↓ 34 callersMethodCreateOrUpdateCountBoundedQueue
core/collection_pipeline/queue/ProcessQueueManager.cpp:41
↓ 34 callersMethodDescription
()
pkg/doc/doc.go:22
↓ 34 callersFunctionGetOptionalUIntParam
core/common/ParamExtractor.cpp:87
↓ 34 callersMethodHasLabel
core/monitor/metric_models/MetricRecord.cpp:208
↓ 34 callersFunctionParseRequest
core/ebpf/protocol/http/HttpParser.cpp:102
↓ 34 callersMethodSub
core/monitor/metric_models/MetricTypes.h:82
↓ 34 callersFunctionnewMetricLogFromRaw
(name string, labels *helper.MetricLabels, nsec int64, value float64)
pkg/protocol/decoder/opentelemetry/otlpDataToSLSProto.go:68
↓ 33 callersMethodAddValue
core/host_monitor/collector/MetricCalculate.h:41
↓ 33 callersFunctionGetCurrentTimeInMicroSeconds
core/common/TimeUtil.cpp:82
↓ 33 callersMethodInitContext
(project, logstore, configName string)
pluginmanager/context_imp.go:99
↓ 33 callersMethodIsValidToPop
core/collection_pipeline/limiter/RateLimiter.cpp:26
↓ 33 callersMethodSend
(*LogData)
plugins/input/skywalkingv3/skywalking/network/logging/v3/Logging_grpc.pb.go:48
↓ 33 callersFunctiongetPluginMeta
core/unittest/processor/ProcessorParseDelimiterNativeUnittest.cpp:68
↓ 32 callersMethodGetCounter
core/monitor/metric_models/ReentrantMetricsRecord.cpp:56
↓ 32 callersMethodGetLabels
()
pkg/helper/profile/pyroscope/jfr/jfr_labels.pb.go:64
↓ 32 callersMethodHandle
core/unittest/event_handler/CreateModifyHandlerUnittest.cpp:44
↓ 32 callersMethodHasMetadata
core/models/MetricEvent.cpp:95
↓ 32 callersMethodOnFail
core/collection_pipeline/limiter/ConcurrencyLimiter.cpp:93
↓ 32 callersFunctionmin
core/plugin/flusher/sls/SLSUtil.cpp:111
↓ 31 callersMethodBytes
Bytes returns a slice of length b.Len() holding the bytes that have been written to the buffer.
external/github.com/elastic/beats/v7/winlogbeat/sys/buffer.go:56
↓ 31 callersMethodCreate
core/ebpf/driver/BPFWrapper.h:65
↓ 31 callersMethodCreateLogEvent
core/models/PipelineEventGroup.cpp:131
↓ 31 callersMethodGetLogstore
()
pkg/pipeline/context.go:30
↓ 31 callersMethodIterator
()
pkg/models/common.go:86
↓ 31 callersFunctionNewSingleValueMetric
(name string, metricType MetricType, tags Tags, timestamp int64, value T)
pkg/models/factory.go:82
↓ 31 callersFunctionSetLogTime
(log *Log, second uint32)
pkg/protocol/sls_logs.pb.helper.go:24
↓ 31 callersFunctiongetPluginMeta
core/unittest/processor/ProcessorDesensitizeNativeUnittest.cpp:57
↓ 31 callersFunctionsovSpanEvent
(x uint64)
pkg/protocol/span_event.pb.go:847
↓ 30 callersMethodAddRawLog
(log *protocol.Log)
pkg/pipeline/collector.go:44
↓ 30 callersFunctionAttrHashCombine
* This implementation is adapted from the OpenTelemetry project * Original source: https://github.com/open-telemetry/opentelemetry-cpp * (https://gi
core/common/HashUtil.h:48
↓ 30 callersFunctionCreateKafkaTestConfig
core/unittest/flusher/FlusherKafkaUnittest.cpp:64
↓ 30 callersMethodCreateOrUpdateQueue
core/collection_pipeline/queue/ExactlyOnceQueueManager.cpp:38
↓ 30 callersFunctionEndWith
core/common/StringTools.h:48
↓ 30 callersMethodGenNextPluginMeta
core/collection_pipeline/CollectionPipeline.cpp:654
↓ 30 callersFunctionNewFlusherDoris
()
plugins/flusher/doris/flusher_doris.go:105
↓ 30 callersMethodbegin
* @brief 获取字段迭代器开始位置 * @return StringViewSplitterIterator */
core/host_monitor/common/FastFieldParser.h:68
↓ 30 callersMethodlock
core/common/Lock.h:50
↓ 30 callersFunctionreadString
readString reads a pointer using the reader then parses the UTF-16 string that the pointer addresses within the buffer.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/wineventlog_windows.go:463
↓ 29 callersFunctionReadLogVal
ReadLogVal returns the log content value for the input key, and returns empty string when not found.
pkg/protocol/decoder/pyroscope/decoder_test.go:126
↓ 29 callersMethodcomputeMatchedContainersDiff
core/container_manager/ContainerManager.cpp:648
↓ 29 callersFunctionencodeVarintSpanEvent
(dAtA []byte, offset int, v uint64)
pkg/protocol/span_event.pb.go:695
↓ 28 callersFunctionGetHostName
()
pkg/util/net_helper.go:47
↓ 28 callersMethodGetInode
core/file_server/event/Event.h:99
↓ 28 callersMethodGetOneConfigServerAddress
core/config/common_provider/CommonConfigProvider.cpp:191
↓ 28 callersMethodHandleHostMetadataUpdate
called by curl thread, async update configs for container ...
core/ebpf/plugin/network_observer/NetworkObserverManager.cpp:1421
↓ 28 callersFunctionParseResponse
core/ebpf/protocol/http/HttpParser.cpp:327
↓ 28 callersMethodRelease
core/models/EventPool.cpp:79
↓ 28 callersMethodemplace
core/common/LRUCache.h:131
↓ 28 callersFunctionnewTimestampFormatMapping
(goFormat, generalFormat string)
pkg/fmtstr/format_timestamp.go:24
↓ 28 callersFunctiontestLinkGenerator
testLinkGenerator returns a LinkGenerator for unit tests (nil metaCacheMu; tests do not concurrently mutate the shared cache map).
pkg/helper/k8smeta/k8s_meta_link_test.go:19
↓ 27 callersMethodGetAvailableItems
core/collection_pipeline/queue/SenderQueue.cpp:127
↓ 27 callersMethodGetLinks
()
pkg/models/span.go:214
↓ 27 callersFunctionGetLogContentSize
core/protobuf/sls/LogGroupSerializer.cpp:227
↓ 27 callersMethodGetType
()
pkg/models/pipeline.go:24
↓ 27 callersMethodHasContent
core/models/LogEvent.cpp:60
↓ 27 callersMethodIsContainerStopped
core/file_server/event/Event.h:148
↓ 27 callersMethodIsFileOpened
core/file_server/reader/LogFileReader.h:307
↓ 27 callersMethodMerge
(other KeyValues[TValue])
pkg/models/common.go:84
↓ 27 callersMethodTagsSize
core/models/SpanEvent.h:184
↓ 27 callersFunctionfnmatch
fnmatch on Windows only supports *, does not support bracket (such as *.[Ll][Oo][Gg]).
core/common/StringTools.cpp:149
↓ 27 callersFunctiongenerateMockPod
(index string)
pkg/helper/k8smeta/k8s_meta_link_test.go:1641
↓ 26 callersFunctionErrnoToString
core/common/ErrorUtil.h:47
↓ 26 callersMethodFindConfigByName
core/config/InstanceConfigManager.cpp:48
↓ 26 callersMethodGetTraceId
core/models/SpanEvent.h:147
↓ 26 callersFunctionInitTestLogger
(options ...ConfigOption)
pkg/logger/logger.go:109
↓ 26 callersFunctionNewConverter
(protocol, encoding string, tagKeyRenameMap, protocolKeyRenameMap map[string]string, globalConfig *config.Glob
pkg/protocol/converter/converter.go:144
↓ 26 callersMethodReadUTF8
core/file_server/reader/LogFileReader.cpp:1570
↓ 26 callersFunctionreadLog
(index int)
pkg/logger/logger_test.go:55
↓ 25 callersMethodDataSize
core/collection_pipeline/batch/BatchItem.h:63
↓ 25 callersMethodGetLogCount
()
plugins/flusher/checker/flusher_checker.go:45
↓ 25 callersMethodGetSpanId
core/models/SpanEvent.h:150
↓ 25 callersMethodInit
Init called for init some system resources, like socket, mutex...
plugins/processor/stringreplace/processor_string_replace.go:61
↓ 25 callersFunctionParseYamlTable
core/common/YamlUtil.cpp:27
↓ 25 callersMethodRange
core/prometheus/labels/Labels.cpp:99
↓ 25 callersMethodUpdate
core/unittest/forward/MockServiceImpl.h:27
↓ 25 callersFunctionXXH_memcpy
! * @internal * @brief Modify this function to use a different routine than memcpy(). */
core/common/xxhash/xxhash.h:1762
↓ 25 callersFunctiongenerateNameWithNamespaceKey
(namespace, name string)
pkg/helper/k8smeta/k8s_meta_cache.go:451
↓ 25 callersMethodprocessEntityLinkCommonPart
(logContents models.LogContents, srcKind, srcNamespace, srcName, destKind, destNamespace, destName, method str
plugins/input/kubernetesmetav2/meta_collector.go:354
↓ 25 callersMethodunlock
core/common/Lock.h:56
↓ 24 callersMethodAddLogContent
core/protobuf/sls/LogGroupSerializer.cpp:122
↓ 24 callersFunctionCheckExistance
core/common/FileSystemUtil.cpp:52
↓ 24 callersMethodClean
()
pkg/helper/containercenter/container_discover_controller.go:144
← previousnext →201–300 of 13,853, ranked by callers