network

Documentation

Index

• Constants
• type Balancer
  • func NewBalancer(offsetsDb *offsets.Db, trafficManager *traffic.Manager, outBufferSize uint64, ...) *Balancer
  • func (b *Balancer) Start()
  • func (b *Balancer) Stop()
• type Encoder
• type EncoderGzip
  • func (e *EncoderGzip) Encode(ev *lsdProto.RequestNewEventsEventT) error
• type EncoderPlain
  • func (e *EncoderPlain) Encode(ev *lsdProto.RequestNewEventsEventT) error
• type IntHeap
  • func (h IntHeap) Len() int
  • func (h IntHeap) Less(i, j int) bool
  • func (h *IntHeap) Pop() interface{}
  • func (h *IntHeap) Push(x interface{})
  • func (h IntHeap) Swap(i, j int)

Constants

const (
	UPSTREAM_ERROR_SLEEP_INTERVAL  = time.Second * 60
	BUSY_UPSTREAMS_REPORT_INTERVAL = time.Second * 60
	BUSY_UPSTREAMS_RETRY_INTERVAL  = time.Millisecond * 100
)

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
)

const MIN_EVENT_BYTES_TO_COMPRESS = 1024 // only compress events larger than this size

Types

type Balancer

type Balancer struct {
	InChan chan *lsdProto.RequestNewEventsEventT // incoming events (from fs)
	// contains filtered or unexported fields
}

func NewBalancer

func NewBalancer(offsetsDb *offsets.Db, trafficManager *traffic.Manager, outBufferSize uint64, confRouting *lsdProto.LsdConfigClientConfigTRoutingConfigT) *Balancer

func (*Balancer) Start

func (b *Balancer) Start()

func (*Balancer) Stop

func (b *Balancer) Stop()

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

type IntHeap

type IntHeap []uint64

func (IntHeap) Len

func (h IntHeap) Len() int

func (IntHeap) Less

func (h IntHeap) Less(i, j int) bool

func (*IntHeap) Pop

func (h *IntHeap) Pop() interface{}

func (*IntHeap) Push

func (h *IntHeap) Push(x interface{})

func (IntHeap) Swap

func (h IntHeap) Swap(i, j int)