Documentation
¶
Index ¶
- type LogEntry
- type LogStream
- type Processor
- func (p *Processor) Cleanup(ctx context.Context, nodeID string) error
- func (p *Processor) ClearProcessedLogs(ctx context.Context, nodeID string) error
- func (p *Processor) CreateStream(ctx context.Context, nodeID string) error
- func (p *Processor) GetProcessedLogs(ctx context.Context, nodeID string) ([]LogEntry, error)
- func (p *Processor) Initialize(ctx context.Context, config hephaestus.LoggingConfiguration) error
- func (p *Processor) ProcessLogs(ctx context.Context, nodeID string, logs []string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LogEntry ¶
type LogEntry struct {
Timestamp time.Time
Level string
Message string
Context map[string]interface{}
StackTrace string
ProcessedAt time.Time
}
LogEntry represents a processed log entry
type LogStream ¶
type LogStream struct {
NodeID string
LogLevel string
OutputFormat string
Buffer []LogEntry
LastActivity time.Time
IsActive bool
}
LogStream represents an active log processing stream
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor implements the LogProcessingService interface
func NewProcessor ¶
func NewProcessor() *Processor
NewProcessor creates a new instance of the log processor
func (*Processor) ClearProcessedLogs ¶
ClearProcessedLogs clears processed log entries for a node
func (*Processor) CreateStream ¶
CreateStream creates a new log processing stream for a node
func (*Processor) GetProcessedLogs ¶
GetProcessedLogs retrieves processed log entries for a node
func (*Processor) Initialize ¶
func (p *Processor) Initialize(ctx context.Context, config hephaestus.LoggingConfiguration) error
Initialize sets up the log processor with the provided configuration
Source Files
Click to show internal directories.
Click to hide internal directories.