MCPcopy Create free account

hub / github.com/alibaba/loongcollector / functions

Functions13,853 in github.com/alibaba/loongcollector

⨍ Functions 13,853◇ Types & classes 2,558
↓ 14 callersMethodHasFeedback
core/unittest/queue/FeedbackInterfaceMock.h:30
↓ 14 callersMethodInit
(context pipeline.Context)
plugins/flusher/http/flusher_http.go:130
↓ 14 callersMethodIsL7MetaAttachReady
core/ebpf/plugin/network_observer/Connection.h:98
↓ 14 callersMethodIsTaskCompleted
core/ebpf/plugin/RetryableEvent.h:79
↓ 14 callersFunctionNewMetric
(name string, metricType MetricType, tags Tags, timestamp int64, value MetricValue, typedValues MetricTypedVal
pkg/models/factory.go:71
↓ 14 callersFunctionNewTagsWithMap
(tags map[string]string)
pkg/models/factory.go:19
↓ 14 callersFunctionParseTagKey
if there is no tag config, config maybe nullptr, will act as default (default added or optional)
core/common/ParamExtractor.cpp:297
↓ 14 callersMethodProcessLogs
(logArray []*protocol.Log)
plugins/processor/logtoslsmetric/processor_log_to_sls_metric.go:172
↓ 14 callersFunctionReadFileContent
core/common/FileSystemUtil.cpp:131
↓ 14 callersMethodSetPB
core/file_server/checkpoint/CheckpointManagerV2.h:91
↓ 14 callersFunctionTrimString
core/common/StringTools.h:75
↓ 14 callersMethodWaitCancel
Waiting for executing task to be canceled
pkg/pipeline/control.go:51
↓ 14 callersMethodWithLabel
(k, v string)
pkg/helper/meta_helper.go:81
↓ 14 callersFunctionXXH3_avalanche
* This is a fast avalanche stage, * suitable when input bits are already partially mixed */
core/common/xxhash/xxhash.h:3749
↓ 14 callersFunctionXXH64_round
! @copydoc XXH32_round */
core/common/xxhash/xxhash.h:2706
↓ 14 callersFunctionfile_register_Register_proto_rawDescGZIP
()
plugins/input/skywalkingv2/skywalking/apm/network/language/agent/Register.pb.go:978
↓ 14 callersMethodgetConnection
core/ebpf/plugin/network_observer/ConnectionManager.cpp:46
↓ 14 callersFunctiongetContextWithTimeout
(timeout time.Duration)
pkg/helper/containercenter/cri_adapter.go:476
↓ 14 callersFunctionnewProcessor
()
plugins/processor/json/processor_json_test.go:34
↓ 14 callersFunctionpanicRecover
()
plugins/input/skywalkingv2/trace_segment_report_handle.go:49
↓ 14 callersFunctionsovPipelineEventGroup
(x uint64)
pkg/protocol/pipeline_event_group.pb.go:687
↓ 14 callersFunctionswap
core/common/queue/concurrentqueue.h:3718
↓ 13 callersMethodAddDataArray
(tags map[string]string, columns []string, values []string, t ...time.Time)
pkg/pipeline/collector.go:39
↓ 13 callersMethodAllocateStringBuffer
core/common/memory/SourceBuffer.h:159
↓ 13 callersFunctionBadRequest
(res http.ResponseWriter)
plugins/input/httpserver/input_http_server.go:225
↓ 13 callersMethodCleanup
Cleanup implements ConsumerGroupHandler
plugins/input/kafka/input_kafka.go:225
↓ 13 callersMethodCommitMetricsRecordRef
core/collection_pipeline/plugin/interface/Plugin.h:50
↓ 13 callersMethodEnable
core/metadata/K8sMetadata.cpp:63
↓ 13 callersFunctionFlush
Flush logs to the output when using async logger.
pkg/logger/logger.go:306
↓ 13 callersMethodGetExecTime
core/common/timer/TimerEvent.h:31
↓ 13 callersFunctionGetMandatoryUInt64Param
core/common/ParamExtractor.cpp:156
↓ 13 callersMethodGetMetricTime
core/host_monitor/HostMonitorContext.h:85
↓ 13 callersFunctionGetQuery
(ctx context.Context)
test/engine/control/query.go:13
↓ 13 callersMethodGetTagsHash
core/models/PipelineEventGroup.cpp:321
↓ 13 callersMethodHandleMessage
core/ebpf/plugin/FileRetryableEvent.cpp:22
↓ 13 callersMethodInit
(context pipeline.Context)
plugins/input/netping/netping.go:149
↓ 13 callersMethodInitContext
(project, logstore, configName string)
pkg/pipeline/context.go:26
↓ 13 callersFunctionInitFromEnvBool
(key string, value *bool, defaultValue bool)
pkg/util/util.go:261
↓ 13 callersMethodIsL4MetaAttachReady
core/ebpf/plugin/network_observer/Connection.h:103
↓ 13 callersMethodIsModify
core/file_server/event/Event.h:133
↓ 13 callersFunctionMax
(x T, y T)
pkg/helper/math/math_helper.go:26
↓ 13 callersMethodNeedFlushBySize
should be called after event is added
core/collection_pipeline/batch/FlushStrategy.h:51
↓ 13 callersFunctionNewParser
(buff []byte)
external/github.com/jeromer/syslogparser/rfc3164/rfc3164.go:42
↓ 13 callersMethodProcessLogs
(logArray []*protocol.Log)
plugins/processor/stringreplace/processor_string_replace.go:101
↓ 13 callersMethodPushEvent
core/common/timer/Timer.cpp:61
↓ 13 callersFunctionRegister
Register the doc description to the doc center.
pkg/doc/doc.go:26
↓ 13 callersFunctionRegisterCreator
(name string, creator Creator)
test/engine/setup/subscriber/subscriber.go:52
↓ 13 callersMethodRegisterMetricCollector
(collector MetricCollector)
pkg/selfmonitor/metrics_record.go:43
↓ 13 callersMethodSetContainerStopped
core/file_server/reader/LogFileReader.cpp:314
↓ 13 callersMethodSetLastContainerUpdateTime
core/file_server/FileDiscoveryOptions.h:113
↓ 13 callersMethodType
()
pkg/selfmonitor/metrics_type.go:74
↓ 13 callersMethodUpdateCurrentFileCheckpoint
core/file_server/checkpoint/InputStaticFileCheckpoint.cpp:80
↓ 13 callersMethodUpdateRecord
core/collection_pipeline/batch/TimeoutFlushManager.cpp:21
↓ 13 callersMethodVersion
(ctx context.Context)
pkg/helper/containercenter/cri_runtime_api_interface.go:152
↓ 13 callersFunctionconvertLabels
(labels []*protocol.Log_Content)
pkg/selfmonitor/metrics_vector_imp.go:397
↓ 13 callersMethodgenEntityTypeKey
(kind string)
plugins/input/kubernetesmetav2/meta_collector.go:514
↓ 13 callersFunctiongenerateLog
(kvPairs ...interface{})
pkg/logger/logger.go:350
↓ 13 callersFunctiongetPluginMeta
core/unittest/processor/ProcessorParseApsaraNativeUnittest.cpp:71
↓ 13 callersMethodlogError
(err error)
plugins/processor/logtoslsmetric/processor_log_to_sls_metric.go:338
↓ 13 callersFunctionpanicRecover
()
pkg/helper/k8smeta/k8s_meta_store_interface.go:29
↓ 13 callersMethodprocessLog
(log *protocol.Log)
plugins/processor/strptime/strptime.go:122
↓ 13 callersMethodsignal
core/common/queue/lightweightsemaphore.h:106
↓ 12 callersMethodAppendTag
core/models/SpanEvent.cpp:72
↓ 12 callersMethodApplyContainerDiffs
core/container_manager/ContainerManager.cpp:102
↓ 12 callersMethodCopy
core/models/RawEvent.cpp:26
↓ 12 callersMethodDecRef
core/ebpf/plugin/ProcessCache.cpp:81
↓ 12 callersMethodDelTag
core/models/SpanEvent.cpp:88
↓ 12 callersMethodDoConverge
core/ebpf/util/Converger.cpp:25
↓ 12 callersMethodErase
core/models/SizedContainer.h:42
↓ 12 callersMethodError
Error returns the cause of the insufficient buffer error.
external/github.com/elastic/beats/v7/winlogbeat/sys/errors.go:28
↓ 12 callersFunctionErrorf
(ctx context.Context, alarmType selfmonitor.TypedAlarmType, format string, params ...interface{})
pkg/logger/logger.go:246
↓ 12 callersFunctionGetCallNameIdx
core/ebpf/driver/CallName.h:25
↓ 12 callersMethodGetCapacity
core/collection_pipeline/queue/QueueParam.h:35
↓ 12 callersFunctionGetCastConfig
core/unittest/spl/SplBenchmark.cpp:51
↓ 12 callersMethodGetCurrentLimit
core/collection_pipeline/limiter/ConcurrencyLimiter.cpp:24
↓ 12 callersMethodGetEndTimeNs
core/models/SpanEvent.h:168
↓ 12 callersMethodGetExtension
(name string)
pluginmanager/plugin_runner.go:53
↓ 12 callersMethodGetFileDiscoveryConfig
获取给定名称的文件发现配置
core/file_server/FileServer.cpp:138
↓ 12 callersMethodGetFiles
core/plugin/input/InputStaticFile.cpp:173
↓ 12 callersMethodGetHostIdType
core/common/MachineInfoUtil.h:82
↓ 12 callersMethodGetKind
core/models/SpanEvent.h:162
↓ 12 callersMethodGetLogStore
()
pkg/context.go:80
↓ 12 callersMethodGetParentSpanId
core/models/SpanEvent.h:156
↓ 12 callersMethodGetQueue
core/collection_pipeline/queue/SenderQueueManager.cpp:56
↓ 12 callersMethodGetResult
GetResult the current aggregates to the accumulator.
pkg/pipeline/aggregator.go:56
↓ 12 callersMethodGetStartTimeNs
core/models/SpanEvent.h:165
↓ 12 callersMethodGetValue
()
pkg/protocol/sls_logs.pb.go:194
↓ 12 callersMethodInit
Init called for init some system resources, like socket, mutex...
plugins/processor/fieldswithcondition/processor_fields_with_condition.go:84
↓ 12 callersMethodIsAllQueueEmpty
core/collection_pipeline/queue/SenderQueueManager.cpp:161
↓ 12 callersFunctionIsIgnoredInterfaceForHostIdentity
core/common/MachineInfoUtil.h:107
↓ 12 callersMethodIsPeerMetaAttachReady
core/ebpf/plugin/network_observer/Connection.h:113
↓ 12 callersMethodIsSelfMetaAttachReady
core/ebpf/plugin/network_observer/Connection.h:108
↓ 12 callersMethodIsValid
core/common/DevInode.h:38
↓ 12 callersFunctionNewAggregatorBase
NewAggregatorBase create a default aggregator with default value.
plugins/aggregator/baseagg/aggregator_base.go:207
↓ 12 callersFunctionNewAsyncControl
()
pkg/pipeline/control.go:57
↓ 12 callersFunctionNewDeferredDeletionMetaStore
(eventCh chan *K8sMetaEvent, stopCh <-chan struct{}, gracePeriod int64, keyFunc cache.KeyFunc, indexRules ...I
pkg/helper/k8smeta/k8s_meta_deferred_deletion_meta_store.go:59
↓ 12 callersMethodNowSec
core/common/TimeKeeper.h:50
↓ 12 callersFunctionOverwriteFile
core/common/FileSystemUtil.cpp:217
↓ 12 callersMethodPushProcessQueue
core/collection_pipeline/queue/ExactlyOnceQueueManager.cpp:130
↓ 12 callersFunctionReadLogVal
ReadLogVal returns the log content value for the input key, and returns empty string when not found.
pkg/helper/profile/pyroscope/pprof/pprof_test.go:110
← previousnext →501–600 of 13,853, ranked by callers