metrics

package
v74.0.2+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 16, 2017 License: Apache-2.0, BSD-3-Clause, MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SinkManagerMetrics

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

func NewSinkManagerMetrics

func NewSinkManagerMetrics() *SinkManagerMetrics

func (*SinkManagerMetrics) Dec

func (s *SinkManagerMetrics) Dec(sink sinks.Sink)

func (*SinkManagerMetrics) DecFirehose

func (s *SinkManagerMetrics) DecFirehose()

func (*SinkManagerMetrics) Inc

func (s *SinkManagerMetrics) Inc(sink sinks.Sink)

func (*SinkManagerMetrics) IncFirehose

func (s *SinkManagerMetrics) IncFirehose()

func (*SinkManagerMetrics) Stop

func (s *SinkManagerMetrics) Stop()

func (*SinkManagerMetrics) UpdateDroppedMessageCount

func (s *SinkManagerMetrics) UpdateDroppedMessageCount(delta int64)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL