cluster

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.Command = actor.NewCommand(core.RedisCluster, "CommandUpdateAccount")
	CommandUpdateConfig                 = actor.NewCommand(core.RedisCluster, "CommandUpdateConfig")
	CommandEnsureResource               = actor.NewCommand(core.RedisCluster, "CommandEnsureResource")
	CommandHealPod                      = actor.NewCommand(core.RedisCluster, "CommandHealPod")
	CommandCleanResource                = actor.NewCommand(core.RedisCluster, "CommandCleanResource")
	CommandJoinNode                     = actor.NewCommand(core.RedisCluster, "CommandJoinNode")
	CommandEnsureSlots                  = actor.NewCommand(core.RedisCluster, "CommandEnsureSlots")
	CommandRebalance                    = actor.NewCommand(core.RedisCluster, "CommandRebalance")
)

Types

type RuleEngine

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

StatusGenerator

func NewRuleEngine

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

NewRuleEngine

func (*RuleEngine) Inspect

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

Inspect