MCPcopy Create free account

hub / github.com/alibaba/loongcollector / functions

Functions13,853 in github.com/alibaba/loongcollector

↓ 9 callersMethodprocessLog
(log *protocol.Log)
plugins/processor/appender/processor_appender.go:76
↓ 9 callersMethodregisterHandler
(parser parameterParser, handler urlHandler)
plugins/input/skywalkingv3/input_skywalking_agent_v3_http.go:223
↓ 9 callersFunctionsetAttributes
(attributes pcommon.Map, tags T)
pkg/protocol/converter/otlp.go:486
↓ 9 callersFunctionsovLogEvent
(x uint64)
pkg/protocol/log_event.pb.go:333
↓ 9 callersMethodtryChangeRunningStatus
(err error)
plugins/input/process/input_process_cache_other.go:249
↓ 9 callersMethodtry_enqueue
Enqueues a single item (by copying it). Does not allocate memory. Fails if not enough room to enqueue (or implicit production is disabled because Trai
core/common/queue/concurrentqueue.h:1060
↓ 9 callersMethodvalues
()
pkg/models/common.go:103
↓ 8 callersMethodAcceptNetStatsEvent
core/ebpf/plugin/network_observer/ConnectionManager.cpp:89
↓ 8 callersMethodAddCounter
core/prometheus/PromSelfMonitor.cpp:20
↓ 8 callersMethodAddDoneCallback
core/prometheus/async/PromFuture.cpp:25
↓ 8 callersMethodAddLabels
core/monitor/metric_models/MetricRecord.cpp:75
↓ 8 callersFunctionCalculateRandomUUID
core/common/UUIDUtil.cpp:27
↓ 8 callersMethodCheck
core/collection_pipeline/route/Condition.cpp:55
↓ 8 callersFunctionCopyCStr
core/ebpf/plugin/agentsight/AgentsightEvents.cpp:25
↓ 8 callersMethodCreateFlusher
core/collection_pipeline/plugin/PluginRegistry.cpp:125
↓ 8 callersMethodCreateInfoDetail
CreateInfoDetail create DockerInfoDetail with docker.Container Container property used in this function : HostsPath, Config.Hostname, Name, Config.Ima
pkg/helper/containercenter/container_center.go:710
↓ 8 callersFunctionCreateK8SFilter
CreateK8SFilter ...
pkg/helper/containercenter/container_center.go:91
↓ 8 callersFunctionDataSize
core/models/MetricValue.cpp:79
↓ 8 callersFunctionDoGC
core/models/EventPool.cpp:152
↓ 8 callersMethodEnabled
Enabled returns true if given level is enabled.
external/github.com/elastic/beats/v7/libbeat/logp/level.go:67
↓ 8 callersFunctionEvtGetPublisherMetadataProperty
(publisherMetadataHandle EvtHandle, propertyID EvtPublisherMetadataPropertyID)
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/syscall_windows.go:510
↓ 8 callersMethodFromJson
core/models/RawEvent.cpp:63
↓ 8 callersMethodGauge
core/monitor/metric_models/MetricTypes.h:62
↓ 8 callersFunctionGenerateSpanID
core/ebpf/util/TraceId.cpp:59
↓ 8 callersFunctionGetAgentConfDir
core/app_config/AppConfig.cpp:361
↓ 8 callersMethodGetAndReset
core/ebpf/util/AggregateTree.h:85
↓ 8 callersMethodGetContainerID
core/file_server/reader/LogFileReader.h:301
↓ 8 callersMethodGetCurrentFileFingerprint
core/file_server/checkpoint/InputStaticFileCheckpoint.cpp:147
↓ 8 callersFunctionGetCurrentLogtailTime
core/common/TimeUtil.cpp:337
↓ 8 callersFunctionGetEnvTags
(firstKey, secondKey string)
pkg/util/util.go:315
↓ 8 callersMethodGetEventPool
core/models/PipelineEventPtr.h:85
↓ 8 callersMethodGetExpireTimeIfOneTime
core/config/PipelineConfig.cpp:83
↓ 8 callersMethodGetGauge
core/monitor/metric_models/SelfMonitorMetricEvent.cpp:201
↓ 8 callersFunctionGetHostIp
core/common/MachineInfoUtil.cpp:341
↓ 8 callersMethodGetIdxInReaderArrayFromLastCpt
core/file_server/reader/LogFileReader.h:261
↓ 8 callersMethodGetKernelEventType
core/ebpf/type/CommonDataEvent.h:51
↓ 8 callersMethodGetLogGroupList
()
pkg/protocol/sls_logs.pb.go:418
↓ 8 callersMethodGetMinSizeBytes
core/collection_pipeline/batch/FlushStrategy.h:46
↓ 8 callersMethodGetNodesWithAggDepth
core/ebpf/util/AggregateTree.h:129
↓ 8 callersFunctionGetOptionalIntParam
core/common/ParamExtractor.cpp:59
↓ 8 callersMethodGetPluginType
core/ebpf/type/FileEvent.h:22
↓ 8 callersMethodGetProcessQueueType
core/unittest/plugin/PluginMock.h:84
↓ 8 callersMethodGetState
core/common/Thread.h:46
↓ 8 callersMethodHostname
(hostname string)
external/github.com/jeromer/syslogparser/rfc3164/rfc3164.go:55
↓ 8 callersMethodIsDeleted
core/file_server/event/Event.h:146
↓ 8 callersMethodIsError
core/ebpf/type/NetworkObserverEvent.h:92
↓ 8 callersMethodIsHostPathMatchBlacklist
core/app_config/AppConfig.cpp:1718
↓ 8 callersMethodIsInitialized
core/unittest/flusher/MockKafkaProducer.h:119
↓ 8 callersMethodIsLogParseAlarmValid
core/app_config/AppConfig.h:408
↓ 8 callersFunctionIsNumber
core/prometheus/Utils.cpp:128
↓ 8 callersMethodIsPurageContainerMode
core/app_config/AppConfig.h:511
↓ 8 callersMethodIsReaderFlushTimeout
core/file_server/event/Event.h:150
↓ 8 callersMethodIsValid
core/unittest/common/timer/TimerUnittest.cpp:27
↓ 8 callersMethodLoadDynLib
LoadDynLib loads dynamic library named @libName from current working dir. For linux, the so name is 'lib+@libName.so'. For Windows, the dll name is '@
core/common/DynamicLibHelper.cpp:67
↓ 8 callersMethodMakeRangeKey
core/file_server/checkpoint/CheckpointManagerV2.cpp:89
↓ 8 callersMethodMarkProcessEventFlushStatus
core/ebpf/plugin/ProcessCacheManager.h:68
↓ 8 callersMethodNeedFlushByCnt
core/collection_pipeline/batch/FlushStrategy.h:52
↓ 8 callersFunctionNewPromEncoder
(seriesLimit int)
pkg/protocol/encoder/prometheus/encoder_prometheus.go:35
↓ 8 callersFunctionParseECSMeta
core/common/EcsMetaData.cpp:49
↓ 8 callersMethodParseLogTime
core/plugin/processor/ProcessorParseTimestampNative.cpp:181
↓ 8 callersMethodPing
()
pkg/helper/platformmeta/interface.go:50
↓ 8 callersMethodProcess
Process the file block and return how many bytes are processed LogFileReader will find last '\n' and call Process @note fileBlock may be nil, in this
pkg/helper/log_file_processor.go:24
↓ 8 callersMethodPushEventQueue
core/file_server/event_handler/LogInput.cpp:467
↓ 8 callersMethodPushSenderQueue
core/collection_pipeline/queue/ExactlyOnceQueueManager.cpp:170
↓ 8 callersMethodRecordActive
core/ebpf/plugin/network_observer/Connection.h:136
↓ 8 callersMethodSetDownStreamQueues
core/collection_pipeline/queue/ProcessQueueManager.cpp:245
↓ 8 callersMethodSetEnableContainerDiscoveryFlag
core/file_server/FileDiscoveryOptions.h:64
↓ 8 callersMethodSetInSendingCount
core/collection_pipeline/limiter/ConcurrencyLimiter.cpp:34
↓ 8 callersMethodSetMinCnt
core/collection_pipeline/batch/FlushStrategy.h:43
↓ 8 callersMethodSetNext
core/monitor/metric_models/MetricRecord.cpp:151
↓ 8 callersMethodSetObservedTimestamp
(uint64)
pkg/models/pipeline.go:30
↓ 8 callersMethodSetOffset
(offset uint64)
pkg/models/logs.go:85
↓ 8 callersMethodSetUpStreamFeedbacks
core/collection_pipeline/queue/BoundedProcessQueue.cpp:78
↓ 8 callersMethodShouldDelete
core/monitor/metric_models/SelfMonitorMetricEvent.cpp:158
↓ 8 callersMethodSize
()
pkg/protocol/pipeline_event_group.pb.go:72
↓ 8 callersFunctionStopAllPipelines
export StopAllPipelines
plugin_main/plugin_export.go:227
↓ 8 callersFunctionToLowerCaseString
core/common/StringTools.cpp:35
↓ 8 callersFunctionToString
core/common/StringTools.cpp:63
↓ 8 callersFunctionTraceIDToString
core/ebpf/util/TraceId.cpp:65
↓ 8 callersFunctionUTF16BytesToString
UTF16BytesToString returns a string that is decoded from the UTF-16 bytes. The byte slice must be of even length otherwise an error will be returned.
external/github.com/elastic/beats/v7/winlogbeat/sys/strings.go:92
↓ 8 callersMethodUnCompress
core/unittest/compression/CompressorUnittest.cpp:27
↓ 8 callersFunctionXXH64_mergeRound
core/common/xxhash/xxhash.h:2713
↓ 8 callersFunctionXXH_setDispatch
! * @internal * @brief Runs a CPUID check and sets the correct dispatch tables. */
core/common/xxhash/xxh_x86dispatch.c:669
↓ 8 callersMethodaddMatcher
(namespace, resourceType string, matcher *labelMatcher)
plugins/input/kubernetesmetav1/kubernetes_collect.go:147
↓ 8 callersFunctioncanParseToFloat64
(s string)
plugins/processor/logtoslsmetric/processor_log_to_sls_metric.go:357
↓ 8 callersFunctiondestroy
core/common/queue/concurrentqueue.h:3642
↓ 8 callersFunctionerrnoErr
errnoErr returns common boxed Errno values, to prevent allocations at runtime.
external/github.com/elastic/beats/v7/winlogbeat/sys/eventlogging/zsyscall_windows.go:43
↓ 8 callersFunctionfile_language_agent_JVMMetric_proto_rawDescGZIP
()
plugins/input/skywalkingv3/skywalking/network/language/agent/v3/JVMMetric.pb.go:679
↓ 8 callersFunctionfilter
Filter returns a new slice holding only the elements of s that satisfy the predicate fn().
plugins/input/input_wineventlog/eventlog/eventlogging.go:206
↓ 8 callersFunctiongenerate
(ctx context.Context, mode, path string, count, interval int, customKV ...string)
test/engine/trigger/log/file.go:70
↓ 8 callersFunctionget_random_mark
()
test/engine/trigger/log/remote_file.py:120
↓ 8 callersFunctionlookupFlag
lookupFlag returns the flag.Flag for the given name, or an error if not found
pkg/flags/flags.go:153
↓ 8 callersFunctionnewTestGrpcMetricServiceV2
(t *testing.T, address string, pause time.Duration)
plugins/flusher/opentelemetry/flusher_otlp_test.go:547
↓ 8 callersMethodpreProcessCommon
(obj interface{})
pkg/helper/k8smeta/k8s_meta_cache.go:233
↓ 8 callersMethodprocessGrok
(log *protocol.Log, val *string)
plugins/processor/grok/processor_grok.go:148
↓ 8 callersMethodrebuild
core/file_server/checkpoint/CheckpointManagerV2.cpp:502
↓ 8 callersFunctionsovMetricEvent
(x uint64)
pkg/protocol/metric_event.pb.go:379
↓ 8 callersMethodtry_dequeue_bulk
core/common/queue/concurrentqueue.h:1231
↓ 7 callersMethodAcceptDataEvent
core/ebpf/plugin/network_observer/NetworkObserverManager.cpp:1568
↓ 7 callersMethodAddEvent
core/ebpf/plugin/RetryableEventCache.cpp:35
← previousnext →801–900 of 13,853, ranked by callers