job_store

Documentation

Index

• Variables
• func CreateCRDDefinition() error
• func CreateJobThroughputMetricObj(metric *JobPerformanceMetric) error
• func GetJobThroughput(performantID string, slType string) (float64, error)
• func InitInformer() error
• func ObjToUnstructured(obj interface{}) (*unstructured.Unstructured, error)
• func SetClientset(c *crdclientset.Clientset, dynamic *dynamic.DynamicClient)
• type JobPerformanceMetric
  • func MetricFromSpec(spec *JobPerformanceMetricSpec) *JobPerformanceMetric
• type JobPerformanceMetricSpec

Variables

var CrdClientset *crdclientset.Clientset

var DynamicClientset *dynamic.DynamicClient

var GVR = schema.GroupVersionResource{
	Group:    constants.CRDGroup,
	Version:  constants.CRDVersion,
	Resource: constants.CRDPlural,
}

var JobThroughputStore cache.Store

Functions

func CreateCRDDefinition

func CreateCRDDefinition() error

func CreateJobThroughputMetricObj

func CreateJobThroughputMetricObj(metric *JobPerformanceMetric) error

func GetJobThroughput

func GetJobThroughput(performantID string, slType string) (float64, error)

func InitInformer

func InitInformer() error

func ObjToUnstructured

func ObjToUnstructured(obj interface{}) (*unstructured.Unstructured, error)

func SetClientset

func SetClientset(c *crdclientset.Clientset, dynamic *dynamic.DynamicClient)

Types

type JobPerformanceMetric

type JobPerformanceMetric struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              JobPerformanceMetricSpec `json:"spec"`
}

func MetricFromSpec

func MetricFromSpec(spec *JobPerformanceMetricSpec) *JobPerformanceMetric

type JobPerformanceMetricSpec

type JobPerformanceMetricSpec struct {
	PerformantID string  `json:"performantID"`
	SLType       string  `json:"slType"`
	IterPerSec   float64 `json:"iterPerSec"`
}