ops

Documentation

Index

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

Constants

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

Variables

var (
	DepthKey       = contextDepthKey{}
	LastCommandKey = contextLastCommandKey{}
)

Types

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 client.Object) (ctrl.Result, error)

Run

type RuleEngine

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