load

Documentation

Index

• Constants
• type CGMetrics
  • func NewCGMetrics() *CGMetrics
• 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
	// HostMetricMsgsOut represents count of outgoing messages per host
	HostMetricMsgsOut
	// HostMetricBytesOut represents count of outgoing bytes per host
	HostMetricBytesOut
)

const (
	// CGMetricNumOpenConns represents number of open conns per consumer group
	CGMetricNumOpenConns = iota
	// CGMetricNumOpenExtents represents number of open extents per consgroup
	CGMetricNumOpenExtents
	// CGMetricMsgsOut represents count of outgoing messages per consgroup
	CGMetricMsgsOut
	// CGMetricBytesOut represents count of outgoing bytes per consgroup
	CGMetricBytesOut
	// CGMetricSmartRetryOn is a 0/1 counter that represents if the smart retry is on/off
	CGMetricSmartRetryOn
)

const (
	// ExtentMetricMsgsOut represents count of outgoing messages per extent
	ExtentMetricMsgsOut = iota
	// ExtentMetricBytesOut represents count of outgoing bytes per extent
	ExtentMetricBytesOut
)

Types

type CGMetrics

type CGMetrics struct {
	*common.CounterBank
}

CGMetrics represents load metrics aggregated at a consumergroup level

func NewCGMetrics

func NewCGMetrics() *CGMetrics

NewCGMetrics returns a new instance of CGMetrics. Should be one instance per consumer group 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