MCPcopy Create free account

hub / github.com/alibaba/loongcollector / functions

Functions13,853 in github.com/alibaba/loongcollector

↓ 7 callersMethodAddInput
core/file_server/StaticFileServer.cpp:95
↓ 7 callersMethodAddLogTime
core/protobuf/sls/LogGroupSerializer.cpp:111
↓ 7 callersMethodAddMetadata
core/file_server/ContainerInfo.cpp:37
↓ 7 callersMethodApsaraEasyReadLogTimeParser
* 解析Apsara格式日志的时间。 * @param buffer - 包含日志数据的字符串视图。 * @param cachedTimeStr - 缓存的时间字符串。 * @param cachedLogTime - 缓存的时间字符串的时间戳(秒),必须与cachedTimeStr同时修改
core/plugin/processor/ProcessorParseApsaraNative.cpp:251
↓ 7 callersFunctionCalculatePathDepth
计算路径深度(路径分隔符的数量)
core/file_server/FileDiscoveryOptions.h:195
↓ 7 callersMethodCheckGC
core/models/EventPool.cpp:181
↓ 7 callersMethodClearCache
core/file_server/polling/PollingModify.h:47
↓ 7 callersMethodClearEnvironment
core/unittest/config/PipelineManagerMock.h:44
↓ 7 callersFunctionCollectBody
(res http.ResponseWriter, req *http.Request, maxBodySize int64)
pkg/protocol/decoder/common/comon.go:61
↓ 7 callersFunctionComputeBuckets
ComputeBuckets computes the bucket boundarys and counts.
pkg/protocol/otlp/metric_helper.go:39
↓ 7 callersMethodConnectionTotal
core/ebpf/plugin/network_observer/ConnectionManager.h:53
↓ 7 callersFunctionConvertKernelTimeToUnixTime
core/common/TimeUtil.cpp:467
↓ 7 callersFunctionDelta
core/host_monitor/collector/DiskCollector.cpp:273
↓ 7 callersMethodDir
core/common/FileSystemUtil.cpp:474
↓ 7 callersMethodDiscovery
(ctx context.Context, in *ServiceNameCollection, opts ...grpc.CallOption)
plugins/input/skywalkingv2/skywalking/apm/network/language/agent/DiscoveryService_grpc.pb.go:142
↓ 7 callersMethodDoCompress
core/common/compression/Compressor.cpp:38
↓ 7 callersMethodDone
()
test/engine/setup/monitor/monitor.go:164
↓ 7 callersFunctionDurationToSecond
core/prometheus/Utils.cpp:36
↓ 7 callersMethodEmpty
core/prometheus/labels/Relabel.cpp:285
↓ 7 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
plugins/flusher/opentelemetry/flusher_otlp.go:138
↓ 7 callersMethodFindBestMatch
core/file_server/ConfigManager.cpp:654
↓ 7 callersMethodForward
core/unittest/forward/MockServiceImpl.h:31
↓ 7 callersMethodGet
(key []string)
pkg/helper/k8smeta/k8s_meta_deferred_deletion_meta_store.go:80
↓ 7 callersFunctionGetAddrString
core/common/NetworkUtil.cpp:62
↓ 7 callersMethodGetAllCheckpointFileNames
core/file_server/checkpoint/InputStaticFileCheckpointManager.cpp:259
↓ 7 callersFunctionGetFieldAs
core/host_monitor/common/FastFieldParser.h:223
↓ 7 callersMethodGetHandler
core/file_server/EventDispatcher.h:121
↓ 7 callersMethodGetLabel
core/monitor/metric_models/SelfMonitorMetricEvent.cpp:187
↓ 7 callersMethodGetLevel
core/models/LogEvent.h:92
↓ 7 callersFunctionGetLogSize
core/protobuf/sls/LogGroupSerializer.cpp:234
↓ 7 callersFunctionGetMandatoryIntParam
core/common/ParamExtractor.cpp:147
↓ 7 callersMethodGetMaxBytePerSec
core/app_config/AppConfig.h:449
↓ 7 callersFunctionGetOSState
GetOSState returns the FileStateOS for non windows systems
pkg/helper/file_helper_darwin.go:35
↓ 7 callersFunctionGetProfileSender
core/provider/Provider.cpp:37
↓ 7 callersMethodGetServiceName
()
plugins/input/skywalkingv2/skywalking/apm/network/language/agent/Register.pb.go:133
↓ 7 callersFunctionHasEnvTags
HasEnvTags check if specific tags exist in envTags
pkg/helper/env_tags.go:47
↓ 7 callersMethodIncRef
core/ebpf/plugin/ProcessCache.cpp:75
↓ 7 callersMethodInfof
Infof uses fmt.Sprintf to log a templated message.
external/github.com/elastic/beats/v7/libbeat/logp/logger.go:107
↓ 7 callersMethodIsAcceptMultiConfig
core/app_config/AppConfig.h:429
↓ 7 callersFunctionIsConfigEnabled
core/config/ConfigUtil.cpp:69
↓ 7 callersMethodIsDirectoryInBlacklist
core/file_server/FileDiscoveryOptions.cpp:447
↓ 7 callersMethodIsECSValid
core/common/MachineInfoUtil.h:74
↓ 7 callersMethodIsExiting
core/application/Application.h:42
↓ 7 callersMethodIsReadToEnd
core/file_server/reader/LogFileReader.h:361
↓ 7 callersMethodIsTimeout
core/file_server/event/Event.h:140
↓ 7 callersMethodKeepAlive
Keep the instance alive in the backend analysis. Only recommend to do separate keepAlive report when no trace and metrics needs to be reported. Otherw
plugins/input/skywalkingv3/skywalking/network/management/v3/Management_grpc.pb.go:29
↓ 7 callersFunctionLoadConfigDetailFromFile
core/config/ConfigUtil.cpp:27
↓ 7 callersFunctionLoadPluginMock
core/unittest/plugin/PluginMock.h:305
↓ 7 callersMethodMarshalToSizedBuffer
(dAtA []byte)
pkg/protocol/sls_logs.pb.go:487
↓ 7 callersMethodMergeInt32
core/app_config/AppConfig.cpp:1922
↓ 7 callersFunctionNewMetricMultiValueWithMap
(keyValues map[string]float64)
pkg/models/factory.go:112
↓ 7 callersFunctionParseCredentials
core/common/EcsMetaData.cpp:96
↓ 7 callersMethodParseEnvToFlags
core/app_config/AppConfig.cpp:1432
↓ 7 callersMethodPluginID
core/collection_pipeline/plugin/instance/PluginInstance.h:33
↓ 7 callersFunctionPodLinkTypeForEntity
PodLinkTypeForEntity returns the link ResourceType for RegisterSendFunc (e.g. pod->customresource/...).
pkg/helper/k8smeta/k8s_meta_custom_resource.go:51
↓ 7 callersMethodRegisterConfig
(ctx pipeline.Context, c *Config)
plugins/input/telegraf/telegraf_manager.go:64
↓ 7 callersMethodRegisterEventHandler
core/file_server/EventDispatcher.cpp:142
↓ 7 callersMethodRemoveInput
core/file_server/StaticFileServer.cpp:81
↓ 7 callersMethodRemoveParser
core/ebpf/protocol/ProtocolParser.cpp:58
↓ 7 callersMethodRequiringJsonReader
core/collection_pipeline/CollectionPipelineContext.h:69
↓ 7 callersMethodReserve
Reserve reserves n bytes by increasing the buffer's length. It may allocate a new underlying buffer discarding any existing contents.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/bufferpool.go:90
↓ 7 callersMethodSaveCheckPoint
RegisterCounterMetric(metric CounterMetric) RegisterStringMetric(metric StringMetric) RegisterLatencyMetric(metric LatencyMetric)
pkg/pipeline/context.go:38
↓ 7 callersFunctionSearchFilePathByDevInodeInDirectory
core/file_server/checkpoint/CheckPointManager.cpp:507
↓ 7 callersMethodSetComponent
core/prometheus/schedulers/BaseScheduler.cpp:52
↓ 7 callersFunctionSetCoolBpfConfig
core/ebpf/driver/eBPFDriver.cpp:65
↓ 7 callersMethodSetEndTsNs
core/ebpf/type/NetworkObserverEvent.h:51
↓ 7 callersMethodSetFileDeleted
core/file_server/reader/LogFileReader.cpp:307
↓ 7 callersFunctionSetID
core/common/EcsMetaData.h:44
↓ 7 callersMethodSetIsFlushingThroughGoPipelineFlag
core/collection_pipeline/CollectionPipelineContext.h:80
↓ 7 callersMethodSetStartTsNs
core/ebpf/type/NetworkObserverEvent.h:50
↓ 7 callersMethodSetUpContainersMeta
core/unittest/pipeline/LogtailPluginMock.h:35
↓ 7 callersMethodShouldSend
core/monitor/metric_models/SelfMonitorMetricEvent.cpp:153
↓ 7 callersMethodSortTo
(buf []KeyValue[TValue])
pkg/models/common.go:88
↓ 7 callersMethodStartToAddLog
core/protobuf/sls/LogGroupSerializer.cpp:105
↓ 7 callersFunctionStop
Stop stop the given config. ConfigName is with suffix.
pluginmanager/plugin_manager.go:235
↓ 7 callersFunctionStringDeepCopy
StringDeepCopy returns a deep copy or src. Because we can not make sure the life cycle of string passed from C++, so we have to make a deep copy of th
pkg/util/util.go:396
↓ 7 callersMethodSwap
(i int, j int)
pkg/helper/log_helper.go:136
↓ 7 callersMethodUpdateConfig
core/unittest/ebpf/NetworkObserverConfigUpdateUnittest.cpp:167
↓ 7 callersMethodWarn
Warn uses fmt.Sprint to construct and log a message.
external/github.com/elastic/beats/v7/libbeat/logp/logger.go:74
↓ 7 callersFunctionWithSubscription
WithSubscription configures the iterator with an existing subscription handle.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/iterator.go:67
↓ 7 callersFunctionXXH64_avalanche
! @copydoc XXH32_avalanche */
core/common/xxhash/xxhash.h:2721
↓ 7 callersFunctionXXH_mult32to64
! * @brief Calculates a 32-bit to 64-bit long multiply. * * Implemented as a macro. * * Wraps `__emulu` on MSVC x86 because it tends to call `__a
core/common/xxhash/xxhash.h:3578
↓ 7 callersFunctionXXH_swap32
core/common/xxhash/xxhash.h:2089
↓ 7 callersFunction_EvtClose
(object EvtHandle)
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/zsyscall_windows.go:183
↓ 7 callersMethodassertPriority
(c *C, p Priority, b []byte, cursor int, expC int, e error)
external/github.com/jeromer/syslogparser/syslogparser_test.go:153
↓ 7 callersMethodconvertPipelinesGroupeEventsToRequest
(pipelinegroupeEventSlice []*models.PipelineGroupEvents)
plugins/flusher/opentelemetry/flusher_otlp.go:187
↓ 7 callersFunctioncreate_directory
core/unittest/input/InputContainerStdioUnittest.cpp:64
↓ 7 callersFunctionencodeVarintLogEvent
(dAtA []byte, offset int, v uint64)
pkg/protocol/log_event.pb.go:277
↓ 7 callersFunctionevtFormatMessage
evtFormatMessage uses EvtFormatMessage to generate a string.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/format_message.go:68
↓ 7 callersFunctionfile_logging_Logging_proto_rawDescGZIP
()
plugins/input/skywalkingv3/skywalking/network/logging/v3/Logging.pb.go:603
↓ 7 callersMethodfree
free returns the byteBuffer to the pool.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/bufferpool.go:46
↓ 7 callersMethodgenKey
(kind, namespace, name string)
plugins/input/kubernetesmetav2/meta_collector.go:464
↓ 7 callersMethodgetAllAcceptedInfoV2
( fullList map[string]bool, matchList map[string]*DockerInfoDetail, includeLabel map[string]string, exclud
pkg/helper/containercenter/container_center.go:1085
↓ 7 callersMethodgetIndexKeys
()
plugins/flusher/elasticsearch/flusher_elasticsearch.go:156
↓ 7 callersFunctiongetTestTelegrafManager
(t *testing.T)
plugins/input/telegraf/telegraf_manager_test.go:62
↓ 7 callersMethodhasWildcard
Check if path contains wildcards
core/file_server/FileDiscoveryOptions.h:51
↓ 7 callersFunctioninitMetric
(m pmetric.Metric, name string, ty pmetric.MetricType)
plugins/input/opentelemetry/service_otlp_test.go:635
↓ 7 callersFunctionloadLogger
()
external/github.com/elastic/beats/v7/libbeat/logp/core.go:210
↓ 7 callersFunctionmapDNSResponseCode
(rcode int)
plugins/input/input_etw/dns_enrichment.go:38
↓ 7 callersFunctionnewAggregatorShardHash
()
plugins/aggregator/shardhash/aggregator_shardhash.go:230
← previousnext →901–1,000 of 13,853, ranked by callers