metrics

package
v0.25.1 Latest Latest
Warning

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

Go to latest
Published: Sep 9, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromShardedCluster

func FromShardedCluster(ctx context.Context, cluster *sharded.Cluster, refresh bool, resource string) error

Types

type SentinelMetricsGatherer

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

SentinelMetricsGatherer is used to export sentinel metrics, obtained thrugh several admin commands, as prometheus metrics

func NewSentinelMetricsGatherer

func NewSentinelMetricsGatherer(sentinelURI string, refreshInterval time.Duration, pool *redis.ServerPool) (*SentinelMetricsGatherer, error)

func (*SentinelMetricsGatherer) CanBeDeleted

func (smg *SentinelMetricsGatherer) CanBeDeleted() bool

func (*SentinelMetricsGatherer) GetID

func (fw *SentinelMetricsGatherer) GetID() string

func (*SentinelMetricsGatherer) IsStarted

func (smg *SentinelMetricsGatherer) IsStarted() bool

IsStarted returns whether the metrics gatherer is running or not

func (*SentinelMetricsGatherer) SetChannel

func (fw *SentinelMetricsGatherer) SetChannel(ch chan event.GenericEvent)

SetChannel is required for SentinelMetricsGatherer to implement the RunnableThread interface, but it actually does nothing with the channel.

func (*SentinelMetricsGatherer) Start

func (smg *SentinelMetricsGatherer) Start(parentCtx context.Context, l logr.Logger) error

Start starts metrics gatherer for sentinel

func (*SentinelMetricsGatherer) Stop

func (smg *SentinelMetricsGatherer) Stop()

Stop stops metrics gatherering for sentinel

Jump to

Keyboard shortcuts

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