failover

Documentation

Index

• Variables
• type RuleEngine
  • func NewRuleEngine(client kubernetes.ClientSet, eventRecorder record.EventRecorder, ...) (*RuleEngine, error)
  • func (g *RuleEngine) Inspect(ctx context.Context, val types.RedisInstance) *actor.ActorResult

Variables

var (
	CommandRequeue = actor.CommandRequeue
	CommandAbort   = actor.CommandAbort
	CommandPaused  = actor.CommandPaused

	CommandUpdateAccount  = actor.NewCommand(core.RedisSentinel, "CommandUpdateAccount")
	CommandUpdateConfig   = actor.NewCommand(core.RedisSentinel, "CommandUpdateConfig")
	CommandEnsureResource = actor.NewCommand(core.RedisSentinel, "CommandEnsureResource")
	CommandHealPod        = actor.NewCommand(core.RedisSentinel, "CommandHealPod")
	CommandHealMonitor    = actor.NewCommand(core.RedisSentinel, "CommandHealMonitor")
	CommandPatchLabels    = actor.NewCommand(core.RedisSentinel, "CommandPatchLabels")
	CommandCleanResource  = actor.NewCommand(core.RedisSentinel, "CommandCleanResource")

	// 3.16 compatibility
	CommandInitMaster   = actor.NewCommand(core.RedisSentinel, "CommandInitMaster")
	CommandHealMaster   = actor.NewCommand(core.RedisSentinel, "CommandHealMaster")
	CommandSentinelHeal = actor.NewCommand(core.RedisSentinel, "CommandSentinelHeal")
)

Types

type RuleEngine

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

func NewRuleEngine

func NewRuleEngine(client kubernetes.ClientSet, eventRecorder record.EventRecorder, logger logr.Logger) (*RuleEngine, error)

func (*RuleEngine) Inspect

func (g *RuleEngine) Inspect(ctx context.Context, val types.RedisInstance) *actor.ActorResult