Versions in this module Expand all Collapse all v0 v0.0.1 Dec 29, 2017 Changes in this version + func NoopCompressor(w net.Conn) (io.ReadWriteCloser, error) + func SnappyCompressor(w net.Conn) (io.ReadWriteCloser, error) + type GzipLeveledCompressor int + func NewGzipLeveledCompressor(level int) *GzipLeveledCompressor + func (c GzipLeveledCompressor) NewWriter(w net.Conn) (io.ReadWriteCloser, error) + type NetWorker interface + GetStats func() *WorkerStats + IsAlive func() bool + Loop func() + TryConnect func() + type WorkerStats struct + ConnectErrors int64 + DroppedPoints int64 + MarshalErrors int64 + SendErrors int64 + SentPoints int64 + SpentTime int64
Go to main page