Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/alibaba/loongcollector
/ functions
Functions
13,853 in github.com/alibaba/loongcollector
⨍
Functions
13,853
◇
Types & classes
2,558
↓ 37 callers
Method
GetProcessQueueKey
core/collection_pipeline/CollectionPipelineContext.h:54
↓ 37 callers
Method
GetSource
()
pkg/protocol/sls_logs.pb.go:264
↓ 37 callers
Method
HandleEvent
core/ebpf/plugin/agentsight/AgentsightManager.cpp:535
↓ 37 callers
Method
PostPop
core/collection_pipeline/limiter/RateLimiter.cpp:37
↓ 37 callers
Method
SendAlarmError
core/monitor/AlarmManager.h:152
↓ 36 callers
Method
Destroy
* Destroy skel and release resources. */
core/ebpf/driver/BPFWrapper.h:390
↓ 36 callers
Method
LoadMethod
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 callers
Method
Remove
(key string)
pkg/helper/k8smeta/k8s_meta_deferred_deletion_meta_store.go:27
↓ 36 callers
Method
Reset
Reset resets the state of backoff.
plugins/input/syslog/backoff.go:25
↓ 35 callers
Function
GetErrno
core/common/ErrorUtil.h:38
↓ 35 callers
Method
GetField
core/host_monitor/common/FastFieldParser.cpp:24
↓ 35 callers
Method
GetSize
()
pkg/models/pipeline.go:32
↓ 35 callers
Method
LoadCheckpointFile
core/config/OnetimeConfigInfoManager.cpp:160
↓ 35 callers
Function
NewGroup
(meta Metadata, tags Tags)
pkg/models/factory.go:65
↓ 35 callers
Method
OnSendDone
core/unittest/plugin/PluginMock.h:278
↓ 35 callers
Method
SetPipeline
core/collection_pipeline/CollectionPipelineContext.h:59
↓ 34 callers
Function
BoostRegexSearch
core/common/StringTools.cpp:154
↓ 34 callers
Method
Count
core/ebpf/util/FrequencyManager.h:33
↓ 34 callers
Method
CreateOrUpdateCountBoundedQueue
core/collection_pipeline/queue/ProcessQueueManager.cpp:41
↓ 34 callers
Method
Description
()
pkg/doc/doc.go:22
↓ 34 callers
Function
GetOptionalUIntParam
core/common/ParamExtractor.cpp:87
↓ 34 callers
Method
HasLabel
core/monitor/metric_models/MetricRecord.cpp:208
↓ 34 callers
Function
ParseRequest
core/ebpf/protocol/http/HttpParser.cpp:102
↓ 34 callers
Method
Sub
core/monitor/metric_models/MetricTypes.h:82
↓ 34 callers
Function
newMetricLogFromRaw
(name string, labels *helper.MetricLabels, nsec int64, value float64)
pkg/protocol/decoder/opentelemetry/otlpDataToSLSProto.go:68
↓ 33 callers
Method
AddValue
core/host_monitor/collector/MetricCalculate.h:41
↓ 33 callers
Function
GetCurrentTimeInMicroSeconds
core/common/TimeUtil.cpp:82
↓ 33 callers
Method
InitContext
(project, logstore, configName string)
pluginmanager/context_imp.go:99
↓ 33 callers
Method
IsValidToPop
core/collection_pipeline/limiter/RateLimiter.cpp:26
↓ 33 callers
Method
Send
(*LogData)
plugins/input/skywalkingv3/skywalking/network/logging/v3/Logging_grpc.pb.go:48
↓ 33 callers
Function
getPluginMeta
core/unittest/processor/ProcessorParseDelimiterNativeUnittest.cpp:68
↓ 32 callers
Method
GetCounter
core/monitor/metric_models/ReentrantMetricsRecord.cpp:56
↓ 32 callers
Method
GetLabels
()
pkg/helper/profile/pyroscope/jfr/jfr_labels.pb.go:64
↓ 32 callers
Method
Handle
core/unittest/event_handler/CreateModifyHandlerUnittest.cpp:44
↓ 32 callers
Method
HasMetadata
core/models/MetricEvent.cpp:95
↓ 32 callers
Method
OnFail
core/collection_pipeline/limiter/ConcurrencyLimiter.cpp:93
↓ 32 callers
Function
min
core/plugin/flusher/sls/SLSUtil.cpp:111
↓ 31 callers
Method
Bytes
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 callers
Method
Create
core/ebpf/driver/BPFWrapper.h:65
↓ 31 callers
Method
CreateLogEvent
core/models/PipelineEventGroup.cpp:131
↓ 31 callers
Method
GetLogstore
()
pkg/pipeline/context.go:30
↓ 31 callers
Method
Iterator
()
pkg/models/common.go:86
↓ 31 callers
Function
NewSingleValueMetric
(name string, metricType MetricType, tags Tags, timestamp int64, value T)
pkg/models/factory.go:82
↓ 31 callers
Function
SetLogTime
(log *Log, second uint32)
pkg/protocol/sls_logs.pb.helper.go:24
↓ 31 callers
Function
getPluginMeta
core/unittest/processor/ProcessorDesensitizeNativeUnittest.cpp:57
↓ 31 callers
Function
sovSpanEvent
(x uint64)
pkg/protocol/span_event.pb.go:847
↓ 30 callers
Method
AddRawLog
(log *protocol.Log)
pkg/pipeline/collector.go:44
↓ 30 callers
Function
AttrHashCombine
* 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 callers
Function
CreateKafkaTestConfig
core/unittest/flusher/FlusherKafkaUnittest.cpp:64
↓ 30 callers
Method
CreateOrUpdateQueue
core/collection_pipeline/queue/ExactlyOnceQueueManager.cpp:38
↓ 30 callers
Function
EndWith
core/common/StringTools.h:48
↓ 30 callers
Method
GenNextPluginMeta
core/collection_pipeline/CollectionPipeline.cpp:654
↓ 30 callers
Function
NewFlusherDoris
()
plugins/flusher/doris/flusher_doris.go:105
↓ 30 callers
Method
begin
* @brief 获取字段迭代器开始位置 * @return StringViewSplitterIterator */
core/host_monitor/common/FastFieldParser.h:68
↓ 30 callers
Method
lock
core/common/Lock.h:50
↓ 30 callers
Function
readString
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 callers
Function
ReadLogVal
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 callers
Method
computeMatchedContainersDiff
core/container_manager/ContainerManager.cpp:648
↓ 29 callers
Function
encodeVarintSpanEvent
(dAtA []byte, offset int, v uint64)
pkg/protocol/span_event.pb.go:695
↓ 28 callers
Function
GetHostName
()
pkg/util/net_helper.go:47
↓ 28 callers
Method
GetInode
core/file_server/event/Event.h:99
↓ 28 callers
Method
GetOneConfigServerAddress
core/config/common_provider/CommonConfigProvider.cpp:191
↓ 28 callers
Method
HandleHostMetadataUpdate
called by curl thread, async update configs for container ...
core/ebpf/plugin/network_observer/NetworkObserverManager.cpp:1421
↓ 28 callers
Function
ParseResponse
core/ebpf/protocol/http/HttpParser.cpp:327
↓ 28 callers
Method
Release
core/models/EventPool.cpp:79
↓ 28 callers
Method
emplace
core/common/LRUCache.h:131
↓ 28 callers
Function
newTimestampFormatMapping
(goFormat, generalFormat string)
pkg/fmtstr/format_timestamp.go:24
↓ 28 callers
Function
testLinkGenerator
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 callers
Method
GetAvailableItems
core/collection_pipeline/queue/SenderQueue.cpp:127
↓ 27 callers
Method
GetLinks
()
pkg/models/span.go:214
↓ 27 callers
Function
GetLogContentSize
core/protobuf/sls/LogGroupSerializer.cpp:227
↓ 27 callers
Method
GetType
()
pkg/models/pipeline.go:24
↓ 27 callers
Method
HasContent
core/models/LogEvent.cpp:60
↓ 27 callers
Method
IsContainerStopped
core/file_server/event/Event.h:148
↓ 27 callers
Method
IsFileOpened
core/file_server/reader/LogFileReader.h:307
↓ 27 callers
Method
Merge
(other KeyValues[TValue])
pkg/models/common.go:84
↓ 27 callers
Method
TagsSize
core/models/SpanEvent.h:184
↓ 27 callers
Function
fnmatch
fnmatch on Windows only supports *, does not support bracket (such as *.[Ll][Oo][Gg]).
core/common/StringTools.cpp:149
↓ 27 callers
Function
generateMockPod
(index string)
pkg/helper/k8smeta/k8s_meta_link_test.go:1641
↓ 26 callers
Function
ErrnoToString
core/common/ErrorUtil.h:47
↓ 26 callers
Method
FindConfigByName
core/config/InstanceConfigManager.cpp:48
↓ 26 callers
Method
GetTraceId
core/models/SpanEvent.h:147
↓ 26 callers
Function
InitTestLogger
(options ...ConfigOption)
pkg/logger/logger.go:109
↓ 26 callers
Function
NewConverter
(protocol, encoding string, tagKeyRenameMap, protocolKeyRenameMap map[string]string, globalConfig *config.Glob
pkg/protocol/converter/converter.go:144
↓ 26 callers
Method
ReadUTF8
core/file_server/reader/LogFileReader.cpp:1570
↓ 26 callers
Function
readLog
(index int)
pkg/logger/logger_test.go:55
↓ 25 callers
Method
DataSize
core/collection_pipeline/batch/BatchItem.h:63
↓ 25 callers
Method
GetLogCount
()
plugins/flusher/checker/flusher_checker.go:45
↓ 25 callers
Method
GetSpanId
core/models/SpanEvent.h:150
↓ 25 callers
Method
Init
Init called for init some system resources, like socket, mutex...
plugins/processor/stringreplace/processor_string_replace.go:61
↓ 25 callers
Function
ParseYamlTable
core/common/YamlUtil.cpp:27
↓ 25 callers
Method
Range
core/prometheus/labels/Labels.cpp:99
↓ 25 callers
Method
Update
core/unittest/forward/MockServiceImpl.h:27
↓ 25 callers
Function
XXH_memcpy
! * @internal * @brief Modify this function to use a different routine than memcpy(). */
core/common/xxhash/xxhash.h:1762
↓ 25 callers
Function
generateNameWithNamespaceKey
(namespace, name string)
pkg/helper/k8smeta/k8s_meta_cache.go:451
↓ 25 callers
Method
processEntityLinkCommonPart
(logContents models.LogContents, srcKind, srcNamespace, srcName, destKind, destNamespace, destName, method str
plugins/input/kubernetesmetav2/meta_collector.go:354
↓ 25 callers
Method
unlock
core/common/Lock.h:56
↓ 24 callers
Method
AddLogContent
core/protobuf/sls/LogGroupSerializer.cpp:122
↓ 24 callers
Function
CheckExistance
core/common/FileSystemUtil.cpp:52
↓ 24 callers
Method
Clean
()
pkg/helper/containercenter/container_discover_controller.go:144
← previous
next →
201–300 of 13,853, ranked by callers