load

Documentation

Index

• Constants
• type DstMetrics
  • func NewDstMetrics() *DstMetrics
• type ExtentMetrics
  • func NewExtentMetrics() *ExtentMetrics
• type HostMetrics
  • func NewHostMetrics() *HostMetrics

Constants

const (
	// HostMetricNumOpenConns represents number of open conns per host
	HostMetricNumOpenConns = iota
	// HostMetricNumOpenExtents represents number of open extents per host
	HostMetricNumOpenExtents
	// HostMetricMsgsIn represents count of incoming messages per host
	HostMetricMsgsIn
	// HostMetricBytesIn represents count of incoming bytes per host
	HostMetricBytesIn
)

const (
	// DstMetricNumOpenConns represents number of open conns per dst
	DstMetricNumOpenConns = iota
	// DstMetricNumOpenExtents represents number of open extents per dst
	DstMetricNumOpenExtents
	// DstMetricNumWritableExtents represents number of open and *writable* extents per dst
	// A draining extent will decrement this and this is used to trigger client connection drain
	DstMetricNumWritableExtents
	// DstMetricMsgsIn represents count of incoming messages per dst
	DstMetricMsgsIn
	// DstMetricBytesIn represents count of incoming bytes per dst
	DstMetricBytesIn
	// DstMetricNumAcks represents count of number of acked messages per dst
	DstMetricNumAcks
	// DstMetricNumNacks represents count of number of nacked messages per dst
	DstMetricNumNacks
	// DstMetricNumThrottled represents count of number of throttled messages per dst
	DstMetricNumThrottled
	// DstMetricNumFailed represents count of number of failed messages per dst
	DstMetricNumFailed
	// DstMetricOverallNumMsgs represents count of the overall number of messages per dst
	// Note: this is different than the MsgsIn above since that maintains the per second msgs
	DstMetricOverallNumMsgs
)

const (
	// ExtentMetricMsgsIn represents count of incoming messages per extent
	ExtentMetricMsgsIn = iota
	// ExtentMetricBytesIn represents count of incoming bytes per extent
	ExtentMetricBytesIn
)

Types

type DstMetrics

type DstMetrics struct {
	*common.CounterBank
}

DstMetrics represents load metrics aggregated at a destination level

func NewDstMetrics

func NewDstMetrics() *DstMetrics

NewDstMetrics returns a new instance of DstMetrics. Should be one instance per destination UUID

type ExtentMetrics

type ExtentMetrics struct {
	*common.CounterBank
}

ExtentMetrics represents load metrics that are aggregated at extent level

func NewExtentMetrics

func NewExtentMetrics() *ExtentMetrics

NewExtentMetrics returns a new instance of ExtentMetrics. Should be one instance per extent uuid.

type HostMetrics

type HostMetrics struct {
	*common.CounterBank
}

HostMetrics represents the load metrics that are aggregated at the input host level

func NewHostMetrics

func NewHostMetrics() *HostMetrics

NewHostMetrics returns a new instance of input host level load metrics. Should be one instance per input host