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
↓ 24 callers
Method
ColIndex
core/ebpf/type/table/DataTable.h:57
↓ 24 callers
Function
CreateStubExecveEvent
core/unittest/ebpf/EBPFRawEventStub.h:25
↓ 24 callers
Function
GetAvailableLocalAddress
GetAvailableLocalAddress finds an available local port and returns an endpoint describing it. The port is available for opening when this function ret
plugins/test/common.go:206
↓ 24 callers
Method
GetCreateTime
core/task_pipeline/TaskPipelineContext.h:41
↓ 24 callers
Method
GetDev
core/file_server/event/Event.h:97
↓ 24 callers
Method
GetFileSize
core/file_server/reader/LogFileReader.h:257
↓ 24 callers
Method
IDPrefix
()
pkg/helper/containercenter/container_center.go:281
↓ 24 callers
Method
IsMultiline
core/file_server/MultilineOptions.h:38
↓ 24 callers
Method
SetKind
core/models/SpanEvent.h:163
↓ 24 callers
Method
SpanKey
core/ebpf/type/table/DataTable.h:34
↓ 24 callers
Function
clean
()
pkg/logger/logger_test.go:50
↓ 24 callers
Method
write
core/file_server/checkpoint/CheckpointManagerV2.cpp:411
↓ 23 callers
Method
AddData
(tags map[string]string, fields map[string]string, t ...time.Time)
pkg/pipeline/collector.go:35
↓ 23 callers
Function
ConvertYamlToJson
core/common/YamlUtil.cpp:105
↓ 23 callers
Method
GetInSendingCount
core/collection_pipeline/limiter/ConcurrencyLimiter.cpp:37
↓ 23 callers
Method
GetNext
core/monitor/metric_models/MetricRecord.cpp:147
↓ 23 callers
Function
InitFromEnvString
(key string, value *string, defaultValue string)
pkg/util/util.go:300
↓ 23 callers
Function
IsDoubleEqual
core/unittest/prometheus/TextParserUnittest.cpp:28
↓ 23 callers
Method
List
()
pkg/helper/k8smeta/k8s_meta_manager.go:29
↓ 23 callers
Method
Read
Collect takes in an accumulator and adds the metrics that the Input gathers. This is called every "interval"
pkg/pipeline/input.go:38
↓ 23 callers
Method
ReadGBK
core/file_server/reader/LogFileReader.cpp:1723
↓ 23 callers
Method
Seek
core/common/LogFileOperator.cpp:49
↓ 23 callers
Method
ToArray
ToArray returns an array containing all of the PipelineGroupEvents in this collector.
pkg/pipeline/pipeline_collector.go:31
↓ 22 callers
Method
Collect
()
pkg/selfmonitor/metrics_type.go:90
↓ 22 callers
Function
ConsumeKernelProcessEvents
core/unittest/ebpf/ProcessCacheManagerUnittest.cpp:182
↓ 22 callers
Method
ExecOnSource
(ctx context.Context, command string)
test/engine/setup/env.go:27
↓ 22 callers
Method
Format
core/common/FormattedString.cpp:76
↓ 22 callers
Method
GetMultiValues
()
pkg/models/metrics.go:69
↓ 22 callers
Function
GetPreciseTimestampFromLogtailTime
DEPRECATED: only for the compability of PreciseTimestamp
core/common/TimeUtil.cpp:319
↓ 22 callers
Function
HashSignatureString
core/common/HashUtil.cpp:387
↓ 22 callers
Function
NewDockerStdoutProcessor
(beginLineReg *regexp.Regexp, beginLineTimeout time.Duration, beginLineCheckLength int, maxLogSize int, stdou
plugins/input/docker/stdout/docker_stdout_processor.go:87
↓ 22 callers
Method
Put
Put writes the given key and value to the map replacing any existing value if it exists. The previous value associated with the key returned or nil if
plugins/input/input_wineventlog/eventlog/common/cache.go:130
↓ 22 callers
Method
Replace
(key, value string)
pkg/helper/log_helper.go:144
↓ 22 callers
Method
SetContentNoCopy
core/models/RawEvent.cpp:39
↓ 22 callers
Method
SetMetadataNoCopy
core/models/MetricEvent.cpp:107
↓ 22 callers
Function
SplitRegexFromMap
SplitRegexFromMap extract regex from user config regex must begin with ^ and end with $(we only check ^)
pkg/helper/containercenter/container_export.go:176
↓ 22 callers
Method
UnloadPlugins
core/task_pipeline/TaskRegistry.cpp:31
↓ 22 callers
Function
addValue
addValue adds a key and value to the given MapStr if the value is not the zero value for the type of v. It is safe to call the function with a nil Map
plugins/input/input_wineventlog/eventlog/eventlog.go:139
↓ 22 callers
Method
decodeCSV
(log *protocol.Log, value string)
plugins/processor/csv/processor_csv.go:60
↓ 22 callers
Function
find
core/common/magic_enum.hpp:312
↓ 22 callers
Method
valid
A token is always valid unless: 1) Memory allocation failed during construction 2) It was moved via the move constructor (Note: assignment does a swap
core/common/queue/concurrentqueue.h:693
↓ 21 callers
Function
ClearMemoryLog
ClearMemoryLog clear the whole memory logs.
pkg/logger/memory_output.go:41
↓ 21 callers
Method
CreateProcessor
core/collection_pipeline/plugin/PluginRegistry.cpp:119
↓ 21 callers
Method
GetTime
()
plugins/input/skywalkingv3/skywalking/network/language/agent/v3/Tracing.pb.go:684
↓ 21 callers
Method
IsBound
core/host_monitor/SystemInformationTools.cpp:139
↓ 21 callers
Method
Load
core/common/auth/AuthConfig.cpp:25
↓ 21 callers
Function
MOODYCAMEL_CONSTEXPR_IF
core/common/queue/concurrentqueue.h:2157
↓ 21 callers
Method
NeedFlushByTime
core/collection_pipeline/batch/FlushStrategy.h:88
↓ 21 callers
Function
NewMetaNode
(id, nodeType string)
pkg/helper/meta_helper.go:54
↓ 21 callers
Method
RemoveConfig
core/unittest/ebpf/NetworkObserverConfigUpdateUnittest.cpp:199
↓ 21 callers
Method
SetExactlyOnceFlag
core/collection_pipeline/CollectionPipelineContext.h:76
↓ 21 callers
Method
SetSpanId
core/models/SpanEvent.cpp:32
↓ 21 callers
Method
SetStatusCode
core/common/http/HttpResponse.h:87
↓ 21 callers
Method
SetTraceId
core/models/SpanEvent.cpp:27
↓ 21 callers
Method
ToByteStream
(logGroup *protocol.LogGroup)
pkg/protocol/converter/converter.go:179
↓ 21 callers
Function
errnoErr
errnoErr returns common boxed Errno values, to prevent allocations at runtime.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/zsyscall_windows.go:43
↓ 21 callers
Function
generateMockNamespace
(namespaceName string)
pkg/helper/k8smeta/k8s_meta_link_test.go:1630
↓ 21 callers
Function
getContainerCenterInstance
()
pkg/helper/containercenter/container_center.go:842
↓ 21 callers
Function
getPluginMeta
core/unittest/processor/ProcessorParseJsonNativeUnittest.cpp:94
↓ 21 callers
Method
processLog
map log contents into target value
plugins/processor/dictmap/processor_dict_map.go:148
↓ 21 callers
Method
read
core/file_server/checkpoint/CheckpointManagerV2.cpp:393
↓ 20 callers
Method
EnablePop
core/collection_pipeline/queue/ProcessQueueManager.cpp:285
↓ 20 callers
Method
Err
Err returns the first non-ERROR_NO_MORE_ITEMS error encountered by the EventIterator. Some Windows versions will fail with windows.RPC_S_INVALID_BOUN
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/iterator.go:191
↓ 20 callers
Function
ExtractCurrentKey
core/common/ParamExtractor.cpp:23
↓ 20 callers
Method
IsFlushingThroughGoPipelineExisted
core/config/CollectionConfig.h:70
↓ 20 callers
Method
LoadPlugins
core/task_pipeline/TaskRegistry.cpp:24
↓ 20 callers
Function
NewMetadata
()
pkg/models/factory.go:61
↓ 20 callers
Function
NewObservePipelineContext
(queueSize int)
pkg/helper/collector_imp.go:146
↓ 20 callers
Function
OneJob
core/unittest/polling/PollingUnittest.cpp:123
↓ 20 callers
Method
Slice
Pointer returns a pointer the EvtVariant array.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/stringinserts.go:49
↓ 20 callers
Method
ToString
core/common/EcsMetaData.cpp:82
↓ 20 callers
Function
initTestLogger
initTestLogger extracted from Init method for unit test.
pkg/logger/logger.go:134
↓ 20 callers
Method
parse
(b []byte, clientIP string, collector pipeline.Collector)
plugins/input/syslog/syslog.go:394
↓ 19 callers
Method
AddSpanEvent
core/models/PipelineEventGroup.cpp:217
↓ 19 callers
Function
CalcMD5
core/common/HashUtil.cpp:325
↓ 19 callers
Method
GetContents
()
pkg/protocol/sls_logs.pb.go:76
↓ 19 callers
Method
IsDir
core/file_server/event/Event.h:135
↓ 19 callers
Function
LoadAndStartMockConfig
project, logstore, config, configJsonStr
pluginmanager/plugin_manager_test.go:101
↓ 19 callers
Method
Next
Next returns the duration to wait before next operation.
plugins/input/syslog/backoff.go:23
↓ 19 callers
Method
OnSuccess
core/collection_pipeline/limiter/ConcurrencyLimiter.cpp:89
↓ 19 callers
Method
Parse
Parse parses @data to parseResult according to the protocol of parser. If it parses failed but failField in parserConfig is set, it will set the conte
plugins/input/syslog/parser.go:59
↓ 19 callers
Method
PopItem
core/common/CircularBuffer.h:102
↓ 19 callers
Function
SendHttpRequest
core/common/http/Curl.cpp:203
↓ 19 callers
Method
SendMsg
(a interface{})
plugins/input/skywalkingv3/logging_handle_test.go:86
↓ 19 callers
Method
SetReaderArray
core/file_server/reader/LogFileReader.cpp:1404
↓ 19 callers
Method
ShouldNativeFlusherConnectedByGoPipeline
core/config/CollectionConfig.h:63
↓ 19 callers
Method
TagsBegin
core/models/SpanEvent.h:182
↓ 19 callers
Method
TagsEnd
core/models/SpanEvent.h:183
↓ 19 callers
Function
XXH_readLE32
core/common/xxhash/xxhash.h:2115
↓ 19 callers
Method
enrichDNSFields
(fields map[string]string, eventID uint16)
plugins/input/input_etw/dns_enrichment.go:93
↓ 19 callers
Function
sovSlsLogs
(x uint64)
pkg/protocol/sls_logs.pb.go:906
↓ 18 callers
Method
Add
(int64)
pkg/selfmonitor/metrics_type.go:83
↓ 18 callers
Method
Add
(key string, value float64)
pkg/models/metrics.go:99
↓ 18 callers
Method
AddSource
core/config/watcher/ConfigWatcher.cpp:21
↓ 18 callers
Method
BuildRequest
core/unittest/plugin/PluginMock.h:262
↓ 18 callers
Method
CheckAndResetProxyEnv
core/app_config/AppConfig.cpp:1209
↓ 18 callers
Method
Context
()
plugins/input/skywalkingv3/logging_handle_test.go:82
↓ 18 callers
Method
CreateQueue
core/collection_pipeline/queue/SenderQueueManager.cpp:31
↓ 18 callers
Method
CreateTimeCounter
core/monitor/metric_models/MetricRecord.cpp:48
↓ 18 callers
Function
GetConfigFlushers
(runner PluginRunner)
pluginmanager/plugin_runner_helper.go:131
← previous
next →
301–400 of 13,853, ranked by callers