core

Documentation

Index

• func EvaluateRule(value resource.Quantity, rule telempol.TASPolicyRule) bool
• type Enforcer
• type Interface
• type MetricEnforcer
  • func NewEnforcer(kubeClient kubernetes.Interface) *MetricEnforcer
  • func (e *MetricEnforcer) AddStrategy(str Interface, strategyType string)
  • func (e *MetricEnforcer) EnforceRegisteredStrategies(cache cache.Reader, timer time.Ticker)
  • func (e *MetricEnforcer) IsRegistered(str string) bool
  • func (e *MetricEnforcer) RegisterStrategyType(str Interface)
  • func (e *MetricEnforcer) RegisteredStrategyTypes() []string
  • func (e *MetricEnforcer) RemoveStrategy(str Interface, strategyType string)
  • func (e *MetricEnforcer) UnregisterStrategyType(str Interface)
• type MockStrategy
  • func (v *MockStrategy) Enforce(enforcer *MetricEnforcer, cache cache.Reader) (int, error)
  • func (v *MockStrategy) Equals(o Interface) bool
  • func (v *MockStrategy) GetPolicyName() string
  • func (v *MockStrategy) SetPolicyName(policyName string)
  • func (v *MockStrategy) StrategyType() string
  • func (v *MockStrategy) Violated(cache cache.Reader) map[string]interface{}
• type NodeSortableMetric
  • func OrderedList(metricsInfo metrics.NodeMetricsInfo, operator string) []NodeSortableMetric

Functions

func EvaluateRule

func EvaluateRule(value resource.Quantity, rule telempol.TASPolicyRule) bool

EvaluateRule returns a boolean after implementing the function described in the TASPolicyRule. The rule is transformed into a function inside of the method.

Types

type Enforcer

type Enforcer interface {
	RegisterStrategyType(strategy Interface)
	UnregisterStrategyType(strategy Interface)
	RegisteredStrategyTypes() []string
	IsRegistered(string) bool
	AddStrategy(Interface, string)
	RemoveStrategy(Interface, string)
	EnforceRegisteredStrategies(cache.Reader, time.Ticker)
}

Enforcer registers strategies by type, adds specific strategies to a registry, and Enforces those strategies.

type Interface

type Interface interface {
	Violated(cache cache.Reader) map[string]interface{}
	Enforce(enforcer *MetricEnforcer, cache cache.Reader) (int, error)
	StrategyType() string
	Equals(Interface) bool
	GetPolicyName() string
	SetPolicyName(string)
}

Interface describes expected behavior of a specific strategy.

type MetricEnforcer

type MetricEnforcer struct {
	sync.RWMutex
	RegisteredStrategies map[string]map[Interface]interface{}
	KubeClient           kubernetes.Interface
}

MetricEnforcer instruments behavior to register strategies and trigger their enforcement actions.

func NewEnforcer

func NewEnforcer(kubeClient kubernetes.Interface) *MetricEnforcer

NewEnforcer returns an enforcer with the passed arguments and an empty strategy store.

func (*MetricEnforcer) AddStrategy

func (e *MetricEnforcer) AddStrategy(str Interface, strategyType string)

AddStrategy includes the specific strategy under its type in the strategy registry.

func (*MetricEnforcer) EnforceRegisteredStrategies

func (e *MetricEnforcer) EnforceRegisteredStrategies(cache cache.Reader, timer time.Ticker)

EnforceRegisteredStrategies runs periodically, enforcing each of the registered strategy types in the registry.

func (*MetricEnforcer) IsRegistered

func (e *MetricEnforcer) IsRegistered(str string) bool

IsRegistered checks to see if a passed strategy is already being enforced

func (*MetricEnforcer) RegisterStrategyType

func (e *MetricEnforcer) RegisterStrategyType(str Interface)

RegisterStrategyType adds the type of strategy as top level entry in the registry.

func (*MetricEnforcer) RegisteredStrategyTypes

func (e *MetricEnforcer) RegisteredStrategyTypes() []string

RegisteredStrategyTypes returns a slice of the names of strategy types currently registered with the enforcer.

func (*MetricEnforcer) RemoveStrategy

func (e *MetricEnforcer) RemoveStrategy(str Interface, strategyType string)

RemoveStrategy will take a strategy out of the enforcer if it's currently registered

func (*MetricEnforcer) UnregisterStrategyType

func (e *MetricEnforcer) UnregisterStrategyType(str Interface)

UnregisterStrategyType removes the passed strategy from the registry if it exists there. If it doesn't exist it fails silently.

type MockStrategy

type MockStrategy struct {
	StrategyTypeMock string
}

MockStrategy is used in the tests for the core and other packages.

func (*MockStrategy) Enforce

func (v *MockStrategy) Enforce(enforcer *MetricEnforcer, cache cache.Reader) (int, error)

Enforce returns 0 value and nil error

func (*MockStrategy) Equals

func (v *MockStrategy) Equals(o Interface) bool

Equals returns the value of checking if the strategy types are the same.

func (*MockStrategy) GetPolicyName

func (v *MockStrategy) GetPolicyName() string

GetPolicyName gets the mock strategy policy name

func (*MockStrategy) SetPolicyName

func (v *MockStrategy) SetPolicyName(policyName string)

SetPolicyName sets the policy name of the mock strategy

func (*MockStrategy) StrategyType

func (v *MockStrategy) StrategyType() string

StrategyType returns the Strategy type of the mock

func (*MockStrategy) Violated

func (v *MockStrategy) Violated(cache cache.Reader) map[string]interface{}

Violated gets the cache values from MockStrategy and returns the map interface

type NodeSortableMetric

type NodeSortableMetric struct {
	NodeName    string
	MetricValue resource.Quantity
}

NodeSortableMetric type is necessary in order to call the sort.Slice method. Note lack of usage of time windows or stamps.

func OrderedList

func OrderedList(metricsInfo metrics.NodeMetricsInfo, operator string) []NodeSortableMetric

OrderedList will return a list of nodes ordered by their linked metric and operator TODO: Make this method more generic so it can use objects other than nodes.