logwriter

Documentation

Index

• Constants
• func DefaultLogMapper(ctx context.Context, msg *log.LogMessage) map[string]any
• func GetLogObjectType(logObj []any) string
• func GetObjectType(obj any) string
• func ParseLogObject(logObj []any, indent bool) string
• func ParseObject(fullMessage any, indent bool) string
• type ConsoleWriter
  • func NewConsoleWriter() *ConsoleWriter
  • func (c *ConsoleWriter) GetBufferSize() int
  • func (c *ConsoleWriter) Start(logChannel chan log.MuxLogMessage)
  • func (c *ConsoleWriter) WriteMessage(ctx context.Context, l *log.LogMessage) error
• type Endpoint
• type GraylogConfig
• type GraylogWriter
  • func NewGraylogTCP(errorLog log.LogWriter, c GraylogConfig) (*GraylogWriter, error)
  • func NewGraylogUDP(errorLog log.LogWriter, c GraylogConfig) (*GraylogWriter, error)
  • func (g *GraylogWriter) GetBufferSize() int
  • func (g *GraylogWriter) Start(logChannel chan log.MuxLogMessage)
  • func (g *GraylogWriter) WriteMessage(ctx context.Context, msg *log.LogMessage) (err error)
• type JSONLConsoleWriter
  • func NewJSONLConsoleWriter(mapper LogMapper) *JSONLConsoleWriter
  • func (c *JSONLConsoleWriter) WriteMessage(ctx context.Context, l *log.LogMessage) error
• type LogMapper
• type SyslogWriter
  • func NewSyslogWriterWriter(ctx context.Context, syslogTag, prefix string) *SyslogWriter
  • func (s *SyslogWriter) GetBufferSize() int
  • func (c *SyslogWriter) Start(logChannel chan log.MuxLogMessage)
  • func (c *SyslogWriter) WriteMessage(ctx context.Context, l *log.LogMessage) error
• type Transport

Constants

const ParseErrorMsg = "******************ERROR DURING MARSHAL OF FULL MESSAGE*******************"

const TimeFormat = "2006-01-02T15:04:05.000Z07:00"

Functions

func DefaultLogMapper

func DefaultLogMapper(ctx context.Context, msg *log.LogMessage) map[string]any

func GetLogObjectType

func GetLogObjectType(logObj []any) string

func GetObjectType

func GetObjectType(obj any) string

func ParseLogObject

func ParseLogObject(logObj []any, indent bool) string

func ParseObject

func ParseObject(fullMessage any, indent bool) string

Types

type ConsoleWriter

type ConsoleWriter struct {
}

func NewConsoleWriter

func NewConsoleWriter() *ConsoleWriter

func (*ConsoleWriter) GetBufferSize

func (c *ConsoleWriter) GetBufferSize() int

func (*ConsoleWriter) Start

func (c *ConsoleWriter) Start(logChannel chan log.MuxLogMessage)

func (*ConsoleWriter) WriteMessage

func (c *ConsoleWriter) WriteMessage(ctx context.Context, l *log.LogMessage) error

type Endpoint

type Endpoint struct {
	Transport Transport
	Address   string
	Port      uint
}

Endpoint represents a graylog endpoint

type GraylogConfig

type GraylogConfig struct {
	Host              string
	Version           string
	Address           string
	Port              int
	ShortMessageLimit uint
	LongMessageLimit  uint
}

type GraylogWriter

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

GraylogWriter represents an established graylog connection

func NewGraylogTCP

func NewGraylogTCP(errorLog log.LogWriter, c GraylogConfig) (*GraylogWriter, error)

func NewGraylogUDP

func NewGraylogUDP(errorLog log.LogWriter, c GraylogConfig) (*GraylogWriter, error)

func (*GraylogWriter) GetBufferSize

func (g *GraylogWriter) GetBufferSize() int

func (*GraylogWriter) Start

func (g *GraylogWriter) Start(logChannel chan log.MuxLogMessage)

func (*GraylogWriter) WriteMessage

func (g *GraylogWriter) WriteMessage(ctx context.Context, msg *log.LogMessage) (err error)

type JSONLConsoleWriter

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

func NewJSONLConsoleWriter

func NewJSONLConsoleWriter(mapper LogMapper) *JSONLConsoleWriter

func (*JSONLConsoleWriter) WriteMessage

func (c *JSONLConsoleWriter) WriteMessage(ctx context.Context, l *log.LogMessage) error

type LogMapper

type LogMapper func(context.Context, *log.LogMessage) map[string]any

type SyslogWriter

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

func NewSyslogWriterWriter

func NewSyslogWriterWriter(ctx context.Context, syslogTag, prefix string) *SyslogWriter

func (*SyslogWriter) GetBufferSize

func (s *SyslogWriter) GetBufferSize() int

func (*SyslogWriter) Start

func (c *SyslogWriter) Start(logChannel chan log.MuxLogMessage)

func (*SyslogWriter) WriteMessage

func (c *SyslogWriter) WriteMessage(ctx context.Context, l *log.LogMessage) error

type Transport

type Transport string

Transport represents a transport type enum

const (
	UDP Transport = "udp"
	TCP Transport = "tcp"
)