Documentation
¶
Index ¶
- type RedisConfig
- type RedisEventMessage
- type RedisInstanceDetails
- type SentinelEventWatcher
- func (sew *SentinelEventWatcher) CanBeDeleted() bool
- func (sew *SentinelEventWatcher) Cleanup() error
- func (sew *SentinelEventWatcher) GetID() string
- func (sew *SentinelEventWatcher) IsStarted() bool
- func (sew *SentinelEventWatcher) SetChannel(ch chan event.GenericEvent)
- func (sew *SentinelEventWatcher) Start(parentCtx context.Context, l logr.Logger) error
- func (sew *SentinelEventWatcher) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisConfig ¶
type RedisConfig struct {
// contains filtered or unexported fields
}
type RedisEventMessage ¶
type RedisEventMessage struct {
// contains filtered or unexported fields
}
func NewRedisEventMessage ¶
func NewRedisEventMessage(msg *goredis.Message) (RedisEventMessage, error)
type RedisInstanceDetails ¶
type RedisInstanceDetails struct {
// contains filtered or unexported fields
}
type SentinelEventWatcher ¶
type SentinelEventWatcher struct {
// contains filtered or unexported fields
}
func NewSentinelEventWatcher ¶
func NewSentinelEventWatcher(sentinelURI string, instance client.Object, topology *sharded.Cluster, metrics bool, pool *redis.ServerPool) (*SentinelEventWatcher, error)
func (*SentinelEventWatcher) CanBeDeleted ¶
func (sew *SentinelEventWatcher) CanBeDeleted() bool
func (*SentinelEventWatcher) Cleanup ¶
func (sew *SentinelEventWatcher) Cleanup() error
func (*SentinelEventWatcher) GetID ¶
func (sew *SentinelEventWatcher) GetID() string
func (*SentinelEventWatcher) IsStarted ¶
func (sew *SentinelEventWatcher) IsStarted() bool
IsStarted returns whether the metrics gatherer is running or not
func (*SentinelEventWatcher) SetChannel ¶
func (sew *SentinelEventWatcher) SetChannel(ch chan event.GenericEvent)
func (*SentinelEventWatcher) Stop ¶
func (sew *SentinelEventWatcher) Stop()
Stop stops the sentinel event watcher
Source Files
Click to show internal directories.
Click to hide internal directories.