category

Documentation

Index

• Constants
• type ChunkedWriter
  • func NewChunkedWriter(baseDir, cname, cpath string, settings Settings, ...) *ChunkedWriter
  • func (w *ChunkedWriter) Close() error
  • func (w *ChunkedWriter) Flush() error
  • func (w *ChunkedWriter) Prepare() error
  • func (w *ChunkedWriter) Rotate() error
  • func (w *ChunkedWriter) Write(event *Event) (bool, error)
• type Event
• type PlainWriter
  • func NewPlainWriter(cname, cpath string, settings Settings, trafficManager *traffic.Manager) *PlainWriter
  • func (w *PlainWriter) Close() error
  • func (w *PlainWriter) Flush() error
  • func (w *PlainWriter) Prepare() error
  • func (w *PlainWriter) Rotate() error
  • func (w *PlainWriter) Write(event *Event) (bool, error)
• type Settings
• type Writer

Constants

const CHUNKED_CATEGORY_READ_DIR_BUFFER_SIZE = 1000

const CHUNKED_EVENTS_BUFFER_SIZE = 1000

const DATE_FORMAT = "2006-01-02"

const EXTENSION_GZIP = ".gz"

const WRITE_BUFFER_SIZE = 1 << 20 // 1mb

Types

type ChunkedWriter

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

func NewChunkedWriter

func NewChunkedWriter(baseDir, cname, cpath string, settings Settings, trafficManager *traffic.Manager) *ChunkedWriter

func (*ChunkedWriter) Close

func (w *ChunkedWriter) Close() error

func (*ChunkedWriter) Flush

func (w *ChunkedWriter) Flush() error

func (*ChunkedWriter) Prepare

func (w *ChunkedWriter) Prepare() error

func (*ChunkedWriter) Rotate

func (w *ChunkedWriter) Rotate() error

func (*ChunkedWriter) Write

func (w *ChunkedWriter) Write(event *Event) (bool, error)

type Event

type Event struct {
	*lsd.RequestNewEventsEventT
	AnswerCh chan *lsd.ResponseOffsetsOffsetT
}

type PlainWriter

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

func NewPlainWriter

func NewPlainWriter(cname, cpath string, settings Settings, trafficManager *traffic.Manager) *PlainWriter

func (*PlainWriter) Close

func (w *PlainWriter) Close() error

func (*PlainWriter) Flush

func (w *PlainWriter) Flush() error

func (*PlainWriter) Prepare

func (w *PlainWriter) Prepare() error

func (*PlainWriter) Rotate

func (w *PlainWriter) Rotate() error

func (*PlainWriter) Write

func (w *PlainWriter) Write(event *Event) (bool, error)

type Settings

type Settings struct {
	Mode               lsd.LsdConfigServerConfigTWriteMode
	Patterns           []*regexp.Regexp
	MaxFileSize        uint64
	FileRotateInterval uint64
	Gzip               bool
	GzipParallel       uint64
}

type Writer

type Writer interface {
	Prepare() error
	Write(*Event) (bool, error) // (rotated after write, error)
	Rotate() error
	Flush() error
	Close() error
}