metrics

package
v1.6.2-rc Latest Latest
Warning

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

 Go to latest Published: May 24, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// RpcLatency the latency of rpc call.
	RpcLatency = prometheus.NewSummaryVec(
		prometheus.SummaryOpts{
			Name: "rpc_latency_ms",
			Help: "cello rpc call latency in ms",
		},
		[]string{"rpc_api", "error"},
	)

	// ResourceManagerErr error counter of resource manager.
	ResourceManagerErr = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: "resource_manager_error_count",
			Help: "The number of errors encountered in eni manager",
		},
		[]string{"fn", "error"},
	)
)
View Source 
var (
	// OpenAPILatency latency of openapi call.
	OpenAPILatency = prometheus.NewSummaryVec(
		prometheus.SummaryOpts{
			Name: "openapi_latency_ms",
			Help: "cello openapi call latency in ms",
		},
		[]string{"api", "error", "code", "requestId"},
	)

	// OpenAPIErr error counter of openapi call.
	OpenAPIErr = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: "openapi_error_count",
			Help: "The number of times openapi returns an error",
		},
		[]string{"api", "error", "code", "requestId"},
	)

	// MetadataLatency latency of metadata call.
	MetadataLatency = prometheus.NewSummaryVec(
		prometheus.SummaryOpts{
			Name: "metadata_latency_ms",
			Help: "cello metadata call latency in ms",
		},
		[]string{"metadata", "error", "status"},
	)

	// MetadataErr error counter of metadata call.
	MetadataErr = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: "metadata_error_count",
			Help: "The number of times metadata returns an error",
		},
		[]string{"metadata", "error"},
	)
)
View Source 
var (
	// ResourcePoolMaxCap Gauge of resource pool maximum capacity.
	ResourcePoolMaxCap = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Name: "resource_pool_max_cap",
			Help: "The max capacity of resource pool"},
		[]string{"name", "type"},
	)

	// ResourcePoolTarget Gauge of resource pool target.
	ResourcePoolTarget = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Name: "resource_pool_target",
			Help: "The cache target of resource pool"},
		[]string{"name", "type"},
	)

	// ResourcePoolTargetMin Gauge of resource pool targetMin.
	ResourcePoolTargetMin = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Name: "resource_pool_target_min",
			Help: "The min cache target of resource pool"},
		[]string{"name", "type"},
	)

	// ResourcePoolTotal Gauge of total resources in resource pool.
	ResourcePoolTotal = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Name: "resource_pool_total",
			Help: "The total number of resource in pool"},
		[]string{"name", "type"},
	)

	// ResourcePoolAvailable Gauge of available resources in resource pool.
	ResourcePoolAvailable = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Name: "resource_pool_available",
			Help: "The available number of resource in pool"},
		[]string{"name", "type"},
	)
)

Functions

func CelloReqErrCode 

func CelloReqErrCode(err error) string

CelloReqErrCode return error code of api request.

func CelloReqId 

func CelloReqId(err error) string

CelloReqId return requestId of api request.

func MetadataErrInc 

func MetadataErrInc(metadata string, err error)

MetadataErrInc help to increment count of MetadataErr.

func MsSince 

func MsSince(start time.Time) float64

MsSince returns milliseconds since start.

func OpenAPIErrInc 

func OpenAPIErrInc(api string, err error)

OpenAPIErrInc help to increment count of OpenAPIErr.

func PrometheusRegister 

func PrometheusRegister()

func ResourceManagerErrInc 

func ResourceManagerErrInc(fn string, err error)

func ServeMetrics 

func ServeMetrics(serveMux *http.ServeMux)

ServeMetrics sets up cello metrics.

Types

type MetricEC2Wrapper 

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

MetricEC2Wrapper wrapper the ec2.EC2 for metrics.

func NewMetricEC2Wrapper 

func NewMetricEC2Wrapper(p ec2.EC2) *MetricEC2Wrapper

func (*MetricEC2Wrapper) AssignIpv6Addresses 

func (m *MetricEC2Wrapper) AssignIpv6Addresses(req *ec2.AssignIpv6AddressesInput) (*ec2.AssignIpv6AddressesOutput, error)

func (*MetricEC2Wrapper) AssignPrivateIpAddress 

func (m *MetricEC2Wrapper) AssignPrivateIpAddress(req *vpc.AssignPrivateIpAddressesInput) (*vpc.AssignPrivateIpAddressesOutput, error)

func (*MetricEC2Wrapper) AttachNetworkInterface 

func (m *MetricEC2Wrapper) AttachNetworkInterface(req *vpc.AttachNetworkInterfaceInput) (*vpc.AttachNetworkInterfaceOutput, error)

func (*MetricEC2Wrapper) CreateNetworkInterface 

func (m *MetricEC2Wrapper) CreateNetworkInterface(req *ec2.CreateNetworkInterfaceInput) (*vpc.CreateNetworkInterfaceOutput, error)

func (*MetricEC2Wrapper) DeleteNetworkInterface 

func (m *MetricEC2Wrapper) DeleteNetworkInterface(req *vpc.DeleteNetworkInterfaceInput) (*vpc.DeleteNetworkInterfaceOutput, error)

func (*MetricEC2Wrapper) DescribeInstanceTypes 

func (m *MetricEC2Wrapper) DescribeInstanceTypes(req *ecs.DescribeInstanceTypesInput) (*ec2.DescribeInstanceTypesOutput, error)

func (*MetricEC2Wrapper) DescribeInstances 

func (m *MetricEC2Wrapper) DescribeInstances(req *ecs.DescribeInstancesInput) (*ecs.DescribeInstancesOutput, error)

func (*MetricEC2Wrapper) DescribeNetworkInterfaceAttributes 

func (m *MetricEC2Wrapper) DescribeNetworkInterfaceAttributes(req *vpc.DescribeNetworkInterfaceAttributesInput) (*ec2.DescribeNetworkInterfaceAttributesOutput, error)

func (*MetricEC2Wrapper) DescribeNetworkInterfaces 

func (m *MetricEC2Wrapper) DescribeNetworkInterfaces(req *vpc.DescribeNetworkInterfacesInput) (*ec2.DescribeNetworkInterfacesOutput, error)

func (*MetricEC2Wrapper) DescribeSubnetAttributes 

func (m *MetricEC2Wrapper) DescribeSubnetAttributes(req *vpc.DescribeSubnetAttributesInput) (*ec2.DescribeSubnetAttributesOutput, error)

func (*MetricEC2Wrapper) DescribeSubnets 

func (m *MetricEC2Wrapper) DescribeSubnets(req *vpc.DescribeSubnetsInput) (*ec2.DescribeSubnetsOutput, error)

func (*MetricEC2Wrapper) DetachNetworkInterface 

func (m *MetricEC2Wrapper) DetachNetworkInterface(req *vpc.DetachNetworkInterfaceInput) (*vpc.DetachNetworkInterfaceOutput, error)

func (*MetricEC2Wrapper) UnAssignPrivateIpAddress 

func (m *MetricEC2Wrapper) UnAssignPrivateIpAddress(req *vpc.UnassignPrivateIpAddressesInput) (*vpc.UnassignPrivateIpAddressesOutput, error)

func (*MetricEC2Wrapper) UnassignIpv6Addresses 

func (m *MetricEC2Wrapper) UnassignIpv6Addresses(req *ec2.UnassignIpv6AddressesInput) (*ec2.UnassignIpv6AddressesOutput, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.