metrics

Documentation

Index

• func FromShardedCluster(ctx context.Context, cluster *sharded.Cluster, refresh bool, resource string) error
• type SentinelMetricsGatherer
  • func NewSentinelMetricsGatherer(sentinelURI string, refreshInterval time.Duration, pool *redis.ServerPool) (*SentinelMetricsGatherer, error)
  • func (smg *SentinelMetricsGatherer) CanBeDeleted() bool
  • func (fw *SentinelMetricsGatherer) GetID() string
  • func (smg *SentinelMetricsGatherer) IsStarted() bool
  • func (fw *SentinelMetricsGatherer) SetChannel(ch chan event.GenericEvent)
  • func (smg *SentinelMetricsGatherer) Start(parentCtx context.Context, l logr.Logger) error
  • func (smg *SentinelMetricsGatherer) Stop()

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