yunikorn

Documentation

Index

• Variables
• func AllocLogToStrings(log []dao.AllocationAskLogDAOInfo) []string
• func CreateApplication(crdclientset crdclientset.Interface, app *v1alpha1.Application, ...) error
• func DeleteApplication(crdclientset crdclientset.Interface, namespace, name string) error
• func GetApplication(crdclientset crdclientset.Interface, namespace, name string) (*v1alpha1.Application, error)
• func GetApplicationObj(yamlPath string) (*v1alpha1.Application, error)
• func GetFailedHealthChecks() (string, error)
• func GetYKHost() string
• func GetYKScheme() string
• func GetYKUrl() string
• func NewApplicationClient() (*crdclientset.Clientset, error)
• func NewClient(kubeconfig string) (*crdclientset.Clientset, error)
• func RestoreConfigMapWrapper(oldConfigMap *v1.ConfigMap, annotation string)
• func UpdateApplication(crdclientset crdclientset.Interface, app *v1alpha1.Application, ...) error
• func UpdateConfigMapWrapper(oldConfigMap *v1.ConfigMap, schedPolicy string, annotation string)
• func WaitForQueueTS(queuePathStr string, ts string, timeout time.Duration) error
• func WaitForSchedPolicy(policy string, timeout time.Duration) error
• type AllStates
  • func States() *AllStates
• type ApplicationStates
• type NodeStates
• type RClient
  • func (c *RClient) AreAllExecPodsAllotted(partition string, queueName string, appID string, execPodCount int) wait.ConditionFunc
  • func (c *RClient) GetAllocationLog(partition string, queueName string, appID string, podName string) ([]dao.AllocationAskLogDAOInfo, error)
  • func (c *RClient) GetAppInfo(partition string, queueName string, appID string) (*dao.ApplicationDAOInfo, error)
  • func (c *RClient) GetApps(partition string, queueName string) ([]map[string]interface{}, error)
  • func (c *RClient) GetHealthCheck() (dao.SchedulerHealthDAOInfo, error)
  • func (c *RClient) GetQueue(partition string, queueName string) (*dao.PartitionQueueDAOInfo, error)
  • func (c *RClient) GetQueues(partition string) (*dao.PartitionQueueDAOInfo, error)
  • func (c *RClient) GetSpecificQueueInfo(partition string, queueName string) (*dao.PartitionQueueDAOInfo, error)
  • func (c *RClient) ValidateSchedulerConfig(cm v1.ConfigMap) (*dao.ValidateConfResponse, error)
  • func (c *RClient) WaitForAllocationLog(partition string, queueName string, appID string, podName string, timeout int) error
  • func (c *RClient) WaitForAppStateTransition(partition string, queueName string, appID string, state string, timeout int) error
• type ResourceUsage
  • func (r *ResourceUsage) GetMemory() int64
  • func (r *ResourceUsage) GetVCPU() int64
  • func (r *ResourceUsage) ParseResourceUsage(resource map[string]int64)

Variables

var AfterEach = ginkgo.AfterEach

var AfterSuite = ginkgo.AfterSuite

var BeEquivalentTo = gomega.BeEquivalentTo

var BeNil = gomega.BeNil

var BeforeEach = ginkgo.BeforeEach

var BeforeSuite = ginkgo.BeforeSuite

var By = ginkgo.By

var Describe = ginkgo.Describe

var Equal = gomega.Equal

var HaveOccurred = gomega.HaveOccurred

var It = ginkgo.It

var Ω = gomega.Expect

Functions

func AllocLogToStrings

func AllocLogToStrings(log []dao.AllocationAskLogDAOInfo) []string

func CreateApplication

func CreateApplication(crdclientset crdclientset.Interface, app *v1alpha1.Application, namespace string) error

func DeleteApplication

func DeleteApplication(crdclientset crdclientset.Interface, namespace, name string) error

func GetApplication

func GetApplication(crdclientset crdclientset.Interface, namespace, name string) (*v1alpha1.Application, error)

func GetApplicationObj

func GetApplicationObj(yamlPath string) (*v1alpha1.Application, error)

func GetFailedHealthChecks

func GetFailedHealthChecks() (string, error)

func GetYKHost

func GetYKHost() string

func GetYKScheme

func GetYKScheme() string

func GetYKUrl

func GetYKUrl() string

func NewApplicationClient

func NewApplicationClient() (*crdclientset.Clientset, error)

func NewClient

func NewClient(kubeconfig string) (*crdclientset.Clientset, error)

func RestoreConfigMapWrapper

func RestoreConfigMapWrapper(oldConfigMap *v1.ConfigMap, annotation string)

func UpdateApplication

func UpdateApplication(crdclientset crdclientset.Interface, app *v1alpha1.Application, namespace string) error

func UpdateConfigMapWrapper

func UpdateConfigMapWrapper(oldConfigMap *v1.ConfigMap, schedPolicy string, annotation string)

func WaitForQueueTS

func WaitForQueueTS(queuePathStr string, ts string, timeout time.Duration) error

Expects queuePath to use periods as delimiters. ie "root.queueA.child"

func WaitForSchedPolicy

func WaitForSchedPolicy(policy string, timeout time.Duration) error

Types

type AllStates

type AllStates struct {
	Application *ApplicationStates
	Node        *NodeStates
}

func States

func States() *AllStates

type ApplicationStates

type ApplicationStates struct {
	New        string
	Recovering string
	Submitted  string
	Starting   string
	Accepted   string
	Running    string
	Rejected   string
	Completed  string
	Killing    string
	Killed     string
	Failed     string
}

type NodeStates

type NodeStates struct {
	New        string
	Recovering string
	Accepted   string
	Healthy    string
	Rejected   string
	Draining   string
}

type RClient

type RClient struct {
	BaseURL   *url.URL
	UserAgent string
	// contains filtered or unexported fields
}

func (*RClient) AreAllExecPodsAllotted

func (c *RClient) AreAllExecPodsAllotted(partition string, queueName string, appID string, execPodCount int) wait.ConditionFunc

func (*RClient) GetAllocationLog

func (c *RClient) GetAllocationLog(partition string, queueName string, appID string, podName string) ([]dao.AllocationAskLogDAOInfo, error)

func (*RClient) GetAppInfo

func (c *RClient) GetAppInfo(partition string, queueName string, appID string) (*dao.ApplicationDAOInfo, error)

func (*RClient) GetApps

func (c *RClient) GetApps(partition string, queueName string) ([]map[string]interface{}, error)

func (*RClient) GetHealthCheck

func (c *RClient) GetHealthCheck() (dao.SchedulerHealthDAOInfo, error)

func (*RClient) GetQueue

func (c *RClient) GetQueue(partition string, queueName string) (*dao.PartitionQueueDAOInfo, error)

func (*RClient) GetQueues

func (c *RClient) GetQueues(partition string) (*dao.PartitionQueueDAOInfo, error)

func (*RClient) GetSpecificQueueInfo

func (c *RClient) GetSpecificQueueInfo(partition string, queueName string) (*dao.PartitionQueueDAOInfo, error)

func (*RClient) ValidateSchedulerConfig

func (c *RClient) ValidateSchedulerConfig(cm v1.ConfigMap) (*dao.ValidateConfResponse, error)

func (*RClient) WaitForAllocationLog

func (c *RClient) WaitForAllocationLog(partition string, queueName string, appID string, podName string, timeout int) error

func (*RClient) WaitForAppStateTransition

func (c *RClient) WaitForAppStateTransition(partition string, queueName string, appID string, state string, timeout int) error

type ResourceUsage

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

func (*ResourceUsage) GetMemory

func (r *ResourceUsage) GetMemory() int64

func (*ResourceUsage) GetVCPU

func (r *ResourceUsage) GetVCPU() int64

func (*ResourceUsage) ParseResourceUsage

func (r *ResourceUsage) ParseResourceUsage(resource map[string]int64)