yunikorn

Documentation

Index

• 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 UpdateApplication(crdclientset crdclientset.Interface, app *v1alpha1.Application, ...) error
• func WaitForSchedPolicy(policy string, timeout time.Duration) error
• type AllStates
  • func States() *AllStates
• type ApplicationStates
• type NodeStates
• type RClient
  • func (c *RClient) AreAllExecPodsAllotted(appID string, execPodCount int) wait.ConditionFunc
  • func (c *RClient) GetAppInfo(appID string) (map[string]interface{}, error)
  • func (c *RClient) GetApps() ([]map[string]interface{}, error)
  • func (c *RClient) GetAppsFromSpecificQueue(queueName string) ([]map[string]interface{}, error)
  • func (c *RClient) GetHealthCheck() (dao.SchedulerHealthDAOInfo, error)
  • func (c *RClient) GetPartitions() (*dao.PartitionDAOInfo, error)
  • func (c *RClient) GetQueues() (map[string]interface{}, error)
  • func (c *RClient) GetSpecificQueueInfo(queueName string) (map[string]interface{}, error)
  • func (c *RClient) ValidateSchedulerConfig(cm v1.ConfigMap) (*dao.ValidateConfResponse, error)
  • func (c *RClient) WaitForAppStateTransition(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]interface{})

Functions

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 UpdateApplication

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

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(appID string, execPodCount int) wait.ConditionFunc

func (*RClient) GetAppInfo

func (c *RClient) GetAppInfo(appID string) (map[string]interface{}, error)

func (*RClient) GetApps

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

func (*RClient) GetAppsFromSpecificQueue

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

func (*RClient) GetHealthCheck

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

func (*RClient) GetPartitions

func (c *RClient) GetPartitions() (*dao.PartitionDAOInfo, error)

func (*RClient) GetQueues

func (c *RClient) GetQueues() (map[string]interface{}, error)

func (*RClient) GetSpecificQueueInfo

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

func (*RClient) ValidateSchedulerConfig

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

func (*RClient) WaitForAppStateTransition

func (c *RClient) WaitForAppStateTransition(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]interface{})