sender

package
v2.6.3 Latest Latest
Warning

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

Go to latest
Published: Apr 8, 2024 License: MIT Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Informer

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

Informer allows to inspect metrics value stored in the registry at runtime

func NewInformer

func NewInformer() *Informer

NewInformer creates an Informer for the current registry

func (*Informer) GetSendMessageFailureCount

func (i *Informer) GetSendMessageFailureCount() (float64, error)

GetSendMessageFailureCount returns the total number of messages sent by the sender with success == false

type Recorder

type Recorder interface {
	Init(registerer prom.Registerer)
	IncSendMessageSuccessCount()
	IncSendMessageFailureCount()
}

Recorder allows to initialize the metric registry and increase/decrease the registered metrics at runtime.

var (

	// Metric exposes a Recorder interface to manipulate the Processor metrics.
	Metric Recorder = metricsRegistry
)

type Registry

type Registry struct {
	MessageSentCount *prom.CounterVec
}

func (*Registry) IncSendMessageFailureCount

func (m *Registry) IncSendMessageFailureCount()

IncSendMessageFailureCount increases the MessageSentCount metric with success == false

func (*Registry) IncSendMessageSuccessCount

func (m *Registry) IncSendMessageSuccessCount()

IncSendMessageSuccessCount increases the MessageSentCount metric with success == true

func (*Registry) Init

func (m *Registry) Init(reg prom.Registerer)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL