log_collector

Documentation

Index

• type LogCollector
  • func NewLogCollector(config LogCollectorConfig) *LogCollector
  • func (s *LogCollector) Send(log *log_models.Log)
  • func (s *LogCollector) Start()
  • func (s *LogCollector) Stop()
• type LogCollectorConfig

Types

type LogCollector

type LogCollector struct {
	// contains filtered or unexported fields
}

func NewLogCollector

func NewLogCollector(config LogCollectorConfig) *LogCollector

func (*LogCollector) Send

func (s *LogCollector) Send(log *log_models.Log)

func (*LogCollector) Start

func (s *LogCollector) Start()

func (*LogCollector) Stop

func (s *LogCollector) Stop()

type LogCollectorConfig

type LogCollectorConfig struct {
	Sock         string
	ChanSize     int
	WorkerNumber int
	Logger       logger.Logger
}