register

Documentation

Index

• Variables
• func DefaultInit()
• func GetRuleStage(ruleDef *appsv1alpha1.TransitionRuleDefinition) string
• func GetRuleType(ruleDef *appsv1alpha1.TransitionRuleDefinition) string
• func InitDefaultRuleStage(ruleDef *appsv1alpha1.TransitionRuleDefinition, stage string)
• type FuncCache
  • func NewFuncCache() *FuncCache
  • func (n *FuncCache) Add(key string, f ...func(obj client.Object) bool)
  • func (n *FuncCache) Get(key string) []func(obj client.Object) bool
  • func (n *FuncCache) Put(key string, f ...func(obj client.Object) bool)
• type Policy
  • func DefaultPolicy() Policy
• type Register
  • func DefaultRegister() Register
• type UnAvailableFunc

Variables

var (
	UnAvailableFuncList []UnAvailableFunc
)

Functions

func DefaultInit

func DefaultInit()

func GetRuleStage

func GetRuleStage(ruleDef *appsv1alpha1.TransitionRuleDefinition) string

func GetRuleType

func GetRuleType(ruleDef *appsv1alpha1.TransitionRuleDefinition) string

func InitDefaultRuleStage

func InitDefaultRuleStage(ruleDef *appsv1alpha1.TransitionRuleDefinition, stage string)

Types

type FuncCache

type FuncCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewFuncCache

func NewFuncCache() *FuncCache

func (*FuncCache) Add

func (n *FuncCache) Add(key string, f ...func(obj client.Object) bool)

func (*FuncCache) Get

func (n *FuncCache) Get(key string) []func(obj client.Object) bool

func (*FuncCache) Put

func (n *FuncCache) Put(key string, f ...func(obj client.Object) bool)

type Policy

type Policy interface {
	Stage(obj client.Object) string
	InStage(obj client.Object, key string) bool
	GetStages() []string
	Conditions(obj client.Object) []string
	MatchConditions(obj client.Object, conditions ...string) []string
}

func DefaultPolicy

func DefaultPolicy() Policy

type Register

type Register interface {
	RegisterStage(key string, inStage func(obj client.Object) bool)
	RegisterCondition(opsCondition string, inCondition func(obj client.Object) bool)
}

func DefaultRegister

func DefaultRegister() Register

type UnAvailableFunc

type UnAvailableFunc func(pod *corev1.Pod) (bool, *int64)