cache

Documentation

Index

• func GenerateDetectionKey(c ActionContext) string
• type ActionContext
• type ActionContextCache
  • func (s *ActionContextCache) Exist(key string) bool
  • func (s *ActionContextCache) Get(key string) (ActionContext, bool)
  • func (s *ActionContextCache) GetOrCreate(c ActionContext) ActionContext
  • func (s *ActionContextCache) ListDetections() []ActionContext
  • func (s *ActionContextCache) Set(c ActionContext)
• type DetectionStatus
• type NodeQOSEnsurancePolicyCache
  • func (s *NodeQOSEnsurancePolicyCache) Delete(name string)
  • func (s *NodeQOSEnsurancePolicyCache) Exist(name string) bool
  • func (s *NodeQOSEnsurancePolicyCache) Get(name string) (*ensuranceapi.NodeQOSEnsurancePolicy, bool)
  • func (s *NodeQOSEnsurancePolicyCache) GetOrCreate(nep *ensuranceapi.NodeQOSEnsurancePolicy) *ensuranceapi.NodeQOSEnsurancePolicy
  • func (s *NodeQOSEnsurancePolicyCache) Init()
  • func (s *NodeQOSEnsurancePolicyCache) ListKeys() []string
  • func (s *NodeQOSEnsurancePolicyCache) Set(nep *ensuranceapi.NodeQOSEnsurancePolicy)

Functions

func GenerateDetectionKey

func GenerateDetectionKey(c ActionContext) string

Types

type ActionContext

type ActionContext 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 ActionContextCache

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

func (*ActionContextCache) Exist

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

func (*ActionContextCache) Get

func (s *ActionContextCache) Get(key string) (ActionContext, bool)

func (*ActionContextCache) GetOrCreate

func (s *ActionContextCache) GetOrCreate(c ActionContext) ActionContext

func (*ActionContextCache) ListDetections

func (s *ActionContextCache) ListDetections() []ActionContext

func (*ActionContextCache) Set

func (s *ActionContextCache) Set(c ActionContext)

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)