logwriter

package
v5.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 5, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const ParseErrorMsg = "******************ERROR DURING MARSHAL OF FULL MESSAGE*******************"
View Source
const TimeFormat = "2006-01-02T15:04:05.000Z07:00"

Variables

This section is empty.

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"
)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL