MCPcopy Create free account

hub / github.com/alibaba/loongcollector / functions

Functions13,853 in github.com/alibaba/loongcollector

↓ 5 callersMethodFlushAll
core/unittest/plugin/PluginMock.h:238
↓ 5 callersMethodFlushTimeoutBatch
core/collection_pipeline/batch/TimeoutFlushManager.cpp:33
↓ 5 callersFunctionFormatTopic
FormatTopic return topic dynamically by using a format string
pkg/fmtstr/format_topic.go:18
↓ 5 callersFunctionGenerateExecId
core/common/ProcParser.cpp:152
↓ 5 callersFunctionGenerateMetrics
(count int)
plugins/input/opentelemetry/service_otlp_test.go:442
↓ 5 callersFunctionGenerateRandomStr
core/unittest/sender/SenderUnittest.cpp:191
↓ 5 callersFunctionGetAgentLogDir
core/app_config/AppConfig.cpp:243
↓ 5 callersMethodGetAgentSightSymbols
core/ebpf/EBPFAdapter.h:87
↓ 5 callersMethodGetApplicationId
()
plugins/input/skywalkingv2/skywalking/apm/network/language/agent/DiscoveryService.pb.go:562
↓ 5 callersMethodGetAvailableSenderQueueItems
core/collection_pipeline/queue/ExactlyOnceQueueManager.cpp:182
↓ 5 callersMethodGetBufferFileName
core/plugin/flusher/sls/DiskBufferWriter.cpp:283
↓ 5 callersMethodGetCacheSize
core/host_monitor/SystemInterface.cpp:533
↓ 5 callersMethodGetCheckPointObject
(key string, obj interface{})
pkg/pipeline/context.go:41
↓ 5 callersFunctionGetCheckpointFileName
core/file_server/checkpoint/InputStaticFileCheckpointManager.cpp:28
↓ 5 callersFunctionGetDateString
core/plugin/flusher/sls/SLSUtil.cpp:213
↓ 5 callersMethodGetDefaultKeyVersion
core/common/FileEncryption.h:36
↓ 5 callersMethodGetEcsVpcID
core/common/MachineInfoUtil.h:79
↓ 5 callersMethodGetEcsVswitchID
core/common/MachineInfoUtil.h:80
↓ 5 callersMethodGetEcsZoneID
core/common/MachineInfoUtil.h:78
↓ 5 callersMethodGetEventCount
()
pkg/models/pipeline.go:61
↓ 5 callersMethodGetExactlyOnceConcurrency
获取给定名称的“ExactlyOnce”并发级别
core/file_server/FileServer.cpp:274
↓ 5 callersFunctionGetHostName
core/common/MachineInfoUtil.cpp:192
↓ 5 callersMethodGetInstanceId
core/application/Application.h:47
↓ 5 callersFunctionGetJmxFetchManager
(agentDirPath string)
plugins/input/jmxfetch/manager.go:47
↓ 5 callersMethodGetLatencyMs
core/ebpf/type/NetworkObserverEvent.h:59
↓ 5 callersMethodGetMaxSizeBytes
core/collection_pipeline/batch/FlushStrategy.h:45
↓ 5 callersMethodGetMinCnt
core/collection_pipeline/batch/FlushStrategy.h:47
↓ 5 callersFunctionGetMonitorFilePath
For system monitoring (/proc). Auto-detects: "" on host, "/logtail_host" in container
pkg/helper/containercenter/mount_others.go:31
↓ 5 callersFunctionGetOSState
GetOSState returns the FileStateOS for non windows systems
pkg/helper/file_helper_linux.go:34
↓ 5 callersFunctionGetPooledByteBuf
()
pkg/protocol/converter/converter.go:210
↓ 5 callersMethodGetProcessInformation
core/host_monitor/SystemInterface.cpp:94
↓ 5 callersMethodGetProcessListInformation
core/host_monitor/SystemInterface.cpp:82
↓ 5 callersMethodGetScrapeIntervalSeconds
core/prometheus/schedulers/ScrapeScheduler.cpp:118
↓ 5 callersFunctionGetShortID
(fullID string)
pkg/helper/containercenter/container_config.go:180
↓ 5 callersFunctionGetStringFromList
(list []string)
pkg/helper/containercenter/container_config.go:187
↓ 5 callersMethodGetTopic
()
pkg/protocol/sls_logs.pb.go:257
↓ 5 callersFunctionHashString
core/common/HashUtil.cpp:374
↓ 5 callersMethodInit
(context pipeline.Context, que pipeline.LogGroupQueue)
plugins/aggregator/metadatagroup/aggregator_metadata_group.go:181
↓ 5 callersMethodInit
Init called for init some system resources, like socket, mutex...
plugins/processor/anchor/anchor.go:74
↓ 5 callersMethodInit
(context pipeline.Context)
plugins/flusher/prometheus/flusher_prometheus.go:46
↓ 5 callersMethodInit
(context pipeline.Context)
plugins/flusher/doris/flusher_doris.go:140
↓ 5 callersMethodInvalidateCurrentFileCheckpoint
core/file_server/checkpoint/InputStaticFileCheckpoint.cpp:122
↓ 5 callersMethodIsComplete
core/file_server/checkpoint/RangeCheckpoint.h:46
↓ 5 callersMethodIsDirRegistered
core/file_server/EventDispatcher.cpp:888
↓ 5 callersMethodIsFlushingThroughGoPipeline
core/collection_pipeline/CollectionPipeline.h:73
↓ 5 callersMethodIsMatch
IsMatch ...
pkg/helper/containercenter/container_center.go:208
↓ 5 callersMethodIsMoveTo
core/file_server/event/Event.h:144
↓ 5 callersMethodIsSingleValue
()
pkg/models/metrics.go:63
↓ 5 callersMethodIsValidNativeProcessorPlugin
core/collection_pipeline/plugin/PluginRegistry.cpp:150
↓ 5 callersMethodLabels
(values *helper.MetricLabels)
plugins/input/process/input_process_cache.go:30
↓ 5 callersMethodListPodSandbox
(ctx context.Context)
pkg/helper/containercenter/cri_runtime_api_interface.go:155
↓ 5 callersMethodLoadContainerInfo
core/container_manager/ContainerManager.cpp:884
↓ 5 callersFunctionLoadSingleValueEnvConfig
core/app_config/AppConfig.cpp:822
↓ 5 callersMethodMarkSample
core/ebpf/plugin/network_observer/HttpRetryableEvent.h:43
↓ 5 callersMethodMessage
Message returns the raw event description without doing any substitutions (e.g. the message will contain %1, %2, etc. as parameter placeholders).
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/publisher_metadata.go:652
↓ 5 callersMethodMessageID
()
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/publisher_metadata.go:642
↓ 5 callersFunctionMinInt
(a, b int)
pkg/util/util.go:386
↓ 5 callersMethodName
Name of subscriber
test/engine/setup/subscriber/subscriber.go:43
↓ 5 callersMethodName
Name returns the event log's name.
plugins/input/input_wineventlog/eventlog/eventlog.go:57
↓ 5 callersMethodNamed
Named adds a new path segment to the logger's name. Segments are joined by periods.
external/github.com/elastic/beats/v7/libbeat/logp/logger.go:57
↓ 5 callersFunctionNetworkCodeToState
core/prometheus/Utils.cpp:155
↓ 5 callersFunctionNewCumulativeCounterMetricVector
Deprecated: use NewCounterMetricVector instead. NewCumulativeCounterMetricVector creates a new CounterMetricVector. Note that MetricVector doesn't exp
pkg/selfmonitor/metrics_vector_imp.go:52
↓ 5 callersFunctionNewStringMetricVector
NewStringMetricVector creates a new StringMetricVector. Note that MetricVector doesn't expose Collect API by default. Plugins Developers should be car
pkg/selfmonitor/metrics_vector_imp.go:82
↓ 5 callersMethodNext
Next advances the iterator to the next handle. After Next returns false, the Err() method will return any error that occurred during iteration, except
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/iterator.go:117
↓ 5 callersMethodOnMetricResult
core/prometheus/schedulers/ScrapeScheduler.cpp:66
↓ 5 callersMethodOnSendDone
core/collection_pipeline/limiter/ConcurrencyLimiter.cpp:85
↓ 5 callersMethodOnSubscription
core/prometheus/schedulers/TargetSubscriberScheduler.cpp:67
↓ 5 callersMethodParse
()
external/github.com/jeromer/syslogparser/syslogparser.go:34
↓ 5 callersMethodPodSandboxStatus
(ctx context.Context, sandboxID string, verbose bool)
pkg/helper/containercenter/cri_runtime_api_interface.go:156
↓ 5 callersMethodPollPerfBuffer
core/ebpf/driver/BPFWrapper.h:350
↓ 5 callersMethodPopEventQueue
core/file_server/event_handler/LogInput.cpp:516
↓ 5 callersMethodProcessLog
(log *protocol.Log)
plugins/processor/anchor/anchor.go:112
↓ 5 callersMethodProcessV1
(logCtx *pipeline.LogWithContext)
pluginmanager/processor_tag.go:50
↓ 5 callersMethodProcessV2
(in *models.PipelineGroupEvents)
pluginmanager/processor_tag.go:86
↓ 5 callersMethodPushToQueue
core/plugin/flusher/sls/FlusherSLS.cpp:1161
↓ 5 callersMethodReadProcNetTcp
Parse TCP state from /proc/net/tcp and /proc/net/tcp6 as a fallback when INET_DIAG is not available
core/host_monitor/LinuxSystemInterface.cpp:144
↓ 5 callersFunctionReadWriteBarrier
core/common/MemoryBarrier.h:48
↓ 5 callersMethodReadyToDestroy
core/ebpf/plugin/network_observer/Connection.h:72
↓ 5 callersMethodRecordFileEvent
core/ebpf/plugin/file_security/FileSecurityManager.cpp:70
↓ 5 callersMethodRecv
()
plugins/input/skywalkingv3/skywalking/network/logging/v3/Logging_grpc.pb.go:107
↓ 5 callersMethodRegisterContinuousInputCreator
core/collection_pipeline/plugin/PluginRegistry.cpp:249
↓ 5 callersMethodRegisterExternalEpollFd
Bridges libagentsight's event fd into the same unified epoll as security/network perf fds (EPOLLIN path dispatches in handleEpollEvents for AGENTSIGHT
core/ebpf/EBPFServer.cpp:797
↓ 5 callersMethodRegisterHandlers
this functions should only be called when register base dir
core/file_server/ConfigManager.cpp:239
↓ 5 callersMethodRemoveHandler
core/file_server/ConfigManager.cpp:228
↓ 5 callersMethodRemoveKey
core/collection_pipeline/queue/QueueKeyManager.cpp:38
↓ 5 callersMethodRoute
core/collection_pipeline/route/Router.cpp:50
↓ 5 callersMethodRun
Run function as a Task
pkg/pipeline/control.go:42
↓ 5 callersMethodSaveCheckPointObject
(key string, obj interface{})
pkg/pipeline/context.go:40
↓ 5 callersMethodSaveContainerInfo
core/container_manager/ContainerManager.cpp:864
↓ 5 callersMethodScheduleNext
core/prometheus/schedulers/ScrapeScheduler.cpp:126
↓ 5 callersMethodSendAndClose
(*common.Commands)
plugins/input/skywalkingv2/skywalking/apm/network/language/agent/v2/trace_grpc.pb.go:101
↓ 5 callersFunctionSerializeSpanAttributesToString
core/collection_pipeline/serializer/SLSSerializer.cpp:131
↓ 5 callersMethodSetDefaultKey
core/common/FileEncryption.cpp:84
↓ 5 callersMethodSetExpectedFileSize
core/file_server/reader/LogFileReader.h:281
↓ 5 callersMethodSetFullContainerList
core/file_server/FileDiscoveryOptions.h:68
↓ 5 callersMethodSetHasNativeProcessorsFlag
core/collection_pipeline/CollectionPipelineContext.h:78
↓ 5 callersMethodSetInstanceID
core/common/EcsMetaData.h:63
↓ 5 callersMethodSetMetrics
core/ebpf/plugin/agentsight/AgentsightManager.h:76
↓ 5 callersMethodSetPeriod
core/ebpf/util/FrequencyManager.h:30
↓ 5 callersMethodSetRegionID
core/common/EcsMetaData.h:67
← previousnext →1,201–1,300 of 13,853, ranked by callers