MCPcopy Create free account

hub / github.com/alibaba/loongcollector / functions

Functions13,853 in github.com/alibaba/loongcollector

↓ 24 callersMethodColIndex
core/ebpf/type/table/DataTable.h:57
↓ 24 callersFunctionCreateStubExecveEvent
core/unittest/ebpf/EBPFRawEventStub.h:25
↓ 24 callersFunctionGetAvailableLocalAddress
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 callersMethodGetCreateTime
core/task_pipeline/TaskPipelineContext.h:41
↓ 24 callersMethodGetDev
core/file_server/event/Event.h:97
↓ 24 callersMethodGetFileSize
core/file_server/reader/LogFileReader.h:257
↓ 24 callersMethodIDPrefix
()
pkg/helper/containercenter/container_center.go:281
↓ 24 callersMethodIsMultiline
core/file_server/MultilineOptions.h:38
↓ 24 callersMethodSetKind
core/models/SpanEvent.h:163
↓ 24 callersMethodSpanKey
core/ebpf/type/table/DataTable.h:34
↓ 24 callersFunctionclean
()
pkg/logger/logger_test.go:50
↓ 24 callersMethodwrite
core/file_server/checkpoint/CheckpointManagerV2.cpp:411
↓ 23 callersMethodAddData
(tags map[string]string, fields map[string]string, t ...time.Time)
pkg/pipeline/collector.go:35
↓ 23 callersFunctionConvertYamlToJson
core/common/YamlUtil.cpp:105
↓ 23 callersMethodGetInSendingCount
core/collection_pipeline/limiter/ConcurrencyLimiter.cpp:37
↓ 23 callersMethodGetNext
core/monitor/metric_models/MetricRecord.cpp:147
↓ 23 callersFunctionInitFromEnvString
(key string, value *string, defaultValue string)
pkg/util/util.go:300
↓ 23 callersFunctionIsDoubleEqual
core/unittest/prometheus/TextParserUnittest.cpp:28
↓ 23 callersMethodList
()
pkg/helper/k8smeta/k8s_meta_manager.go:29
↓ 23 callersMethodRead
Collect takes in an accumulator and adds the metrics that the Input gathers. This is called every "interval"
pkg/pipeline/input.go:38
↓ 23 callersMethodReadGBK
core/file_server/reader/LogFileReader.cpp:1723
↓ 23 callersMethodSeek
core/common/LogFileOperator.cpp:49
↓ 23 callersMethodToArray
ToArray returns an array containing all of the PipelineGroupEvents in this collector.
pkg/pipeline/pipeline_collector.go:31
↓ 22 callersMethodCollect
()
pkg/selfmonitor/metrics_type.go:90
↓ 22 callersFunctionConsumeKernelProcessEvents
core/unittest/ebpf/ProcessCacheManagerUnittest.cpp:182
↓ 22 callersMethodExecOnSource
(ctx context.Context, command string)
test/engine/setup/env.go:27
↓ 22 callersMethodFormat
core/common/FormattedString.cpp:76
↓ 22 callersMethodGetMultiValues
()
pkg/models/metrics.go:69
↓ 22 callersFunctionGetPreciseTimestampFromLogtailTime
DEPRECATED: only for the compability of PreciseTimestamp
core/common/TimeUtil.cpp:319
↓ 22 callersFunctionHashSignatureString
core/common/HashUtil.cpp:387
↓ 22 callersFunctionNewDockerStdoutProcessor
(beginLineReg *regexp.Regexp, beginLineTimeout time.Duration, beginLineCheckLength int, maxLogSize int, stdou
plugins/input/docker/stdout/docker_stdout_processor.go:87
↓ 22 callersMethodPut
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 callersMethodReplace
(key, value string)
pkg/helper/log_helper.go:144
↓ 22 callersMethodSetContentNoCopy
core/models/RawEvent.cpp:39
↓ 22 callersMethodSetMetadataNoCopy
core/models/MetricEvent.cpp:107
↓ 22 callersFunctionSplitRegexFromMap
SplitRegexFromMap extract regex from user config regex must begin with ^ and end with $(we only check ^)
pkg/helper/containercenter/container_export.go:176
↓ 22 callersMethodUnloadPlugins
core/task_pipeline/TaskRegistry.cpp:31
↓ 22 callersFunctionaddValue
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 callersMethoddecodeCSV
(log *protocol.Log, value string)
plugins/processor/csv/processor_csv.go:60
↓ 22 callersFunctionfind
core/common/magic_enum.hpp:312
↓ 22 callersMethodvalid
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 callersFunctionClearMemoryLog
ClearMemoryLog clear the whole memory logs.
pkg/logger/memory_output.go:41
↓ 21 callersMethodCreateProcessor
core/collection_pipeline/plugin/PluginRegistry.cpp:119
↓ 21 callersMethodGetTime
()
plugins/input/skywalkingv3/skywalking/network/language/agent/v3/Tracing.pb.go:684
↓ 21 callersMethodIsBound
core/host_monitor/SystemInformationTools.cpp:139
↓ 21 callersMethodLoad
core/common/auth/AuthConfig.cpp:25
↓ 21 callersFunctionMOODYCAMEL_CONSTEXPR_IF
core/common/queue/concurrentqueue.h:2157
↓ 21 callersMethodNeedFlushByTime
core/collection_pipeline/batch/FlushStrategy.h:88
↓ 21 callersFunctionNewMetaNode
(id, nodeType string)
pkg/helper/meta_helper.go:54
↓ 21 callersMethodRemoveConfig
core/unittest/ebpf/NetworkObserverConfigUpdateUnittest.cpp:199
↓ 21 callersMethodSetExactlyOnceFlag
core/collection_pipeline/CollectionPipelineContext.h:76
↓ 21 callersMethodSetSpanId
core/models/SpanEvent.cpp:32
↓ 21 callersMethodSetStatusCode
core/common/http/HttpResponse.h:87
↓ 21 callersMethodSetTraceId
core/models/SpanEvent.cpp:27
↓ 21 callersMethodToByteStream
(logGroup *protocol.LogGroup)
pkg/protocol/converter/converter.go:179
↓ 21 callersFunctionerrnoErr
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 callersFunctiongenerateMockNamespace
(namespaceName string)
pkg/helper/k8smeta/k8s_meta_link_test.go:1630
↓ 21 callersFunctiongetContainerCenterInstance
()
pkg/helper/containercenter/container_center.go:842
↓ 21 callersFunctiongetPluginMeta
core/unittest/processor/ProcessorParseJsonNativeUnittest.cpp:94
↓ 21 callersMethodprocessLog
map log contents into target value
plugins/processor/dictmap/processor_dict_map.go:148
↓ 21 callersMethodread
core/file_server/checkpoint/CheckpointManagerV2.cpp:393
↓ 20 callersMethodEnablePop
core/collection_pipeline/queue/ProcessQueueManager.cpp:285
↓ 20 callersMethodErr
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 callersFunctionExtractCurrentKey
core/common/ParamExtractor.cpp:23
↓ 20 callersMethodIsFlushingThroughGoPipelineExisted
core/config/CollectionConfig.h:70
↓ 20 callersMethodLoadPlugins
core/task_pipeline/TaskRegistry.cpp:24
↓ 20 callersFunctionNewMetadata
()
pkg/models/factory.go:61
↓ 20 callersFunctionNewObservePipelineContext
(queueSize int)
pkg/helper/collector_imp.go:146
↓ 20 callersFunctionOneJob
core/unittest/polling/PollingUnittest.cpp:123
↓ 20 callersMethodSlice
Pointer returns a pointer the EvtVariant array.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/stringinserts.go:49
↓ 20 callersMethodToString
core/common/EcsMetaData.cpp:82
↓ 20 callersFunctioninitTestLogger
initTestLogger extracted from Init method for unit test.
pkg/logger/logger.go:134
↓ 20 callersMethodparse
(b []byte, clientIP string, collector pipeline.Collector)
plugins/input/syslog/syslog.go:394
↓ 19 callersMethodAddSpanEvent
core/models/PipelineEventGroup.cpp:217
↓ 19 callersFunctionCalcMD5
core/common/HashUtil.cpp:325
↓ 19 callersMethodGetContents
()
pkg/protocol/sls_logs.pb.go:76
↓ 19 callersMethodIsDir
core/file_server/event/Event.h:135
↓ 19 callersFunctionLoadAndStartMockConfig
project, logstore, config, configJsonStr
pluginmanager/plugin_manager_test.go:101
↓ 19 callersMethodNext
Next returns the duration to wait before next operation.
plugins/input/syslog/backoff.go:23
↓ 19 callersMethodOnSuccess
core/collection_pipeline/limiter/ConcurrencyLimiter.cpp:89
↓ 19 callersMethodParse
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 callersMethodPopItem
core/common/CircularBuffer.h:102
↓ 19 callersFunctionSendHttpRequest
core/common/http/Curl.cpp:203
↓ 19 callersMethodSendMsg
(a interface{})
plugins/input/skywalkingv3/logging_handle_test.go:86
↓ 19 callersMethodSetReaderArray
core/file_server/reader/LogFileReader.cpp:1404
↓ 19 callersMethodShouldNativeFlusherConnectedByGoPipeline
core/config/CollectionConfig.h:63
↓ 19 callersMethodTagsBegin
core/models/SpanEvent.h:182
↓ 19 callersMethodTagsEnd
core/models/SpanEvent.h:183
↓ 19 callersFunctionXXH_readLE32
core/common/xxhash/xxhash.h:2115
↓ 19 callersMethodenrichDNSFields
(fields map[string]string, eventID uint16)
plugins/input/input_etw/dns_enrichment.go:93
↓ 19 callersFunctionsovSlsLogs
(x uint64)
pkg/protocol/sls_logs.pb.go:906
↓ 18 callersMethodAdd
(int64)
pkg/selfmonitor/metrics_type.go:83
↓ 18 callersMethodAdd
(key string, value float64)
pkg/models/metrics.go:99
↓ 18 callersMethodAddSource
core/config/watcher/ConfigWatcher.cpp:21
↓ 18 callersMethodBuildRequest
core/unittest/plugin/PluginMock.h:262
↓ 18 callersMethodCheckAndResetProxyEnv
core/app_config/AppConfig.cpp:1209
↓ 18 callersMethodContext
()
plugins/input/skywalkingv3/logging_handle_test.go:82
↓ 18 callersMethodCreateQueue
core/collection_pipeline/queue/SenderQueueManager.cpp:31
↓ 18 callersMethodCreateTimeCounter
core/monitor/metric_models/MetricRecord.cpp:48
↓ 18 callersFunctionGetConfigFlushers
(runner PluginRunner)
pluginmanager/plugin_runner_helper.go:131
← previousnext →301–400 of 13,853, ranked by callers