Versions in this module Expand all Collapse all v1 v1.29.0 Feb 28, 2025 v1.28.2 Feb 17, 2025 v1.28.0 Jan 10, 2025 v1.27.0 Dec 6, 2024 Changes in this version + const FileTypeJSON + const FileTypeMultiline + const FileTypeText + const KVLogfileStateBucket + func LoadFileID(fi os.FileInfo, path string) (map[string]interface{}, error) + func New(c *config.Config) (pipeline.Processor, error) + func NewFromConfig(cfg Config) (pipeline.Processor, error) + func SaveFileState(path string, source FileState) + type Cluster struct + ID string + Name string + UUID string + type Config struct + LogsPath string + Metadata util.MapStr + Patterns []*Pattern + QueueName string + type FSEvent struct + Info os.FileInfo + Offset int64 + Op Operation + Path string + Pattern *Pattern + State FileState + type File struct + Offset int64 + Path string + type FileDetector struct + func NewFileDetector(rootPath string, patterns []*Pattern) *FileDetector + func (w *FileDetector) Detect(ctx context.Context) + func (w *FileDetector) Event() FSEvent + func (w *FileDetector) IsSameFile(preState FileState, currentInfo os.FileInfo, path string) bool + type FileState struct + ModTime time.Time + Name string + Offset int64 + Path string + Size int64 + Sys any + func GetFileState(path string) (FileState, error) + type LogEvent struct + AgentMeta *event.AgentMeta + Fields util.MapStr + Meta util.MapStr + Timestamp string + type LogsProcessor struct + func (p *LogsProcessor) GetAgentMeta() *event2.AgentMeta + func (p *LogsProcessor) Name() string + func (p *LogsProcessor) Process(c *pipeline.Context) error + func (p *LogsProcessor) ReadJsonLogs(event FSEvent, c *pipeline.Context) + func (p *LogsProcessor) ReadLogs(event FSEvent, c *pipeline.Context) + func (p *LogsProcessor) ReadMultilineLogs(event FSEvent, c *pipeline.Context) + func (p *LogsProcessor) ReadPlainTextLogs(event FSEvent, c *pipeline.Context) + func (p *LogsProcessor) Save(event FSEvent, logContent util.MapStr, timestamp string) + type Node struct + ID string + Name string + Port int + type Operation uint8 + const OpCreate + const OpDone + const OpTruncate + const OpWrite + type Pattern struct + LinePattern string + Metadata util.MapStr + Pattern string + RemoveFields []string + TimestampFields []string + TimestampPatterns []string + Type string
Go to main page