NewEventIterator creates an iterator to read event handles from a subscription. The iterator is thread-safe.

StartService starts the ServiceInput's service, whatever that may be

export Stop

Parse time (local timezone) from log return the position of the parsing ends. If parsing fails, return NULL. */

attrs2Tags converts otlp attributes to tags, it skips empty values.

Rule: pluginTypeWithID=pluginType/pluginID#pluginPriority.

openLog opens an event log or .evtx file for reading.

CancelToken returns a readonly channel that can be subscribed to as a cancel token

valid proxy address format: [scheme://[user:pwd\@]]address[:port], 'http' and '80' assumed if no scheme or port provided

CollectList collect GroupEvents list that have been grouped

DecodeOtlpRequest decodes the data and fills into the otlp logs/metrics/traces export request.

Init called for init some system resources, like socket, mutex...

export LoadPipeline

暂停文件服务，根据配置更新标志来决定是否要执行相关的清理和保存操作

释放“ReentrantMetricsRecordRef”指标记录对象

Remove an address from the listen inputs

恢复文件服务，重新注册事件处理程序和恢复日志输入

export Start

newLabelMatcher create a new label matcher.