stats

Documentation

Index

• func NewClientSyncerStats(leafMetricNames map[message.NodeType]string) *clientSyncerStats
• type ClientSyncerStats
  • func NewNoOpStats() ClientSyncerStats
• type MessageMetric
  • func NewMessageMetric(name string) MessageMetric

Functions

func NewClientSyncerStats

func NewClientSyncerStats(leafMetricNames map[message.NodeType]string) *clientSyncerStats

NewClientSyncerStats returns stats for the client syncer

Types

type ClientSyncerStats

type ClientSyncerStats interface {
	GetMetric(message.Request) (MessageMetric, error)
}

func NewNoOpStats

func NewNoOpStats() ClientSyncerStats

type MessageMetric

type MessageMetric interface {
	IncRequested()
	IncSucceeded()
	IncFailed()
	IncInvalidResponse()
	IncReceived(int64)
	UpdateRequestLatency(time.Duration)
}

func NewMessageMetric

func NewMessageMetric(name string) MessageMetric