sentinel

Documentation

Index

• Variables
• type RuleEngine
  • func NewRuleEngine(client kubernetes.ClientSet, eventRecorder record.EventRecorder, ...) (*RuleEngine, error)
  • func (g *RuleEngine) CheckMaster(ctx context.Context, st types.RedisFailoverInstance) *actor.ActorResult
  • func (g *RuleEngine) CheckRedisConfig(ctx context.Context, st types.RedisFailoverInstance) *actor.ActorResult
  • func (g *RuleEngine) CheckRedisLabels(ctx context.Context, st types.RedisInstance) *actor.ActorResult
  • func (g *RuleEngine) CheckRedisPasswordChange(ctx context.Context, st types.RedisFailoverInstance) *actor.ActorResult
  • func (g *RuleEngine) CheckSentinel(ctx context.Context, st types.RedisFailoverInstance) *actor.ActorResult
  • func (g *RuleEngine) FinallyCheck(ctx context.Context, st types.RedisFailoverInstance) *actor.ActorResult
  • func (g *RuleEngine) Inspect(ctx context.Context, val types.RedisInstance) *actor.ActorResult

Variables

var (
	CommandUpdateAccount  actor.Command = &sentinelCommand{typ: "SentinelCommandUpdateAccount"}
	CommandUpdateConfig                 = &sentinelCommand{typ: "SentinelCommandUpdateConfig"}
	CommandEnsureResource               = &sentinelCommand{typ: "SentinelCommandEnsureResource"}
	CommandHealPod                      = &sentinelCommand{typ: "SentinelCommandHealPod"}
	CommandCleanResource                = &sentinelCommand{typ: "SentinelCommandCleanResource"}

	CommandSentinelHeal = &sentinelCommand{typ: "SentinelCommandSentinelHeal"}
	CommandInitMaster   = &sentinelCommand{typ: "SentinelCommandInitMaster"}
	CommandHealMaster   = &sentinelCommand{typ: "SentinelCommandHealMaster"}
	CommandPatchLabels  = &sentinelCommand{typ: "SentinelCommandPatchLabels"}

	CommandRequeue = &sentinelCommand{typ: "SentinelCommandRequeue"}
	CommandAbort   = &sentinelCommand{typ: "SentinelCommandAbort"}
	CommandPaused  = &sentinelCommand{typ: "SentinelCommandPaused"}
)

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) CheckMaster

func (g *RuleEngine) CheckMaster(ctx context.Context, st types.RedisFailoverInstance) *actor.ActorResult

检测是否只有一个master

func (*RuleEngine) CheckRedisConfig

func (g *RuleEngine) CheckRedisConfig(ctx context.Context, st types.RedisFailoverInstance) *actor.ActorResult

func (*RuleEngine) CheckRedisLabels

func (g *RuleEngine) CheckRedisLabels(ctx context.Context, st types.RedisInstance) *actor.ActorResult

func (*RuleEngine) CheckRedisPasswordChange

func (g *RuleEngine) CheckRedisPasswordChange(ctx context.Context, st types.RedisFailoverInstance) *actor.ActorResult

func (*RuleEngine) CheckSentinel

func (g *RuleEngine) CheckSentinel(ctx context.Context, st types.RedisFailoverInstance) *actor.ActorResult

func (*RuleEngine) FinallyCheck

func (g *RuleEngine) FinallyCheck(ctx context.Context, st types.RedisFailoverInstance) *actor.ActorResult

最后比对数量是否相同

func (*RuleEngine) Inspect

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