log4j2

Documentation

Index

• type Log4j2SocketEvent
• type Log4j2SocketEventInstant
• type Log4j2SocketProcessor
  • func NewLog4j2SocketProcessor(config Log4j2SocketProcessorConfig, ledgerWriter backends.LedgerWriter) *Log4j2SocketProcessor
  • func (m *Log4j2SocketProcessor) ParseCommand(bytes []byte) *processors.LogEvent
  • func (m *Log4j2SocketProcessor) ProcessConnection(conn net.Conn) error
  • func (m *Log4j2SocketProcessor) Start()
  • func (m *Log4j2SocketProcessor) Stop()
• type Log4j2SocketProcessorConfig

Types

type Log4j2SocketEvent

type Log4j2SocketEvent struct {
	LoggerName string                   `json:"loggerName"`
	Message    string                   `json:"message"`
	Instant    Log4j2SocketEventInstant `json:"instant"`
	ContextMap map[string]interface{}   `json:"contextMap"`
}

type Log4j2SocketEventInstant

type Log4j2SocketEventInstant struct {
	Timestamp int64 `json:"epochSecond"`
}

type Log4j2SocketProcessor

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

func NewLog4j2SocketProcessor

func NewLog4j2SocketProcessor(config Log4j2SocketProcessorConfig, ledgerWriter backends.LedgerWriter) *Log4j2SocketProcessor

func (*Log4j2SocketProcessor) ParseCommand

func (m *Log4j2SocketProcessor) ParseCommand(bytes []byte) *processors.LogEvent

func (*Log4j2SocketProcessor) ProcessConnection

func (m *Log4j2SocketProcessor) ProcessConnection(conn net.Conn) error

func (*Log4j2SocketProcessor) Start

func (m *Log4j2SocketProcessor) Start()

func (*Log4j2SocketProcessor) Stop

func (m *Log4j2SocketProcessor) Stop()

type Log4j2SocketProcessorConfig

type Log4j2SocketProcessorConfig struct {
	IdleConnectionTimeout time.Duration
}