failover

package

v1.0.0 Latest Latest Go to latest Published: Jun 5, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/chideat/valkey-operator

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

This section is empty.

Variables ¶

View Source

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

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

Functions ¶

This section is empty.

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.Instance) *actor.ActorResult

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
actor

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