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
↓ 4,095 callers
Method
size
core/common/LRUCache.h:105
↓ 2,172 callers
Method
end
core/models/LogEvent.cpp:138
↓ 1,089 callers
Method
Init
Init called for init some system resources, like socket, mutex...
pkg/pipeline/flusher.go:26
↓ 1,056 callers
Method
begin
core/models/LogEvent.cpp:133
↓ 933 callers
Method
empty
core/common/LRUCache.h:109
↓ 884 callers
Method
insert
core/common/LRUCache.h:118
↓ 870 callers
Method
Errorf
Errorf uses fmt.Sprintf to log a templated message.
external/github.com/elastic/beats/v7/libbeat/logp/logger.go:117
↓ 845 callers
Method
data
core/common/magic_enum.hpp:267
↓ 778 callers
Method
find
(log *protocol.Log, key string)
plugins/processor/appender/processor_appender.go:108
↓ 776 callers
Method
GetRuntimeContext
()
pkg/pipeline/context.go:31
↓ 750 callers
Method
get
added for backward compatibility */
core/common/LRUCache.h:160
↓ 659 callers
Method
reset
()
pkg/protocol/converter/converter_sls_metric.go:202
↓ 576 callers
Function
ParseJsonTable
core/common/JsonUtil.cpp:30
↓ 554 callers
Method
Add
(key string, value TValue)
pkg/models/common.go:74
↓ 530 callers
Method
GetConfigName
()
pkg/pipeline/context.go:28
↓ 502 callers
Function
Warning
(ctx context.Context, alarmType selfmonitor.TypedAlarmType, kvPairs ...interface{})
pkg/logger/logger.go:188
↓ 466 callers
Function
CompactJson
core/common/JsonUtil.cpp:109
↓ 463 callers
Method
clear
core/common/LRUCache.h:113
↓ 460 callers
Function
ToString
core/common/StringTools.h:80
↓ 450 callers
Method
GetEvents
()
pkg/models/span.go:221
↓ 426 callers
Method
Process
(in *models.PipelineGroupEvents, context PipelineContext)
pkg/pipeline/processor.go:39
↓ 377 callers
Method
String
()
pkg/selfmonitor/alarm_type.go:28
↓ 342 callers
Method
str
core/host_monitor/SystemInterface.cpp:485
↓ 313 callers
Method
SetContext
core/task_pipeline/Task.h:39
↓ 302 callers
Method
Get
(key string)
pkg/models/common.go:78
↓ 301 callers
Method
Parse
(ctx context.Context, meta *Meta, tags map[string]string)
pkg/helper/profile/meta.go:228
↓ 300 callers
Method
GetValue
core/common/Thread.h:38
↓ 290 callers
Function
NewEmptyContext
(project, logstore, configName string)
plugins/test/mock/context.go:31
↓ 289 callers
Method
CreateMetricsRecordRef
core/monitor/MetricManager.cpp:38
↓ 285 callers
Method
FromJsonString
core/models/PipelineEvent.cpp:78
↓ 280 callers
Method
CommitMetricsRecordRef
core/monitor/MetricManager.cpp:47
↓ 280 callers
Method
Pointer
Pointer returns a pointer to an array of UTF-16 strings suitable to be passed to the FormatMessage API.
external/github.com/elastic/beats/v7/winlogbeat/sys/eventlogging/stringinserts_windows.go:95
↓ 270 callers
Method
GetAlarm
()
pkg/context.go:87
↓ 267 callers
Method
GetValue
()
plugins/input/skywalkingv3/skywalking/network/language/agent/v3/Meter.pb.go:92
↓ 267 callers
Method
Len
()
pkg/models/common.go:90
↓ 265 callers
Method
GetLogger
core/logger/Logger.cpp:165
↓ 265 callers
Method
GetTag
core/models/SpanEvent.cpp:42
↓ 258 callers
Function
Info
(ctx context.Context, kvPairs ...interface{})
pkg/logger/logger.go:170
↓ 257 callers
Method
ToJsonString
core/models/PipelineEvent.cpp:67
↓ 237 callers
Method
close
core/file_server/checkpoint/CheckpointManagerV2.cpp:370
↓ 234 callers
Method
load
(sampleType int64, labels tree.Labels)
pkg/helper/profile/pyroscope/pprof/pyroscope.go:98
↓ 218 callers
Method
Lock
core/common/WaitObject.h:39
↓ 217 callers
Method
GetKey
()
plugins/input/skywalkingv2/skywalking/apm/network/common/common.pb.go:189
↓ 217 callers
Method
Init
(inputQueueSize int, aggrQueueSize int)
pluginmanager/plugin_runner.go:41
↓ 205 callers
Function
Debug
(ctx context.Context, kvPairs ...interface{})
pkg/logger/logger.go:146
↓ 204 callers
Method
CopyString
core/common/memory/SourceBuffer.h:165
↓ 193 callers
Method
CreateCounter
core/monitor/metric_models/MetricRecord.cpp:39
↓ 190 callers
Method
SetTag
core/models/SpanEvent.cpp:56
↓ 187 callers
Method
UpdatePipelines
core/task_pipeline/TaskPipelineManager.cpp:27
↓ 186 callers
Method
SetConfigName
core/file_server/event/Event.h:123
↓ 181 callers
Method
Error
()
pkg/helper/grpc_helper.go:129
↓ 180 callers
Method
Name
()
pkg/selfmonitor/metrics_type.go:53
↓ 178 callers
Method
Stop
Stop stops flusher and release resources. It is time for flusher to do cleaning jobs, includes: 1. Export cached but not flushed data. For flushers th
pkg/pipeline/flusher.go:57
↓ 172 callers
Method
Contains
(key string)
pkg/models/common.go:80
↓ 170 callers
Method
Set
(float64)
pkg/selfmonitor/metrics_type.go:89
↓ 170 callers
Method
end
core/common/StringTools.h:301
↓ 164 callers
Method
GetName
()
pkg/models/pipeline.go:18
↓ 156 callers
Method
SetTimestamp
core/models/PipelineEvent.h:50
↓ 154 callers
Function
sleep
core/common/TimeUtil.h:93
↓ 146 callers
Function
close
(producer pulsar.Producer)
plugins/flusher/pulsar/producers.go:102
↓ 145 callers
Method
ParsePipelineEventGroup
core/protobuf/models/ManualPBParser.cpp:97
↓ 145 callers
Method
Start
Start starts the ServiceInput's service, whatever that may be
pkg/pipeline/input.go:57
↓ 142 callers
Method
GetSourceBuffer
core/ebpf/type/table/StaticDataRow.h:168
↓ 140 callers
Method
GetContent
core/models/LogEvent.cpp:50
↓ 135 callers
Method
Join
core/common/Thread.h:88
↓ 131 callers
Method
Size
()
pkg/protocol/metric_event.pb.go:117
↓ 129 callers
Method
Unmarshal
(dAtA []byte)
pkg/protocol/sls_logs.pb.go:912
↓ 126 callers
Method
Run
Run execute the formatter returning the generated string.
pkg/fmtstr/formatstring.go:39
↓ 122 callers
Method
SetContent
core/models/RawEvent.cpp:35
↓ 121 callers
Function
Warningf
(ctx context.Context, alarmType selfmonitor.TypedAlarmType, format string, params ...interface{})
pkg/logger/logger.go:207
↓ 120 callers
Method
WithAttribute
(k string, v interface{})
pkg/helper/meta_helper.go:89
↓ 120 callers
Method
open
core/file_server/checkpoint/CheckpointManagerV2.cpp:354
↓ 118 callers
Method
ProcessLogs
ProcessLogs the filter to the given metric
pkg/pipeline/processor.go:34
↓ 117 callers
Function
CreateLogs
(kvs ...string)
plugins/test/common.go:83
↓ 116 callers
Method
Append
Append ...
pkg/helper/log_helper.go:196
↓ 112 callers
Method
CheckConfigDiff
core/config/watcher/PipelineConfigWatcher.cpp:41
↓ 110 callers
Method
GetAllConfigNames
core/config/InstanceConfigManager.cpp:56
↓ 106 callers
Function
GetFileDevInode
core/common/DevInode.cpp:45
↓ 105 callers
Method
GetTimestamp
()
pkg/models/pipeline.go:26
↓ 105 callers
Method
Marshal
()
pkg/protocol/sls_logs.pb.go:472
↓ 102 callers
Function
Infof
(ctx context.Context, format string, params ...interface{})
pkg/logger/logger.go:179
↓ 101 callers
Method
handleAddOrUpdateEvent
(event *K8sMetaEvent)
pkg/helper/k8smeta/k8s_meta_deferred_deletion_meta_store.go:212
↓ 99 callers
Method
SetTagNoCopy
core/models/SpanEvent.cpp:64
↓ 98 callers
Method
Close
()
pkg/pipeline/pipeline_collector.go:36
↓ 98 callers
Method
Println
(v ...interface{})
plugins/input/mqtt/input_mqtt.go:64
↓ 97 callers
Function
Error
(ctx context.Context, alarmType selfmonitor.TypedAlarmType, kvPairs ...interface{})
pkg/logger/logger.go:227
↓ 91 callers
Method
Close
Close the event log. It should not be re-opened after closing.
plugins/input/input_wineventlog/eventlog/eventlog.go:54
↓ 91 callers
Function
Debugf
(ctx context.Context, format string, params ...interface{})
pkg/logger/logger.go:158
↓ 91 callers
Function
StringTo
core/common/StringTools.h:310
↓ 90 callers
Method
RemoveLastIncompleteLog
Rollback from the end to ensure that the logs before are complete. Here are expected behaviours of this function: 1. The logs remained must be
core/file_server/reader/LogFileReader.cpp:2017
↓ 88 callers
Method
GetContext
()
plugins/input/telegraf/telegraf_manager.go:337
↓ 88 callers
Method
SendAlarmWarning
core/monitor/AlarmManager.h:144
↓ 86 callers
Method
AddLogEvent
core/models/PipelineEventGroup.cpp:187
↓ 84 callers
Method
SetValue
core/models/MetricValue.cpp:35
↓ 83 callers
Method
LogKey
core/ebpf/type/table/DataTable.h:35
↓ 82 callers
Method
Push
core/common/SafeQueue.h:29
↓ 82 callers
Method
Run
()
pluginmanager/plugin_runner.go:55
↓ 80 callers
Method
GetProject
()
pkg/pipeline/context.go:29
↓ 80 callers
Method
SetName
(string)
pkg/models/pipeline.go:20
↓ 79 callers
Method
Clear
core/unittest/queue/FeedbackInterfaceMock.h:32
next →
1–100 of 13,853, ranked by callers