Flush flushes data to destination, such as SLS, console, file, etc. It is expected to return no error at most time because IsReady will be called befo

Write {logNum} logs to {filename} filename: /{workpath}/{jobname}.log

Open the event log. checkpoint points to the last successfully read event in this event log. Read will resume from the next record. To start reading f

Reset resets the aggregators caches and aggregates.

* @brief 获取字段迭代器结束位置 * @return StringViewSplitterIterator */

Fatal uses fmt.Sprint to construct and log a message, then calls os.Exit(1).

NewMetricLog create a metric log, time support unix milliseconds and unix nanoseconds. Note: must pass safe string

For hostnames in the following format, gethostbyname will fake an IP (and thus return wrong IP): 1. a, where a is a number between 0 and 2^32-1; 2. a.

Add the metric to the aggregator.

Fatalf uses fmt.Sprintf to log a templated message, then calls os.Exit(1).

nolint

NewCounterMetricAndRegister creates a new DeltaMetric and register it's metricVector to the MetricsRecord.

nolint:gosec

nolint:gosec

Collect takes in an accumulator and adds the metrics that the Input gathers. This is called every "interval"

注意: 不要在类初始化时调用并缓存结果，因为此时ECS元数据可能尚未就绪 建议在实际使用时再调用此方法

key: fd + "_" + dev + "_" + inode

PathJoin concats base and sub (by adding necessary path separator). NOTE: the implementation is not elegant for better performance (backward).

ReadLogVal returns the log content value for the input key, and returns empty string when not found.

Build builds a query from the given parameters. The query is returned as a XML string and can be used with Subscribe function.

Recommend to report log data in a stream mode. The service/instance/endpoint of the log could share the previous value if they are not set. Reporting

Decode reader to logs