Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Init ¶ added in v0.8.1
func Init(cfg *config.LogProcessorConfig) error
Types ¶
type LogCollector ¶
type LogCollector struct {
// contains filtered or unexported fields
}
LogCollector implements the collector.Collector interface for log collection
func GetInstance ¶
func GetInstance() *LogCollector
GetInstance returns the singleton instance of LogCollector
func (*LogCollector) CollectorName ¶
func (lc *LogCollector) CollectorName() string
CollectorName returns the unique name of the collector
func (*LogCollector) Disable ¶
func (lc *LogCollector) Disable()
func (*LogCollector) Enable ¶
func (lc *LogCollector) Enable()
func (*LogCollector) GetStatus ¶ added in v0.5.16
func (lc *LogCollector) GetStatus() ds.CollectorStatus
GetStatus returns the current status of the log collector
func (*LogCollector) OnNewConnection ¶ added in v0.8.1
func (lc *LogCollector) OnNewConnection()
OnNewConnection is called when a new connection is established
type LogStreamWriter ¶ added in v0.5.0
type LogStreamWriter struct {
// contains filtered or unexported fields
}
LogStreamWriter implements io.Writer to send logs to Outrig
func MakeLogStreamWriter ¶ added in v0.5.0
func MakeLogStreamWriter(name string) *LogStreamWriter
MakeLogStreamWriter creates a new LogStreamWriter
Source Files
Click to show internal directories.
Click to hide internal directories.