Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchChainByteWriter ¶
type BatchChainByteWriter interface {
Write(message []byte, chainers ...metricbatcher.BatchCounterChainer) (sentLength int, err error)
}
type BatchCounterIncrementer ¶
type BatchCounterIncrementer interface {
BatchIncrementCounter(name string)
}
type DroppedCounter ¶
type DroppedCounter struct {
// contains filtered or unexported fields
}
func NewDroppedCounter ¶
func NewDroppedCounter(byteWriter BatchChainByteWriter, incrementer BatchCounterIncrementer, origin, ip string, conf *config.Config) *DroppedCounter
func (*DroppedCounter) Drop ¶
func (d *DroppedCounter) Drop(n uint32)
func (*DroppedCounter) Dropped ¶
func (d *DroppedCounter) Dropped() int64
type DroppedMessageCounter ¶
type DroppedMessageCounter interface {
Drop(count uint32)
}
type Writer ¶
type Writer struct {
// contains filtered or unexported fields
}
func NewWriter ¶
func NewWriter(protocol string, writer BatchChainByteWriter, droppedCounter DroppedMessageCounter, bufferCapacity uint64, flushDuration time.Duration) (*Writer, error)
func (*Writer) Write ¶
func (w *Writer) Write(msgBytes []byte, chainers ...metricbatcher.BatchCounterChainer) (int, error)
Source Files
Click to show internal directories.
Click to hide internal directories.