util

Documentation

Index

• type InterfaceBuffer
  • func NewInterfaceBuffer(size int) *InterfaceBuffer
  • func (mb *InterfaceBuffer) Clear()
  • func (mb *InterfaceBuffer) Get(i int) interface{}
  • func (mb *InterfaceBuffer) Len() int
  • func (mb *InterfaceBuffer) ReadNext() (p interface{}, eof bool, err error)
  • func (mb *InterfaceBuffer) Scan(pos int)
  • func (mb *InterfaceBuffer) Write(p interface{}) (err error)
• type MemoryBuffer
  • func NewMemoryBuffer(size int) *MemoryBuffer
  • func (mb *MemoryBuffer) ByteSize() int
  • func (mb *MemoryBuffer) Clear()
  • func (mb *MemoryBuffer) Len() int
  • func (mb *MemoryBuffer) ReadNext() (p []byte, eof bool, err error)
  • func (mb *MemoryBuffer) Scan(pos int)
  • func (mb *MemoryBuffer) Stop()
  • func (mb *MemoryBuffer) Write(p []byte) (n int, err error)
• type MetricsGroup
• type SequentialBuffer
  • func NewSequentialBufferChanImpl(maxItems int) SequentialBuffer
• type SequentialBufferChanImpl
  • func (buf *SequentialBufferChanImpl) Ack(seq int) uint
  • func (buf *SequentialBufferChanImpl) Add(payload []byte) (seq int, err error)
  • func (buf *SequentialBufferChanImpl) CanAdd() bool
  • func (buf *SequentialBufferChanImpl) Len() int
  • func (buf *SequentialBufferChanImpl) Reset() [][]byte
• type StreamingMetrics
  • func NewStreamingMetrics(mReg metrics.Registry) *StreamingMetrics
  • func (m *StreamingMetrics) Error(op *string)
  • func (m *StreamingMetrics) Event(op *string)
  • func (m *StreamingMetrics) Register(op string)
  • func (m *StreamingMetrics) Update(op *string, v int)

Types

type InterfaceBuffer

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

func NewInterfaceBuffer

func NewInterfaceBuffer(size int) *InterfaceBuffer

func (*InterfaceBuffer) Clear

func (mb *InterfaceBuffer) Clear()

func (*InterfaceBuffer) Get

func (mb *InterfaceBuffer) Get(i int) interface{}

func (*InterfaceBuffer) Len

func (mb *InterfaceBuffer) Len() int

func (*InterfaceBuffer) ReadNext

func (mb *InterfaceBuffer) ReadNext() (p interface{}, eof bool, err error)

func (*InterfaceBuffer) Scan

func (mb *InterfaceBuffer) Scan(pos int)

func (*InterfaceBuffer) Write

func (mb *InterfaceBuffer) Write(p interface{}) (err error)

type MemoryBuffer

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

func NewMemoryBuffer

func NewMemoryBuffer(size int) *MemoryBuffer

func (*MemoryBuffer) ByteSize

func (mb *MemoryBuffer) ByteSize() int

func (*MemoryBuffer) Clear

func (mb *MemoryBuffer) Clear()

func (*MemoryBuffer) Len

func (mb *MemoryBuffer) Len() int

func (*MemoryBuffer) ReadNext

func (mb *MemoryBuffer) ReadNext() (p []byte, eof bool, err error)

func (*MemoryBuffer) Scan

func (mb *MemoryBuffer) Scan(pos int)

func (*MemoryBuffer) Stop

func (mb *MemoryBuffer) Stop()

func (*MemoryBuffer) Write

func (mb *MemoryBuffer) Write(p []byte) (n int, err error)

type MetricsGroup

type MetricsGroup struct {
	Events      metrics.Counter
	Errors      metrics.Counter
	QueueLength metrics.Gauge
}

type SequentialBuffer

type SequentialBuffer interface {
	CanAdd() bool
	Add(payload []byte) (seq int, err error)
	Ack(seq int) uint
	//Unacked() [][]byte //guaranteed only on first call
	Len() int
	Reset() [][]byte
}

func NewSequentialBufferChanImpl

func NewSequentialBufferChanImpl(maxItems int) SequentialBuffer

type SequentialBufferChanImpl

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

func (*SequentialBufferChanImpl) Ack

func (buf *SequentialBufferChanImpl) Ack(seq int) uint

func (*SequentialBufferChanImpl) Add

func (buf *SequentialBufferChanImpl) Add(payload []byte) (seq int, err error)

func (*SequentialBufferChanImpl) CanAdd

func (buf *SequentialBufferChanImpl) CanAdd() bool

func (*SequentialBufferChanImpl) Len

func (buf *SequentialBufferChanImpl) Len() int

func (*SequentialBufferChanImpl) Reset

func (buf *SequentialBufferChanImpl) Reset() [][]byte

type StreamingMetrics

type StreamingMetrics struct {
	Reg       metrics.Registry
	OpGroups  map[string]MetricsGroup // Each Op can have an associated metrics group
	StartTime int64                   // How long we've been running for
}

func NewStreamingMetrics

func NewStreamingMetrics(mReg metrics.Registry) *StreamingMetrics

func (*StreamingMetrics) Error

func (m *StreamingMetrics) Error(op *string)

func (*StreamingMetrics) Event

func (m *StreamingMetrics) Event(op *string)

func (*StreamingMetrics) Register

func (m *StreamingMetrics) Register(op string)

func (*StreamingMetrics) Update

func (m *StreamingMetrics) Update(op *string, v int)