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)
Source Files
Click to show internal directories.
Click to hide internal directories.