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 (
	CommandUpdateAccount  actor.Command = &clusterCommand{typ: "CommandUpdateAccount"}
	CommandUpdateConfig                 = &clusterCommand{typ: "CommandUpdateConfig"}
	CommandEnsureResource               = &clusterCommand{typ: "CommandEnsureResource"}
	CommandHealPod                      = &clusterCommand{typ: "CommandHealPod"}
	CommandCleanResource                = &clusterCommand{typ: "CommandCleanResource"}

	CommandJoinNode    = &clusterCommand{typ: "CommandJoinNode"}
	CommandEnsureSlots = &clusterCommand{typ: "CommandEnsureSlots"}
	CommandRebalance   = &clusterCommand{typ: "CommandRebalance"}

	CommandRequeue = &clusterCommand{typ: "CommandRequeue"}
	CommandAbort   = &clusterCommand{typ: "CommandAbort"}
	CommandPaused  = &clusterCommand{typ: "CommandPaused"}
)

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