processor

Documentation

Index

• Constants
• Variables
• type ProcessResult
• type Processor
  • func NewRuleProcessor(client client.Client, stage string, ...) *Processor
  • func (p *Processor) Process(targets map[string]*corev1.Pod) *ProcessResult
• type RejectInfo

Constants

const (
	EnvSkipTransitionRules = "SKIP_POD_TRANSITION_RULES"
)

Variables

var (
	SkipTransitionRules = sets.NewString()
)

Types

type ProcessResult

type ProcessResult struct {
	Rejected map[string]RejectInfo
	// pod:rules
	PassRules map[string]sets.String
	Retry     bool
	Interval  *time.Duration

	RuleStates []*appsv1alpha1.RuleState
}

type Processor

type Processor struct {
	register.Policy
	logr.Logger
	// contains filtered or unexported fields
}

func NewRuleProcessor

func NewRuleProcessor(client client.Client, stage string, podTransitionRule *appsv1alpha1.PodTransitionRule, log logr.Logger) *Processor

func (*Processor) Process

func (p *Processor) Process(targets map[string]*corev1.Pod) *ProcessResult

type RejectInfo

type RejectInfo struct {
	RuleName string
	Reason   string
}