cache

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 17, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenerateDetectionKey 

func GenerateDetectionKey(c DetectionCondition) string

Types

type DetectionCondition 

type DetectionCondition struct {
	// the Objective Ensurance name
	ObjectiveEnsuranceName string
	// strategy for the action
	Strategy ensuranceapi.AvoidanceActionStrategy
	// if the policy triggered action
	Triggered bool
	// if the policy triggered restored action
	Restored bool
	// action name
	ActionName string
	// node qos ensurance policy
	Nep *ensuranceapi.NodeQOSEnsurancePolicy
	// time for detection
	Time time.Time
	// the influenced pod list
	// node detection the pod list is empty
	BeInfluencedPods []types.NamespacedName
}

type DetectionConditionCache 

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

func (*DetectionConditionCache) Exist 

func (s *DetectionConditionCache) Exist(key string) bool

func (*DetectionConditionCache) Get 

func (s *DetectionConditionCache) Get(key string) (DetectionCondition, bool)

func (*DetectionConditionCache) GetOrCreate 

func (s *DetectionConditionCache) GetOrCreate(c DetectionCondition) DetectionCondition

func (*DetectionConditionCache) ListDetections 

func (s *DetectionConditionCache) ListDetections() []DetectionCondition

func (*DetectionConditionCache) Set 

func (s *DetectionConditionCache) Set(c DetectionCondition)

type DetectionStatus 

type DetectionStatus struct {
	IsTriggered bool
	LastTime    time.Time
}

type NodeQOSEnsurancePolicyCache 

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

func (*NodeQOSEnsurancePolicyCache) Delete 

func (s *NodeQOSEnsurancePolicyCache) Delete(name string)

func (*NodeQOSEnsurancePolicyCache) Exist 

func (s *NodeQOSEnsurancePolicyCache) Exist(name string) bool

func (*NodeQOSEnsurancePolicyCache) Get 

func (s *NodeQOSEnsurancePolicyCache) Get(name string) (*ensuranceapi.NodeQOSEnsurancePolicy, bool)

func (*NodeQOSEnsurancePolicyCache) GetOrCreate 

func (s *NodeQOSEnsurancePolicyCache) GetOrCreate(nep *ensuranceapi.NodeQOSEnsurancePolicy) *ensuranceapi.NodeQOSEnsurancePolicy

func (*NodeQOSEnsurancePolicyCache) Init 

func (s *NodeQOSEnsurancePolicyCache) Init()

func (*NodeQOSEnsurancePolicyCache) ListKeys 

func (s *NodeQOSEnsurancePolicyCache) ListKeys() []string

ListKeys implements the interface required by DeltaFIFO to list the keys we already know about.

func (*NodeQOSEnsurancePolicyCache) Set 

func (s *NodeQOSEnsurancePolicyCache) Set(nep *ensuranceapi.NodeQOSEnsurancePolicy)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.