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
↓ 9 callers
Method
processLog
(log *protocol.Log)
plugins/processor/appender/processor_appender.go:76
↓ 9 callers
Method
registerHandler
(parser parameterParser, handler urlHandler)
plugins/input/skywalkingv3/input_skywalking_agent_v3_http.go:223
↓ 9 callers
Function
setAttributes
(attributes pcommon.Map, tags T)
pkg/protocol/converter/otlp.go:486
↓ 9 callers
Function
sovLogEvent
(x uint64)
pkg/protocol/log_event.pb.go:333
↓ 9 callers
Method
tryChangeRunningStatus
(err error)
plugins/input/process/input_process_cache_other.go:249
↓ 9 callers
Method
try_enqueue
Enqueues a single item (by copying it). Does not allocate memory. Fails if not enough room to enqueue (or implicit production is disabled because Trai
core/common/queue/concurrentqueue.h:1060
↓ 9 callers
Method
values
()
pkg/models/common.go:103
↓ 8 callers
Method
AcceptNetStatsEvent
core/ebpf/plugin/network_observer/ConnectionManager.cpp:89
↓ 8 callers
Method
AddCounter
core/prometheus/PromSelfMonitor.cpp:20
↓ 8 callers
Method
AddDoneCallback
core/prometheus/async/PromFuture.cpp:25
↓ 8 callers
Method
AddLabels
core/monitor/metric_models/MetricRecord.cpp:75
↓ 8 callers
Function
CalculateRandomUUID
core/common/UUIDUtil.cpp:27
↓ 8 callers
Method
Check
core/collection_pipeline/route/Condition.cpp:55
↓ 8 callers
Function
CopyCStr
core/ebpf/plugin/agentsight/AgentsightEvents.cpp:25
↓ 8 callers
Method
CreateFlusher
core/collection_pipeline/plugin/PluginRegistry.cpp:125
↓ 8 callers
Method
CreateInfoDetail
CreateInfoDetail create DockerInfoDetail with docker.Container Container property used in this function : HostsPath, Config.Hostname, Name, Config.Ima
pkg/helper/containercenter/container_center.go:710
↓ 8 callers
Function
CreateK8SFilter
CreateK8SFilter ...
pkg/helper/containercenter/container_center.go:91
↓ 8 callers
Function
DataSize
core/models/MetricValue.cpp:79
↓ 8 callers
Function
DoGC
core/models/EventPool.cpp:152
↓ 8 callers
Method
Enabled
Enabled returns true if given level is enabled.
external/github.com/elastic/beats/v7/libbeat/logp/level.go:67
↓ 8 callers
Function
EvtGetPublisherMetadataProperty
(publisherMetadataHandle EvtHandle, propertyID EvtPublisherMetadataPropertyID)
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/syscall_windows.go:510
↓ 8 callers
Method
FromJson
core/models/RawEvent.cpp:63
↓ 8 callers
Method
Gauge
core/monitor/metric_models/MetricTypes.h:62
↓ 8 callers
Function
GenerateSpanID
core/ebpf/util/TraceId.cpp:59
↓ 8 callers
Function
GetAgentConfDir
core/app_config/AppConfig.cpp:361
↓ 8 callers
Method
GetAndReset
core/ebpf/util/AggregateTree.h:85
↓ 8 callers
Method
GetContainerID
core/file_server/reader/LogFileReader.h:301
↓ 8 callers
Method
GetCurrentFileFingerprint
core/file_server/checkpoint/InputStaticFileCheckpoint.cpp:147
↓ 8 callers
Function
GetCurrentLogtailTime
core/common/TimeUtil.cpp:337
↓ 8 callers
Function
GetEnvTags
(firstKey, secondKey string)
pkg/util/util.go:315
↓ 8 callers
Method
GetEventPool
core/models/PipelineEventPtr.h:85
↓ 8 callers
Method
GetExpireTimeIfOneTime
core/config/PipelineConfig.cpp:83
↓ 8 callers
Method
GetGauge
core/monitor/metric_models/SelfMonitorMetricEvent.cpp:201
↓ 8 callers
Function
GetHostIp
core/common/MachineInfoUtil.cpp:341
↓ 8 callers
Method
GetIdxInReaderArrayFromLastCpt
core/file_server/reader/LogFileReader.h:261
↓ 8 callers
Method
GetKernelEventType
core/ebpf/type/CommonDataEvent.h:51
↓ 8 callers
Method
GetLogGroupList
()
pkg/protocol/sls_logs.pb.go:418
↓ 8 callers
Method
GetMinSizeBytes
core/collection_pipeline/batch/FlushStrategy.h:46
↓ 8 callers
Method
GetNodesWithAggDepth
core/ebpf/util/AggregateTree.h:129
↓ 8 callers
Function
GetOptionalIntParam
core/common/ParamExtractor.cpp:59
↓ 8 callers
Method
GetPluginType
core/ebpf/type/FileEvent.h:22
↓ 8 callers
Method
GetProcessQueueType
core/unittest/plugin/PluginMock.h:84
↓ 8 callers
Method
GetState
core/common/Thread.h:46
↓ 8 callers
Method
Hostname
(hostname string)
external/github.com/jeromer/syslogparser/rfc3164/rfc3164.go:55
↓ 8 callers
Method
IsDeleted
core/file_server/event/Event.h:146
↓ 8 callers
Method
IsError
core/ebpf/type/NetworkObserverEvent.h:92
↓ 8 callers
Method
IsHostPathMatchBlacklist
core/app_config/AppConfig.cpp:1718
↓ 8 callers
Method
IsInitialized
core/unittest/flusher/MockKafkaProducer.h:119
↓ 8 callers
Method
IsLogParseAlarmValid
core/app_config/AppConfig.h:408
↓ 8 callers
Function
IsNumber
core/prometheus/Utils.cpp:128
↓ 8 callers
Method
IsPurageContainerMode
core/app_config/AppConfig.h:511
↓ 8 callers
Method
IsReaderFlushTimeout
core/file_server/event/Event.h:150
↓ 8 callers
Method
IsValid
core/unittest/common/timer/TimerUnittest.cpp:27
↓ 8 callers
Method
LoadDynLib
LoadDynLib loads dynamic library named @libName from current working dir. For linux, the so name is 'lib+@libName.so'. For Windows, the dll name is '@
core/common/DynamicLibHelper.cpp:67
↓ 8 callers
Method
MakeRangeKey
core/file_server/checkpoint/CheckpointManagerV2.cpp:89
↓ 8 callers
Method
MarkProcessEventFlushStatus
core/ebpf/plugin/ProcessCacheManager.h:68
↓ 8 callers
Method
NeedFlushByCnt
core/collection_pipeline/batch/FlushStrategy.h:52
↓ 8 callers
Function
NewPromEncoder
(seriesLimit int)
pkg/protocol/encoder/prometheus/encoder_prometheus.go:35
↓ 8 callers
Function
ParseECSMeta
core/common/EcsMetaData.cpp:49
↓ 8 callers
Method
ParseLogTime
core/plugin/processor/ProcessorParseTimestampNative.cpp:181
↓ 8 callers
Method
Ping
()
pkg/helper/platformmeta/interface.go:50
↓ 8 callers
Method
Process
Process the file block and return how many bytes are processed LogFileReader will find last '\n' and call Process @note fileBlock may be nil, in this
pkg/helper/log_file_processor.go:24
↓ 8 callers
Method
PushEventQueue
core/file_server/event_handler/LogInput.cpp:467
↓ 8 callers
Method
PushSenderQueue
core/collection_pipeline/queue/ExactlyOnceQueueManager.cpp:170
↓ 8 callers
Method
RecordActive
core/ebpf/plugin/network_observer/Connection.h:136
↓ 8 callers
Method
SetDownStreamQueues
core/collection_pipeline/queue/ProcessQueueManager.cpp:245
↓ 8 callers
Method
SetEnableContainerDiscoveryFlag
core/file_server/FileDiscoveryOptions.h:64
↓ 8 callers
Method
SetInSendingCount
core/collection_pipeline/limiter/ConcurrencyLimiter.cpp:34
↓ 8 callers
Method
SetMinCnt
core/collection_pipeline/batch/FlushStrategy.h:43
↓ 8 callers
Method
SetNext
core/monitor/metric_models/MetricRecord.cpp:151
↓ 8 callers
Method
SetObservedTimestamp
(uint64)
pkg/models/pipeline.go:30
↓ 8 callers
Method
SetOffset
(offset uint64)
pkg/models/logs.go:85
↓ 8 callers
Method
SetUpStreamFeedbacks
core/collection_pipeline/queue/BoundedProcessQueue.cpp:78
↓ 8 callers
Method
ShouldDelete
core/monitor/metric_models/SelfMonitorMetricEvent.cpp:158
↓ 8 callers
Method
Size
()
pkg/protocol/pipeline_event_group.pb.go:72
↓ 8 callers
Function
StopAllPipelines
export StopAllPipelines
plugin_main/plugin_export.go:227
↓ 8 callers
Function
ToLowerCaseString
core/common/StringTools.cpp:35
↓ 8 callers
Function
ToString
core/common/StringTools.cpp:63
↓ 8 callers
Function
TraceIDToString
core/ebpf/util/TraceId.cpp:65
↓ 8 callers
Function
UTF16BytesToString
UTF16BytesToString returns a string that is decoded from the UTF-16 bytes. The byte slice must be of even length otherwise an error will be returned.
external/github.com/elastic/beats/v7/winlogbeat/sys/strings.go:92
↓ 8 callers
Method
UnCompress
core/unittest/compression/CompressorUnittest.cpp:27
↓ 8 callers
Function
XXH64_mergeRound
core/common/xxhash/xxhash.h:2713
↓ 8 callers
Function
XXH_setDispatch
! * @internal * @brief Runs a CPUID check and sets the correct dispatch tables. */
core/common/xxhash/xxh_x86dispatch.c:669
↓ 8 callers
Method
addMatcher
(namespace, resourceType string, matcher *labelMatcher)
plugins/input/kubernetesmetav1/kubernetes_collect.go:147
↓ 8 callers
Function
canParseToFloat64
(s string)
plugins/processor/logtoslsmetric/processor_log_to_sls_metric.go:357
↓ 8 callers
Function
destroy
core/common/queue/concurrentqueue.h:3642
↓ 8 callers
Function
errnoErr
errnoErr returns common boxed Errno values, to prevent allocations at runtime.
external/github.com/elastic/beats/v7/winlogbeat/sys/eventlogging/zsyscall_windows.go:43
↓ 8 callers
Function
file_language_agent_JVMMetric_proto_rawDescGZIP
()
plugins/input/skywalkingv3/skywalking/network/language/agent/v3/JVMMetric.pb.go:679
↓ 8 callers
Function
filter
Filter returns a new slice holding only the elements of s that satisfy the predicate fn().
plugins/input/input_wineventlog/eventlog/eventlogging.go:206
↓ 8 callers
Function
generate
(ctx context.Context, mode, path string, count, interval int, customKV ...string)
test/engine/trigger/log/file.go:70
↓ 8 callers
Function
get_random_mark
()
test/engine/trigger/log/remote_file.py:120
↓ 8 callers
Function
lookupFlag
lookupFlag returns the flag.Flag for the given name, or an error if not found
pkg/flags/flags.go:153
↓ 8 callers
Function
newTestGrpcMetricServiceV2
(t *testing.T, address string, pause time.Duration)
plugins/flusher/opentelemetry/flusher_otlp_test.go:547
↓ 8 callers
Method
preProcessCommon
(obj interface{})
pkg/helper/k8smeta/k8s_meta_cache.go:233
↓ 8 callers
Method
processGrok
(log *protocol.Log, val *string)
plugins/processor/grok/processor_grok.go:148
↓ 8 callers
Method
rebuild
core/file_server/checkpoint/CheckpointManagerV2.cpp:502
↓ 8 callers
Function
sovMetricEvent
(x uint64)
pkg/protocol/metric_event.pb.go:379
↓ 8 callers
Method
try_dequeue_bulk
core/common/queue/concurrentqueue.h:1231
↓ 7 callers
Method
AcceptDataEvent
core/ebpf/plugin/network_observer/NetworkObserverManager.cpp:1568
↓ 7 callers
Method
AddEvent
core/ebpf/plugin/RetryableEventCache.cpp:35
← previous
next →
801–900 of 13,853, ranked by callers