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 NodeQOSCache
  • func (s *NodeQOSCache) Delete(name string)
  • func (s *NodeQOSCache) Exist(name string) bool
  • func (s *NodeQOSCache) Get(name string) (*ensuranceapi.NodeQOS, bool)
  • func (s *NodeQOSCache) GetOrCreate(nodeQOS *ensuranceapi.NodeQOS) *ensuranceapi.NodeQOS
  • func (s *NodeQOSCache) Init()
  • func (s *NodeQOSCache) ListKeys() []string
  • func (s *NodeQOSCache) Set(nodeQOS *ensuranceapi.NodeQOS)

Functions

func GenerateDetectionKey

func GenerateDetectionKey(c ActionContext) string

Types

type ActionContext

type ActionContext struct {
	// the Objective Ensurance name
	RuleName 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
	NodeQOS *ensuranceapi.NodeQOS
	// time for detection
	Time time.Time
}

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 NodeQOSCache

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

func (*NodeQOSCache) Delete

func (s *NodeQOSCache) Delete(name string)

func (*NodeQOSCache) Exist

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

func (*NodeQOSCache) Get

func (s *NodeQOSCache) Get(name string) (*ensuranceapi.NodeQOS, bool)

func (*NodeQOSCache) GetOrCreate

func (s *NodeQOSCache) GetOrCreate(nodeQOS *ensuranceapi.NodeQOS) *ensuranceapi.NodeQOS

func (*NodeQOSCache) Init

func (s *NodeQOSCache) Init()

func (*NodeQOSCache) ListKeys

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

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

func (*NodeQOSCache) Set

func (s *NodeQOSCache) Set(nodeQOS *ensuranceapi.NodeQOS)