Documentation
¶
Index ¶
Constants ¶
View Source
const ( UPSTREAM_ERROR_SLEEP_INTERVAL = time.Second * 60 BUSY_UPSTREAMS_REPORT_INTERVAL = time.Second * 60 BUSY_UPSTREAMS_RETRY_INTERVAL = time.Millisecond * 100 )
View Source
const ( MAX_BYTES_TO_SEND = 1 << 22 // 4mb MAX_MESSAGES_TO_SEND = 50 // if batches are big then too many batches could cause OOM eventually )
View Source
const MIN_EVENT_BYTES_TO_COMPRESS = 1024 // only compress events larger than this size
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Balancer ¶
type Balancer struct {
InChan chan *lsdProto.RequestNewEventsEventT // incoming events (from fs)
// contains filtered or unexported fields
}
func NewBalancer ¶
type Encoder ¶
type Encoder interface {
Encode(*lsdProto.RequestNewEventsEventT) error
}
type EncoderGzip ¶
type EncoderGzip struct{}
func (*EncoderGzip) Encode ¶
func (e *EncoderGzip) Encode(ev *lsdProto.RequestNewEventsEventT) error
compresses event if enabled and not already compressed modifies event in place
type EncoderPlain ¶
type EncoderPlain struct{}
func (*EncoderPlain) Encode ¶
func (e *EncoderPlain) Encode(ev *lsdProto.RequestNewEventsEventT) error
Source Files
Click to show internal directories.
Click to hide internal directories.