MCPcopy Create free account

hub / github.com/alibaba/loongcollector / functions

Functions13,853 in github.com/alibaba/loongcollector

⨍ Functions 13,853◇ Types & classes 2,558
↓ 12 callersMethodSendEvents
core/ebpf/plugin/file_security/FileSecurityManager.cpp:117
↓ 12 callersMethodSetCurrentLimit
core/collection_pipeline/limiter/ConcurrencyLimiter.cpp:29
↓ 12 callersMethodSetEventGroupMetaAndTag
core/file_server/reader/LogFileReader.cpp:2465
↓ 12 callersMethodSetScopeTag
core/models/SpanEvent.cpp:350
↓ 12 callersMethodSetSpanID
(spanID string)
pkg/models/logs.go:124
↓ 12 callersMethodSetStatus
core/models/SpanEvent.h:194
↓ 12 callersMethodSetTime
core/host_monitor/HostMonitorContext.h:79
↓ 12 callersMethodSetTraceID
(traceID string)
pkg/models/logs.go:137
↓ 12 callersMethodShouldSample
core/ebpf/util/sampler/Sampler.cpp:51
↓ 12 callersFunctionXXH32_round
! * @internal * @brief Normal stripe processing routine. * * This shuffles the bits so that any bit from @p input impacts several bits in * @p ac
core/common/xxhash/xxhash.h:2190
↓ 12 callersFunctionencodeVarintPipelineEventGroup
(dAtA []byte, offset int, v uint64)
pkg/protocol/pipeline_event_group.pb.go:559
↓ 12 callersMethodgetIndexKeyDiff
getIndexKeyDiff returns keys to remove and keys to add for incremental index update
pkg/helper/k8smeta/k8s_meta_deferred_deletion_meta_store.go:354
↓ 12 callersFunctionglobalLogger
()
external/github.com/elastic/beats/v7/libbeat/logp/core.go:206
↓ 12 callersFunctionmapDNSQueryType
(qtype string)
plugins/input/input_etw/dns_enrichment.go:31
↓ 12 callersFunctionnewInput
(enableGRPC, enableHTTP bool, grpcEndpoint, httpEndpoint string, ops ...op)
plugins/input/opentelemetry/service_otlp_test.go:79
↓ 12 callersFunctionnewKeyValueSplitter
()
plugins/processor/split/keyvalue/key_value_splitter.go:194
↓ 11 callersMethodAddLink
core/models/SpanEvent.cpp:332
↓ 11 callersFunctionCreateTestTracker
core/unittest/ebpf/NetworkObserverManagerUnittest.cpp:173
↓ 11 callersMethodDataAdd
core/ebpf/plugin/ProcessDataMap.cpp:33
↓ 11 callersMethodDelContent
core/models/LogEvent.cpp:97
↓ 11 callersMethodDisablePop
core/collection_pipeline/queue/ProcessQueueManager.cpp:272
↓ 11 callersMethodExecute
core/host_monitor/HostMonitorTimerEvent.cpp:31
↓ 11 callersMethodExport
Export data to destination, such as gRPC, console, file, etc. It is expected to return no error at most time because IsReady will be called before it
pkg/pipeline/flusher.go:73
↓ 11 callersMethodFeedbackContinuousPipelineConfigStatus
core/config/feedbacker/ConfigFeedbackReceiver.cpp:53
↓ 11 callersFunctionFindCRLF
Helper function: Find CRLF (\r\n) in buffer
core/ebpf/protocol/redis/RedisParser.cpp:89
↓ 11 callersFunctionGenerateTraceID
core/ebpf/util/TraceId.cpp:53
↓ 11 callersMethodGetAlarm
()
pkg/helper/input_manager_helper.go:94
↓ 11 callersMethodGetCnt
core/collection_pipeline/batch/BatchStatus.h:45
↓ 11 callersMethodGetCompressType
core/plugin/flusher/sls/FlusherSLS.h:78
↓ 11 callersMethodGetFileReaderConfig
获取给定名称的文件读取器配置
core/file_server/FileServer.cpp:162
↓ 11 callersMethodGetId
core/prometheus/component/StreamScraper.cpp:160
↓ 11 callersMethodGetInstance
core/unittest/pipeline/HttpSinkMock.h:33
↓ 11 callersMethodGetInstanceID
()
pkg/helper/platformmeta/interface.go:39
↓ 11 callersMethodGetLastWriteTime
core/common/FileSystemUtil.cpp:779
↓ 11 callersMethodGetMultilineConfig
获取给定名称的多行配置
core/file_server/FileServer.cpp:186
↓ 11 callersFunctionGetOptionalMapParam
core/common/ParamExtractor.h:261
↓ 11 callersMethodGetPriority
core/collection_pipeline/queue/ProcessQueueInterface.h:39
↓ 11 callersMethodGetSendRequestConcurrency
单地域并发度
core/app_config/AppConfig.h:461
↓ 11 callersMethodGetSourceBuffer
core/ebpf/plugin/ProcessCacheValue.h:113
↓ 11 callersFunctionGetTestConfig
(configName string)
pluginmanager/plugin_manager_test.go:91
↓ 11 callersMethodHandle
core/unittest/controller/EventDispatcherDirUnittest.cpp:55
↓ 11 callersMethodHasCol
core/ebpf/type/table/DataTable.h:67
↓ 11 callersMethodInfo
Info uses fmt.Sprint to construct and log a message.
external/github.com/elastic/beats/v7/libbeat/logp/logger.go:69
↓ 11 callersFunctionInitGoSNMP
(ctx *pluginmanager.ContextImp, input *Agent)
plugins/input/snmp/input_snmp_test.go:157
↓ 11 callersMethodIsMetaAttachReadyForAppRecord
core/ebpf/plugin/network_observer/Connection.h:89
↓ 11 callersMethodIsRegFile
core/common/FileSystemUtil.cpp:681
↓ 11 callersMethodIsValidGoPlugin
core/collection_pipeline/plugin/PluginRegistry.cpp:131
↓ 11 callersMethodNowMs
core/common/TimeKeeper.h:51
↓ 11 callersMethodRecord
(event *models.PipelineGroupEvents, ctx pipeline.PipelineContext)
plugins/aggregator/metadatagroup/aggregator_metadata_group.go:204
↓ 11 callersMethodRegisterCallback
core/app_config/AppConfig.cpp:1823
↓ 11 callersMethodRemove
core/unittest/forward/MockServiceImpl.h:28
↓ 11 callersMethodSetContainerInfo
core/file_server/FileDiscoveryOptions.h:73
↓ 11 callersMethodSetTimeoutSecs
core/collection_pipeline/batch/FlushStrategy.h:44
↓ 11 callersFunctionSplitString
core/common/StringTools.cpp:118
↓ 11 callersFunctionStopAllPipelines
StopAllPipelines stops all pipelines so that it is ready to quit. For user-defined config, timeoutStop is used to avoid hanging.
pluginmanager/plugin_manager.go:125
↓ 11 callersMethodToByteStreamWithSelectedFields
(logGroup *protocol.LogGroup, targetFields []string)
pkg/protocol/converter/converter.go:184
↓ 11 callersFunctionTrim
trim from both ends (returns a new string_view)
core/common/StringTools.h:185
↓ 11 callersMethodUpdateFilePtr
core/file_server/reader/LogFileReader.cpp:1087
↓ 11 callersMethodWrite
Write appends the contents of p to the buffer, growing the buffer as needed. The return value is the length of p; err is always nil.
external/github.com/elastic/beats/v7/winlogbeat/sys/buffer.go:34
↓ 11 callersFunctionexcludeFlag
()
pkg/logger/option_test.go:27
↓ 11 callersFunctiongetPluginMeta
core/unittest/processor/ProcessorTimestampFilterNativeUnittest.cpp:55
↓ 11 callersFunctioninitNormalLogger
initNormalLogger extracted from Init method for unit test.
pkg/logger/logger.go:120
↓ 11 callersFunctionisPathExists
(p string)
plugins/input/telegraf/telegraf_manager_test.go:74
↓ 11 callersFunctionnewProcessor
(format string, utcOffset int, enablePreciseTimestamp bool)
plugins/processor/strptime/strptime_test.go:33
↓ 11 callersFunctionpanicRecover
(pluginType string)
pluginmanager/plugin_manager.go:69
↓ 11 callersMethodprocessLog
(log *protocol.Log)
plugins/processor/gotime/processor_gotime.go:119
↓ 11 callersFunctionswap_relaxed
core/common/queue/concurrentqueue.h:510
↓ 10 callersMethodAcquireMetricEvent
core/models/EventPool.cpp:52
↓ 10 callersMethodAcquireRawEvent
core/models/EventPool.cpp:70
↓ 10 callersMethodAcquireSpanEvent
core/models/EventPool.cpp:61
↓ 10 callersMethodCreateCheckpoint
core/file_server/checkpoint/InputStaticFileCheckpointManager.cpp:42
↓ 10 callersMethodCreateLogFileReaderPtr
core/file_server/event_handler/EventHandler.cpp:352
↓ 10 callersMethodCreateMetricsRecordRef
core/collection_pipeline/plugin/interface/Plugin.h:39
↓ 10 callersMethodDebug
Sprint Debug uses fmt.Sprint to construct and log a message.
external/github.com/elastic/beats/v7/libbeat/logp/logger.go:64
↓ 10 callersMethodEmpty
core/collection_pipeline/queue/QueueInterface.h:52
↓ 10 callersMethodEncodeBatchV2
([]*models.PipelineGroupEvents)
pkg/pipeline/extensions/encoder.go:47
↓ 10 callersMethodEventSize
core/collection_pipeline/batch/BatchItem.h:62
↓ 10 callersMethodFlushQueue
key != 0: event level queue key = 0: group level queue
core/collection_pipeline/batch/Batcher.h:232
↓ 10 callersMethodForEach
core/ebpf/util/AggregateTree.h:135
↓ 10 callersMethodFull
core/collection_pipeline/queue/BoundedQueueInterface.h:41
↓ 10 callersFunctionGetCapabilities
core/common/ProcParser.cpp:122
↓ 10 callersMethodGetContainerDiscoveryOptions
core/file_server/FileDiscoveryOptions.h:71
↓ 10 callersMethodGetEcsInstanceID
core/common/MachineInfoUtil.h:75
↓ 10 callersFunctionGetEnv
core/common/EnvUtil.cpp:37
↓ 10 callersMethodGetHighWatermark
core/collection_pipeline/queue/QueueParam.h:36
↓ 10 callersMethodGetInputIndex
core/file_server/checkpoint/InputStaticFileCheckpoint.h:56
↓ 10 callersMethodGetLowWatermark
core/collection_pipeline/queue/QueueParam.h:37
↓ 10 callersFunctionGetMetaManagerInstance
()
pkg/helper/k8smeta/k8s_meta_manager.go:69
↓ 10 callersMethodGetMode
GetMode returns st_mode.
core/common/FileSystemUtil.h:289
↓ 10 callersMethodGetPipelineScopeConfig
()
pkg/pipeline/context.go:32
↓ 10 callersMethodGetTime
()
plugins/input/skywalkingv2/skywalking/apm/network/language/agent/JVM.pb.go:440
↓ 10 callersMethodGetTimeoutSecs
core/collection_pipeline/batch/FlushStrategy.h:48
↓ 10 callersFunctionGuessRegionByEndpoint
GuessRegionByEndpoint guess region cn-hangzhou.log.aliyuncs.com cn-hangzhou-intranet.log.aliyuncs.com cn-hangzhou-vpc.log.aliyuncs.com cn-hangzhou-sha
pkg/util/util.go:325
↓ 10 callersMethodInit
(ctx pipeline.Context)
plugins/flusher/opentelemetry/flusher_otlp.go:63
↓ 10 callersMethodInit
(context pipeline.Context)
plugins/input/input_etw/etw.go:124
↓ 10 callersFunctionInitFromEnvInt
(key string, value *int, defaultValue int)
pkg/util/util.go:281
↓ 10 callersMethodInitInner
InitInner initializes instance for other aggregators.
plugins/aggregator/baseagg/aggregator_base.go:184
↓ 10 callersMethodInitMetricRecord
(pluginMeta *pipeline.PluginMeta)
pluginmanager/plugin_wrapper.go:40
↓ 10 callersMethodIsEmpty
core/container_manager/ContainerDiff.h:41
↓ 10 callersMethodIsEmpty
core/collection_pipeline/batch/BatchItem.h:66
← previousnext →601–700 of 13,853, ranked by callers