Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/alibaba/loongcollector
/ functions
Functions
13,853 in github.com/alibaba/loongcollector
⨍
Functions
13,853
◇
Types & classes
2,558
↓ 7 callers
Method
AddInput
core/file_server/StaticFileServer.cpp:95
↓ 7 callers
Method
AddLogTime
core/protobuf/sls/LogGroupSerializer.cpp:111
↓ 7 callers
Method
AddMetadata
core/file_server/ContainerInfo.cpp:37
↓ 7 callers
Method
ApsaraEasyReadLogTimeParser
* 解析Apsara格式日志的时间。 * @param buffer - 包含日志数据的字符串视图。 * @param cachedTimeStr - 缓存的时间字符串。 * @param cachedLogTime - 缓存的时间字符串的时间戳(秒),必须与cachedTimeStr同时修改
core/plugin/processor/ProcessorParseApsaraNative.cpp:251
↓ 7 callers
Function
CalculatePathDepth
计算路径深度(路径分隔符的数量)
core/file_server/FileDiscoveryOptions.h:195
↓ 7 callers
Method
CheckGC
core/models/EventPool.cpp:181
↓ 7 callers
Method
ClearCache
core/file_server/polling/PollingModify.h:47
↓ 7 callers
Method
ClearEnvironment
core/unittest/config/PipelineManagerMock.h:44
↓ 7 callers
Function
CollectBody
(res http.ResponseWriter, req *http.Request, maxBodySize int64)
pkg/protocol/decoder/common/comon.go:61
↓ 7 callers
Function
ComputeBuckets
ComputeBuckets computes the bucket boundarys and counts.
pkg/protocol/otlp/metric_helper.go:39
↓ 7 callers
Method
ConnectionTotal
core/ebpf/plugin/network_observer/ConnectionManager.h:53
↓ 7 callers
Function
ConvertKernelTimeToUnixTime
core/common/TimeUtil.cpp:467
↓ 7 callers
Function
Delta
core/host_monitor/collector/DiskCollector.cpp:273
↓ 7 callers
Method
Dir
core/common/FileSystemUtil.cpp:474
↓ 7 callers
Method
Discovery
(ctx context.Context, in *ServiceNameCollection, opts ...grpc.CallOption)
plugins/input/skywalkingv2/skywalking/apm/network/language/agent/DiscoveryService_grpc.pb.go:142
↓ 7 callers
Method
DoCompress
core/common/compression/Compressor.cpp:38
↓ 7 callers
Method
Done
()
test/engine/setup/monitor/monitor.go:164
↓ 7 callers
Function
DurationToSecond
core/prometheus/Utils.cpp:36
↓ 7 callers
Method
Empty
core/prometheus/labels/Relabel.cpp:285
↓ 7 callers
Method
Export
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 callers
Method
FindBestMatch
core/file_server/ConfigManager.cpp:654
↓ 7 callers
Method
Forward
core/unittest/forward/MockServiceImpl.h:31
↓ 7 callers
Method
Get
(key []string)
pkg/helper/k8smeta/k8s_meta_deferred_deletion_meta_store.go:80
↓ 7 callers
Function
GetAddrString
core/common/NetworkUtil.cpp:62
↓ 7 callers
Method
GetAllCheckpointFileNames
core/file_server/checkpoint/InputStaticFileCheckpointManager.cpp:259
↓ 7 callers
Function
GetFieldAs
core/host_monitor/common/FastFieldParser.h:223
↓ 7 callers
Method
GetHandler
core/file_server/EventDispatcher.h:121
↓ 7 callers
Method
GetLabel
core/monitor/metric_models/SelfMonitorMetricEvent.cpp:187
↓ 7 callers
Method
GetLevel
core/models/LogEvent.h:92
↓ 7 callers
Function
GetLogSize
core/protobuf/sls/LogGroupSerializer.cpp:234
↓ 7 callers
Function
GetMandatoryIntParam
core/common/ParamExtractor.cpp:147
↓ 7 callers
Method
GetMaxBytePerSec
core/app_config/AppConfig.h:449
↓ 7 callers
Function
GetOSState
GetOSState returns the FileStateOS for non windows systems
pkg/helper/file_helper_darwin.go:35
↓ 7 callers
Function
GetProfileSender
core/provider/Provider.cpp:37
↓ 7 callers
Method
GetServiceName
()
plugins/input/skywalkingv2/skywalking/apm/network/language/agent/Register.pb.go:133
↓ 7 callers
Function
HasEnvTags
HasEnvTags check if specific tags exist in envTags
pkg/helper/env_tags.go:47
↓ 7 callers
Method
IncRef
core/ebpf/plugin/ProcessCache.cpp:75
↓ 7 callers
Method
Infof
Infof uses fmt.Sprintf to log a templated message.
external/github.com/elastic/beats/v7/libbeat/logp/logger.go:107
↓ 7 callers
Method
IsAcceptMultiConfig
core/app_config/AppConfig.h:429
↓ 7 callers
Function
IsConfigEnabled
core/config/ConfigUtil.cpp:69
↓ 7 callers
Method
IsDirectoryInBlacklist
core/file_server/FileDiscoveryOptions.cpp:447
↓ 7 callers
Method
IsECSValid
core/common/MachineInfoUtil.h:74
↓ 7 callers
Method
IsExiting
core/application/Application.h:42
↓ 7 callers
Method
IsReadToEnd
core/file_server/reader/LogFileReader.h:361
↓ 7 callers
Method
IsTimeout
core/file_server/event/Event.h:140
↓ 7 callers
Method
KeepAlive
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 callers
Function
LoadConfigDetailFromFile
core/config/ConfigUtil.cpp:27
↓ 7 callers
Function
LoadPluginMock
core/unittest/plugin/PluginMock.h:305
↓ 7 callers
Method
MarshalToSizedBuffer
(dAtA []byte)
pkg/protocol/sls_logs.pb.go:487
↓ 7 callers
Method
MergeInt32
core/app_config/AppConfig.cpp:1922
↓ 7 callers
Function
NewMetricMultiValueWithMap
(keyValues map[string]float64)
pkg/models/factory.go:112
↓ 7 callers
Function
ParseCredentials
core/common/EcsMetaData.cpp:96
↓ 7 callers
Method
ParseEnvToFlags
core/app_config/AppConfig.cpp:1432
↓ 7 callers
Method
PluginID
core/collection_pipeline/plugin/instance/PluginInstance.h:33
↓ 7 callers
Function
PodLinkTypeForEntity
PodLinkTypeForEntity returns the link ResourceType for RegisterSendFunc (e.g. pod->customresource/...).
pkg/helper/k8smeta/k8s_meta_custom_resource.go:51
↓ 7 callers
Method
RegisterConfig
(ctx pipeline.Context, c *Config)
plugins/input/telegraf/telegraf_manager.go:64
↓ 7 callers
Method
RegisterEventHandler
core/file_server/EventDispatcher.cpp:142
↓ 7 callers
Method
RemoveInput
core/file_server/StaticFileServer.cpp:81
↓ 7 callers
Method
RemoveParser
core/ebpf/protocol/ProtocolParser.cpp:58
↓ 7 callers
Method
RequiringJsonReader
core/collection_pipeline/CollectionPipelineContext.h:69
↓ 7 callers
Method
Reserve
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 callers
Method
SaveCheckPoint
RegisterCounterMetric(metric CounterMetric) RegisterStringMetric(metric StringMetric) RegisterLatencyMetric(metric LatencyMetric)
pkg/pipeline/context.go:38
↓ 7 callers
Function
SearchFilePathByDevInodeInDirectory
core/file_server/checkpoint/CheckPointManager.cpp:507
↓ 7 callers
Method
SetComponent
core/prometheus/schedulers/BaseScheduler.cpp:52
↓ 7 callers
Function
SetCoolBpfConfig
core/ebpf/driver/eBPFDriver.cpp:65
↓ 7 callers
Method
SetEndTsNs
core/ebpf/type/NetworkObserverEvent.h:51
↓ 7 callers
Method
SetFileDeleted
core/file_server/reader/LogFileReader.cpp:307
↓ 7 callers
Function
SetID
core/common/EcsMetaData.h:44
↓ 7 callers
Method
SetIsFlushingThroughGoPipelineFlag
core/collection_pipeline/CollectionPipelineContext.h:80
↓ 7 callers
Method
SetStartTsNs
core/ebpf/type/NetworkObserverEvent.h:50
↓ 7 callers
Method
SetUpContainersMeta
core/unittest/pipeline/LogtailPluginMock.h:35
↓ 7 callers
Method
ShouldSend
core/monitor/metric_models/SelfMonitorMetricEvent.cpp:153
↓ 7 callers
Method
SortTo
(buf []KeyValue[TValue])
pkg/models/common.go:88
↓ 7 callers
Method
StartToAddLog
core/protobuf/sls/LogGroupSerializer.cpp:105
↓ 7 callers
Function
Stop
Stop stop the given config. ConfigName is with suffix.
pluginmanager/plugin_manager.go:235
↓ 7 callers
Function
StringDeepCopy
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 callers
Method
Swap
(i int, j int)
pkg/helper/log_helper.go:136
↓ 7 callers
Method
UpdateConfig
core/unittest/ebpf/NetworkObserverConfigUpdateUnittest.cpp:167
↓ 7 callers
Method
Warn
Warn uses fmt.Sprint to construct and log a message.
external/github.com/elastic/beats/v7/libbeat/logp/logger.go:74
↓ 7 callers
Function
WithSubscription
WithSubscription configures the iterator with an existing subscription handle.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/iterator.go:67
↓ 7 callers
Function
XXH64_avalanche
! @copydoc XXH32_avalanche */
core/common/xxhash/xxhash.h:2721
↓ 7 callers
Function
XXH_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 callers
Function
XXH_swap32
core/common/xxhash/xxhash.h:2089
↓ 7 callers
Function
_EvtClose
(object EvtHandle)
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/zsyscall_windows.go:183
↓ 7 callers
Method
assertPriority
(c *C, p Priority, b []byte, cursor int, expC int, e error)
external/github.com/jeromer/syslogparser/syslogparser_test.go:153
↓ 7 callers
Method
convertPipelinesGroupeEventsToRequest
(pipelinegroupeEventSlice []*models.PipelineGroupEvents)
plugins/flusher/opentelemetry/flusher_otlp.go:187
↓ 7 callers
Function
create_directory
core/unittest/input/InputContainerStdioUnittest.cpp:64
↓ 7 callers
Function
encodeVarintLogEvent
(dAtA []byte, offset int, v uint64)
pkg/protocol/log_event.pb.go:277
↓ 7 callers
Function
evtFormatMessage
evtFormatMessage uses EvtFormatMessage to generate a string.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/format_message.go:68
↓ 7 callers
Function
file_logging_Logging_proto_rawDescGZIP
()
plugins/input/skywalkingv3/skywalking/network/logging/v3/Logging.pb.go:603
↓ 7 callers
Method
free
free returns the byteBuffer to the pool.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/bufferpool.go:46
↓ 7 callers
Method
genKey
(kind, namespace, name string)
plugins/input/kubernetesmetav2/meta_collector.go:464
↓ 7 callers
Method
getAllAcceptedInfoV2
( fullList map[string]bool, matchList map[string]*DockerInfoDetail, includeLabel map[string]string, exclud
pkg/helper/containercenter/container_center.go:1085
↓ 7 callers
Method
getIndexKeys
()
plugins/flusher/elasticsearch/flusher_elasticsearch.go:156
↓ 7 callers
Function
getTestTelegrafManager
(t *testing.T)
plugins/input/telegraf/telegraf_manager_test.go:62
↓ 7 callers
Method
hasWildcard
Check if path contains wildcards
core/file_server/FileDiscoveryOptions.h:51
↓ 7 callers
Function
initMetric
(m pmetric.Metric, name string, ty pmetric.MetricType)
plugins/input/opentelemetry/service_otlp_test.go:635
↓ 7 callers
Function
loadLogger
()
external/github.com/elastic/beats/v7/libbeat/logp/core.go:210
↓ 7 callers
Function
mapDNSResponseCode
(rcode int)
plugins/input/input_etw/dns_enrichment.go:38
↓ 7 callers
Function
newAggregatorShardHash
()
plugins/aggregator/shardhash/aggregator_shardhash.go:230
← previous
next →
901–1,000 of 13,853, ranked by callers