ops

Documentation

Index

• Constants
• type ContextKeyType
• type OpEngine
  • func NewOpEngine(client client.Client, eventRecorder record.EventRecorder, ...) (*OpEngine, error)
  • func (e *OpEngine) Run(ctx context.Context, val interface{}) (ctrl.Result, error)
• type RuleEngine

Constants

const (
	MaxCallDepth                = 15
	DefaultRequeueDuration      = time.Second * 10
	DefaultAbortRequeueDuration = time.Minute
	PauseRequeueDuration        = time.Minute * 10
	DefaultReconcileTimeout     = time.Minute * 5
)

Types

type ContextKeyType

type ContextKeyType string

const (
	ContextKeyDepth       ContextKeyType = "depth"
	ContextKeyLastCommand ContextKeyType = "last_command"
)

type OpEngine

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

OpEngine

func NewOpEngine

func NewOpEngine(client client.Client, eventRecorder record.EventRecorder, manager *actor.ActorManager, logger logr.Logger) (*OpEngine, error)

NewOpEngine

func (*OpEngine) Run

func (e *OpEngine) Run(ctx context.Context, val interface{}) (ctrl.Result, error)

Run

type RuleEngine

type RuleEngine interface {
	Inspect(ctx context.Context, instance types.RedisInstance) *actor.ActorResult
}