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
↓ 5 callers
Method
SetSql
core/ebpf/type/NetworkObserverEvent.h:158
↓ 5 callers
Method
SetUserID
core/common/EcsMetaData.h:65
↓ 5 callers
Method
SetVpcID
core/common/EcsMetaData.h:71
↓ 5 callers
Method
SetVswitchID
core/common/EcsMetaData.h:73
↓ 5 callers
Method
ShouldAddSourceContent
core/plugin/processor/CommonParserOptions.cpp:95
↓ 5 callers
Method
SizeReachingUpperLimit
core/collection_pipeline/batch/FlushStrategy.h:57
↓ 5 callers
Function
StartWith
core/plugin/flusher/sls/SLSUtil.cpp:230
↓ 5 callers
Method
Stop
()
plugins/flusher/doris/flusher_doris.go:400
↓ 5 callers
Function
StringPointer
StringPointer returns the pointer of the given string. nolint:gosec
pkg/util/util.go:402
↓ 5 callers
Method
Suspend
core/ebpf/plugin/agentsight/AgentsightManager.cpp:494
↓ 5 callers
Method
ToString
core/container_manager/ContainerDiscoveryOptions.h:87
↓ 5 callers
Method
TryPop
core/common/SafeQueue.h:45
↓ 5 callers
Function
TryReplacePhysicalAddress
(addr string)
test/engine/setup/subscriber/subscriber.go:78
↓ 5 callers
Method
UnblockProcess
core/unittest/pipeline/LogtailPluginMock.h:32
↓ 5 callers
Method
UnregisterConfig
(ctx pipeline.Context, c *Config)
plugins/input/telegraf/telegraf_manager.go:76
↓ 5 callers
Method
Update
(project, logstore, config string)
pkg/selfmonitor/alarm_imp.go:95
↓ 5 callers
Method
UpdateBPFHashMap
* update elements from bpf map */
core/ebpf/driver/BPFWrapper.h:296
↓ 5 callers
Method
UpdateBlockEvent
core/file_server/event/BlockEventManager.cpp:80
↓ 5 callers
Method
UpdateFileProperty
core/file_server/polling/PollingCache.cpp:23
↓ 5 callers
Method
UsingHttps
core/plugin/flusher/sls/SLSClientManager.h:75
↓ 5 callers
Function
WithBatchSize
WithBatchSize configures the number of handles the iterator will request when calling EvtNext. Valid batch sizes range on [1, 1024].
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/iterator.go:75
↓ 5 callers
Function
XXH32_avalanche
! * @internal * @brief Mixes all bits to finalize the hash. * * The final mix ensures that all input bits have a chance to impact any bit in * th
core/common/xxhash/xxhash.h:2243
↓ 5 callers
Function
_EvtCreateBookmark
(bookmarkXML *uint16)
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/zsyscall_windows.go:133
↓ 5 callers
Function
_EvtNext
(resultSet EvtHandle, eventArraySize uint32, eventArray *EvtHandle, timeout uint32, flags uint32, numReturned
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/zsyscall_windows.go:208
↓ 5 callers
Function
addTagIfRequired
(tags, tagKeyRenameMap map[string]string, key, value string)
pkg/protocol/converter/converter.go:309
↓ 5 callers
Method
assertLogPosition
(c *check.C, log *protocol.Log, offset string)
plugins/processor/split/logregex/split_log_regex_test.go:305
↓ 5 callers
Function
benchmarkSplit
(b *testing.B, s *KeyValueSplitter, totalPartCount int, partLength int)
plugins/processor/split/keyvalue/key_value_splitter_test.go:291
↓ 5 callers
Function
buildEncoder
(cfg Config)
external/github.com/elastic/beats/v7/libbeat/logp/encoding.go:39
↓ 5 callers
Function
containsResource
helper: 判断资源列表里是否包含指定名称
pkg/helper/k8smeta/k8s_meta_cache.go:434
↓ 5 callers
Function
convertUniIDToString
(u *agent.UniqueId)
plugins/input/skywalkingv2/trace_segment_handle.go:232
↓ 5 callers
Function
deref_noexcept
core/common/queue/concurrentqueue.h:545
↓ 5 callers
Function
extractTags
extractTags extracts tags from rawTags and append them into log. Rule: k1~=~v1^^^k2~=~v2 rawTags
pluginmanager/logstore_config.go:152
↓ 5 callers
Function
extractTagsToLogTags
extractTagsToLogTags extracts tags from rawTags and append them into []*protocol.LogTag. Rule: k1~=~v1^^^k2~=~v2 rawTags
pluginmanager/logstore_config.go:185
↓ 5 callers
Function
file_common_Common_proto_rawDescGZIP
()
plugins/input/skywalkingv3/skywalking/network/common/v3/Common.pb.go:340
↓ 5 callers
Function
file_common_trace_common_proto_rawDescGZIP
()
plugins/input/skywalkingv2/skywalking/apm/network/language/agent/trace-common.pb.go:338
↓ 5 callers
Method
fillProcessPlainFields
core/ebpf/plugin/ProcessExecveRetryableEvent.cpp:68
↓ 5 callers
Method
findPodByPodIPPort
(ip string, port int32, objs map[string][]*ObjectWrapper)
pkg/helper/k8smeta/k8s_meta_http_server.go:195
↓ 5 callers
Method
findPodByServiceIPPort
(ip string, port int32)
pkg/helper/k8smeta/k8s_meta_http_server.go:131
↓ 5 callers
Function
fmix32
core/common/murmurhash3.cpp:64
↓ 5 callers
Function
frames
(st *parser.StackTrace)
pkg/helper/profile/pyroscope/jfr/parser.go:279
↓ 5 callers
Function
generateMetricEvents
(count int, meta map[string]string)
plugins/aggregator/metadatagroup/aggregator_metadata_group_test.go:228
↓ 5 callers
Method
get
get returns the non-expired values from the cache.
plugins/input/input_wineventlog/eventlog/common/cache.go:253
↓ 5 callers
Function
getMessageStringFromMessageID
getMessageStringFromMessageID returns the message associated with the given message ID.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/format_message.go:36
↓ 5 callers
Method
getNextRetryDelay
(retryTime int)
plugins/flusher/http/flusher_http.go:477
↓ 5 callers
Method
getOrCreateConnection
core/ebpf/plugin/network_observer/ConnectionManager.cpp:26
↓ 5 callers
Function
getblock32
core/common/murmurhash3.cpp:53
↓ 5 callers
Function
httpExport
(cli *http.Client, eReq P, url string, usePB bool)
plugins/input/opentelemetry/service_otlp_test.go:291
↓ 5 callers
Function
initMetricAttributes13
(dest pcommon.Map)
plugins/input/opentelemetry/service_otlp_test.go:674
↓ 5 callers
Function
isContainerLabelMatch
(includeLabel map[string]string, excludeLabel map[string]string, includeLabelRegex map[string]*regexp2.Regex
pkg/helper/containercenter/container_center.go:991
↓ 5 callers
Function
logDatabaseError
Log error locally and send alarm.
core/file_server/checkpoint/CheckpointManagerV2.cpp:44
↓ 5 callers
Method
logErr
(errStr string)
plugins/input/udpserver/shared_udp_server.go:104
↓ 5 callers
Function
newByteBuffer
newByteBuffer return a byteBuffer from the pool. The returned value must be released with free().
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/bufferpool.go:39
↓ 5 callers
Function
newInputV3
()
plugins/input/snmp/input_snmp_test.go:144
↓ 5 callers
Function
newProcessor
()
plugins/processor/rename/processor_rename_test.go:51
↓ 5 callers
Function
newSyslog
()
plugins/input/syslog/syslog.go:447
↓ 5 callers
Function
new_block_index
core/common/queue/concurrentqueue.h:2356
↓ 5 callers
Function
parseTemplate
(name string, bytes []byte)
tools/builder/templates.go:44
↓ 5 callers
Method
processCustomResourceEntity
(data *k8smeta.ObjectWrapper, method string)
plugins/input/kubernetesmetav2/meta_collector_cr.go:13
↓ 5 callers
Method
put
return need to save
plugins/input/skywalkingv3/management_handle.go:45
↓ 5 callers
Method
readBytes
core/protobuf/models/ManualPBParser.cpp:276
↓ 5 callers
Method
registerPodCRLink
(linkType string, rt *podCRLinkRuntime)
pkg/helper/k8smeta/k8s_meta_link.go:38
↓ 5 callers
Method
registryApplicationInstance
(int32, string, *agent.OSInfo)
plugins/input/skywalkingv2/application_cache.go:56
↓ 5 callers
Method
registryEndpoint
(applicationID int32, endpoint string)
plugins/input/skywalkingv2/application_cache.go:61
↓ 5 callers
Function
rewind_block_index_tail
core/common/queue/concurrentqueue.h:2935
↓ 5 callers
Function
safeGetInt32String
(pointer *int32)
plugins/input/kubernetesmetav2/meta_collector.go:544
↓ 5 callers
Function
skipSpaces
core/plugin/processor/inner/ProcessorParseContainerLogNative.cpp:259
↓ 5 callers
Function
stringField
(t *testing.T, log *models.Log, key string)
plugins/input/kubernetesmetav2/meta_collector_cr_test.go:222
↓ 5 callers
Function
timeoutFlush
( q Q, req T, metadata metadata.MD, grpcConfig *helper.GrpcClientConfig)
plugins/flusher/opentelemetry/flusher_otlp.go:320
↓ 5 callers
Method
updateContainers
(containerMap map[string]*DockerInfoDetail)
pkg/helper/containercenter/container_center.go:1199
↓ 4 callers
Method
AddCheckPoint
core/file_server/checkpoint/CheckPointManager.cpp:50
↓ 4 callers
Method
AddEvent
core/prometheus/component/StreamScraper.cpp:90
↓ 4 callers
Method
AddFileTagConfig
添加Tag配置
core/file_server/FileServer.cpp:220
↓ 4 callers
Method
AddLog
core/plugin/processor/ProcessorParseJsonNative.cpp:469
↓ 4 callers
Method
AddSourceBuffer
core/models/PipelineEventGroup.cpp:247
↓ 4 callers
Method
AddSourceBuffer
core/collection_pipeline/batch/BatchItem.h:152
↓ 4 callers
Method
AlignLastCharacter
core/file_server/reader/LogFileReader.cpp:2095
↓ 4 callers
Method
Allocate
core/common/memory/SourceBuffer.h:83
↓ 4 callers
Function
AtomicLoadFloat64
(dst *float64)
pkg/helper/math/math_helper.go:58
↓ 4 callers
Method
AttachProcessData
core/ebpf/plugin/ProcessCacheManager.cpp:248
↓ 4 callers
Method
Block
core/unittest/plugin/PluginMock.h:86
↓ 4 callers
Function
BoostRegexMatch
core/common/StringTools.cpp:183
↓ 4 callers
Method
BuildAsyncRequest
core/metadata/K8sMetadata.cpp:286
↓ 4 callers
Method
Cancel
core/prometheus/async/PromFuture.cpp:30
↓ 4 callers
Function
CastContainerDetail
(containerInfo *DockerInfoDetail, envSet, labelSet, k8sLabelSet map[string]struct{})
pkg/helper/containercenter/container_export.go:363
↓ 4 callers
Method
CheckFileChange
()
pkg/helper/log_file_reader.go:146
↓ 4 callers
Function
CheckNameExist
core/common/JsonUtil.cpp:139
↓ 4 callers
Method
Clear
core/collection_pipeline/batch/BatchedEvents.cpp:93
↓ 4 callers
Method
ClearRetryTimes
core/forward/loongsuite/LoongSuiteForwardService.h:68
↓ 4 callers
Method
ClearStatistic
()
test/engine/setup/monitor/statistic.go:94
↓ 4 callers
Method
CloneInto
(dst *MetricLabels)
pkg/helper/log_helper.go:166
↓ 4 callers
Function
Close
Close the logger and recover the stdout and stderr
pkg/logger/logger.go:375
↓ 4 callers
Function
Close
Close closes an EvtHandle.
external/github.com/elastic/beats/v7/winlogbeat/sys/wineventlog/wineventlog_windows.go:359
↓ 4 callers
Function
ComposeBucketFieldName
ComposeBucketFieldName generates the bucket count field name for histogram metrics.
pkg/protocol/otlp/metric_helper.go:31
↓ 4 callers
Function
ConvertOtlpMetricV1
(otlpMetrics pmetric.Metrics)
pkg/protocol/decoder/opentelemetry/otlpDataToSLSProto.go:344
↓ 4 callers
Function
CreateHttpDataEvent
core/unittest/ebpf/HttpRetryableEventUnittest.cpp:64
↓ 4 callers
Method
CreateInput
core/collection_pipeline/plugin/PluginRegistry.cpp:108
↓ 4 callers
Function
CreateLog
(t time.Time, enableTimestampNano bool, configTag map[string]string, logTags map[string]string, fields map[str
pkg/helper/log_helper.go:41
↓ 4 callers
Function
CreateLogByArray
(t time.Time, enableTimestampNano bool, configTag map[string]string, logTags map[string]string, columns []stri
pkg/helper/log_helper.go:75
↓ 4 callers
Method
Decode
Decode impl
pkg/protocol/decoder/opentelemetry/decoder.go:45
↓ 4 callers
Function
DeleteLogstoreConfig
(config *LogstoreConfig, removedFlag bool)
pluginmanager/plugin_manager.go:164
← previous
next →
1,301–1,400 of 13,853, ranked by callers