workers

Documentation

Index

• func NoopCompressor(w net.Conn) (io.ReadWriteCloser, error)
• func SnappyCompressor(w net.Conn) (io.ReadWriteCloser, error)
• type GzipLeveledCompressor
  • func NewGzipLeveledCompressor(level int) *GzipLeveledCompressor
  • func (c GzipLeveledCompressor) NewWriter(w net.Conn) (io.ReadWriteCloser, error)
• type NetWorker
• type WorkerStats

Functions

func NoopCompressor

func NoopCompressor(w net.Conn) (io.ReadWriteCloser, error)

func SnappyCompressor

func SnappyCompressor(w net.Conn) (io.ReadWriteCloser, error)

Types

type GzipLeveledCompressor

type GzipLeveledCompressor int

func NewGzipLeveledCompressor

func NewGzipLeveledCompressor(level int) *GzipLeveledCompressor

func (GzipLeveledCompressor) NewWriter

func (c GzipLeveledCompressor) NewWriter(w net.Conn) (io.ReadWriteCloser, error)

type NetWorker

type NetWorker interface {
	TryConnect()
	IsAlive() bool
	Loop()
	GetStats() *WorkerStats
}

type WorkerStats

type WorkerStats struct {
	SpentTime     int64
	SentPoints    int64
	SendErrors    int64
	MarshalErrors int64
	ConnectErrors int64
	DroppedPoints int64
}