metrics

Documentation

Index

• Constants
• type ActorMetrics
  • func NewActorMetrics(logger *slog.Logger) *ActorMetrics
  • func (am *ActorMetrics) SetActorMailboxLengthGauge(gauge metric.Int64ObservableGauge)
• type ProtoMetrics
  • func NewProtoMetrics(logger *slog.Logger) *ProtoMetrics
  • func (pm *ProtoMetrics) Get(key string) *ActorMetrics
  • func (pm *ProtoMetrics) Instruments() *ActorMetrics
  • func (pm *ProtoMetrics) Register(key string, instance *ActorMetrics)

Constants

const InternalActorMetrics string = "internal.actor.metrics"

const LibName string = "protoactor"

Types

type ActorMetrics

type ActorMetrics struct {

	// MetricsID
	ID string

	// Actors
	ActorFailureCount            metric.Int64Counter
	ActorMailboxLength           metric.Int64ObservableGauge
	ActorMessageReceiveHistogram metric.Float64Histogram
	ActorRestartedCount          metric.Int64Counter
	ActorSpawnCount              metric.Int64Counter
	ActorStoppedCount            metric.Int64Counter

	// Deadletters
	DeadLetterCount metric.Int64Counter

	// Futures
	FuturesStartedCount   metric.Int64Counter
	FuturesCompletedCount metric.Int64Counter
	FuturesTimedOutCount  metric.Int64Counter

	// Threadpool
	ThreadPoolLatency metric.Int64Histogram
	// contains filtered or unexported fields
}

func NewActorMetrics

func NewActorMetrics(logger *slog.Logger) *ActorMetrics

NewActorMetrics creates a new ActorMetrics value and returns a pointer to it

func (*ActorMetrics) SetActorMailboxLengthGauge

func (am *ActorMetrics) SetActorMailboxLengthGauge(gauge metric.Int64ObservableGauge)

SetActorMailboxLengthGauge makes sure access to ActorMailboxLength is sequenced

type ProtoMetrics

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

func NewProtoMetrics

func NewProtoMetrics(logger *slog.Logger) *ProtoMetrics

func (*ProtoMetrics) Get

func (pm *ProtoMetrics) Get(key string) *ActorMetrics

func (*ProtoMetrics) Instruments

func (pm *ProtoMetrics) Instruments() *ActorMetrics

func (*ProtoMetrics) Register

func (pm *ProtoMetrics) Register(key string, instance *ActorMetrics)