manager

Documentation

Index

• Constants
• Variables
• func IsResourceNode(o schedv1alpha1.ObservabilityIndicantSpecTargetRef) bool
• func IsResourcePod(o schedv1alpha1.ObservabilityIndicantSpecTargetRef) bool
• func SchedulerNamespace() string
• type FullMetrics
• type Manager
  • func NewManager(client clientset.Interface, snapshotSharedLister framework.SharedLister, ...) *Manager
  • func (mgr *Manager) GetNodeMetric(ctx context.Context, node *v1.Node) (metric MetricData, err error)
  • func (mgr *Manager) GetPodMetric(ctx context.Context, pod *v1.Pod) (metric MetricData, err error)
  • func (mgr *Manager) GetScoreSpec(ctx context.Context) (logic string)
  • func (mgr *Manager) ObservabilityIndicantAdd(obj interface{})
  • func (mgr *Manager) ObservabilityIndicantDelete(obj interface{})
  • func (mgr *Manager) ObservabilityIndicantUpdate(old interface{}, new interface{})
  • func (mgr *Manager) RsAdd(obj interface{})
  • func (mgr *Manager) RsDelete(obj interface{})
  • func (mgr *Manager) RsUpdate(old interface{}, new interface{})
  • func (mgr *Manager) SchedulerAdd(obj interface{})
  • func (mgr *Manager) SchedulerDelete(obj interface{})
  • func (mgr *Manager) SchedulerUpdate(old interface{}, new interface{})
  • func (mgr *Manager) ScoreAdd(obj interface{})
  • func (mgr *Manager) ScoreDelete(obj interface{})
  • func (mgr *Manager) ScoreUpdate(old interface{}, new interface{})
• type Manager1
• type MetricData
• type NodeWithMetric
• type PodWithMetric

Constants

const (
	DefaultName      = "default"
	ManagerLogPrefix = "[Arbiter-Manager] "
)

Variables

var (
	ErrNotFoundInCache = errors.New("not Found In Memory Cache")
	ErrTypeAssertion   = errors.New("type assertion err")
	ErrNoData          = errors.New("obi have no data")
)

Functions

func IsResourceNode

func IsResourceNode(o schedv1alpha1.ObservabilityIndicantSpecTargetRef) bool

func IsResourcePod

func IsResourcePod(o schedv1alpha1.ObservabilityIndicantSpecTargetRef) bool

func SchedulerNamespace

func SchedulerNamespace() string

Types

type FullMetrics

type FullMetrics struct {
	*v1alpha1.ObservabilityIndicantStatusMetricInfo
	Avg float64 `json:"avg"`
	Max float64 `json:"max"`
	Min float64 `json:"min"`
}

type Manager

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

func NewManager

func NewManager(client clientset.Interface, snapshotSharedLister framework.SharedLister, podInformer informerv1.PodInformer, nodeInformer informerv1.NodeInformer) *Manager

func (*Manager) GetNodeMetric

func (mgr *Manager) GetNodeMetric(ctx context.Context, node *v1.Node) (metric MetricData, err error)

func (*Manager) GetPodMetric

func (mgr *Manager) GetPodMetric(ctx context.Context, pod *v1.Pod) (metric MetricData, err error)

func (*Manager) GetScoreSpec

func (mgr *Manager) GetScoreSpec(ctx context.Context) (logic string)

func (*Manager) ObservabilityIndicantAdd

func (mgr *Manager) ObservabilityIndicantAdd(obj interface{})

func (*Manager) ObservabilityIndicantDelete

func (mgr *Manager) ObservabilityIndicantDelete(obj interface{})

func (*Manager) ObservabilityIndicantUpdate

func (mgr *Manager) ObservabilityIndicantUpdate(old interface{}, new interface{})

func (*Manager) RsAdd

func (mgr *Manager) RsAdd(obj interface{})

func (*Manager) RsDelete

func (mgr *Manager) RsDelete(obj interface{})

func (*Manager) RsUpdate

func (mgr *Manager) RsUpdate(old interface{}, new interface{})

func (*Manager) SchedulerAdd

func (mgr *Manager) SchedulerAdd(obj interface{})

func (*Manager) SchedulerDelete

func (mgr *Manager) SchedulerDelete(obj interface{})

func (*Manager) SchedulerUpdate

func (mgr *Manager) SchedulerUpdate(old interface{}, new interface{})

func (*Manager) ScoreAdd

func (mgr *Manager) ScoreAdd(obj interface{})

func (*Manager) ScoreDelete

func (mgr *Manager) ScoreDelete(obj interface{})

func (*Manager) ScoreUpdate

func (mgr *Manager) ScoreUpdate(old interface{}, new interface{})

type Manager1

type Manager1 interface {
	GetScoreSpec(ctx context.Context) string
	GetPodMetric(ctx context.Context, pod *v1.Pod) (metric MetricData, err error)
	GetNodeMetric(ctx context.Context, node *v1.Node) (metric MetricData, err error)
}

type MetricData

type MetricData map[string]*FullMetrics

type NodeWithMetric

type NodeWithMetric struct {
	Node   *v1.Node   `json:"raw"`
	Metric MetricData `json:"metric"`
}

type PodWithMetric

type PodWithMetric struct {
	Pod    *v1.Pod    `json:"raw"`
	Metric MetricData `json:"metric"`
}