gelfudp

Documentation

Index

• Constants
• Variables
• func GuessIP() (uint64, error)
• func New(rawConfig *common.Config) (zapcore.WriteSyncer, error)
• type Compressor
  • func NewCompressor(compressionType string, compressionLevel int) (*Compressor, error)
  • func (c *Compressor) Compress(buf []byte) (int, []byte, error)
• type Config
• type DefaultIdGenerator
  • func NewDefaultIdGenerator(ip uint64) *DefaultIdGenerator
  • func (g *DefaultIdGenerator) NextId() uint64
• type IdGenerator
• type UDPSender
  • func NewUDPSender(address string) (*UDPSender, error)
  • func (s *UDPSender) Send(message []byte) error
• type Writer
  • func (w *Writer) Write(p []byte) (n int, err error)

Constants

const (
	MaxDatagramSize = 1420
	HeadSize        = 12
	MaxChunkSize    = MaxDatagramSize - HeadSize
	MaxChunks       = 128
	MaxMessageSize  = MaxChunkSize * MaxChunks

	CompressionNone = 0
	CompressionGzip = 1
	CompressionZlib = 2
)

Variables

var ErrTooLargeMessageSize = errors.New("too large message size")

var Magic = []byte{0x1e, 0x0f}

Functions

func GuessIP

func GuessIP() (uint64, error)

func New

func New(rawConfig *common.Config) (zapcore.WriteSyncer, error)

Types

type Compressor

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

func NewCompressor

func NewCompressor(compressionType string, compressionLevel int) (*Compressor, error)

func (*Compressor) Compress

func (c *Compressor) Compress(buf []byte) (int, []byte, error)

type Config

type Config struct {
	Host             string `logos-config:"host"`
	Port             int    `logos-config:"port"`
	CompressionType  string `logos-config:"compression_type" logos-validate:"logos.oneof=none gzip zlib"`
	CompressionLevel int    `logos-config:"compression_level"`
}

type DefaultIdGenerator

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

func NewDefaultIdGenerator

func NewDefaultIdGenerator(ip uint64) *DefaultIdGenerator

func (*DefaultIdGenerator) NextId

func (g *DefaultIdGenerator) NextId() uint64

type IdGenerator

type IdGenerator interface {
	NextId() uint64
}

type UDPSender

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

func NewUDPSender

func NewUDPSender(address string) (*UDPSender, error)

func (*UDPSender) Send

func (s *UDPSender) Send(message []byte) error

type Writer

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

func (*Writer) Write

func (w *Writer) Write(p []byte) (n int, err error)