yunikorn

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 7, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const DefaultPartition = "default"

Variables

View Source 
var AfterEach = ginkgo.AfterEach
View Source 
var AfterSuite = ginkgo.AfterSuite
View Source 
var BeEquivalentTo = gomega.BeEquivalentTo
View Source 
var BeNil = gomega.BeNil
View Source 
var BeforeEach = ginkgo.BeforeEach
View Source 
var BeforeSuite = ginkgo.BeforeSuite
View Source 
var By = ginkgo.By
View Source 
var Describe = ginkgo.Describe
View Source 
var Equal = gomega.Equal
View Source 
var HaveOccurred = gomega.HaveOccurred
View Source 
var It = ginkgo.It
View Source 
var Ω = gomega.Expect

Functions

func AllocLogToStrings added in v1.1.0 

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

func CreateDefaultConfigMap added in v1.2.0 

func CreateDefaultConfigMap() *v1.ConfigMap

func EnsureYuniKornConfigsPresent added in v1.2.0 

func EnsureYuniKornConfigsPresent()

func GetFailedHealthChecks 

func GetFailedHealthChecks() (string, error)

func GetSchedulerPodName added in v1.2.0 

func GetSchedulerPodName(kClient k8s.KubeCtl) (string, error)

func GetYKHost 

func GetYKHost() string

func GetYKScheme 

func GetYKScheme() string

func GetYKUrl 

func GetYKUrl() string

func RestartYunikorn added in v1.2.0 

func RestartYunikorn(kClient *k8s.KubeCtl)

func RestartYunikornAndAddTolerations added in v1.3.0 

func RestartYunikornAndAddTolerations(kClient *k8s.KubeCtl, addTolerations bool, newTolerations []v1.Toleration)

func RestoreConfigMapWrapper added in v1.1.0 

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

func RestorePortForwarding added in v1.2.0 

func RestorePortForwarding(kClient *k8s.KubeCtl)

func UpdateConfigMapWrapper added in v1.1.0 

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

func UpdateCustomConfigMapWrapper added in v1.2.0 

func UpdateCustomConfigMapWrapper(oldConfigMap *v1.ConfigMap, schedPolicy string, annotation string, mutator func(sc *configs.SchedulerConfig) error)

func UpdateCustomConfigMapWrapperWithMap added in v1.4.0 

func UpdateCustomConfigMapWrapperWithMap(oldConfigMap *v1.ConfigMap, schedPolicy string, annotation string, customMap map[string]string, mutator func(sc *configs.SchedulerConfig) error)

func WaitForAdmissionControllerRefreshConfAfterAction added in v1.4.0 

func WaitForAdmissionControllerRefreshConfAfterAction(action func())

There is no available method to check whether the config in admission controller has been updated As a temporary solution, we are checking the update event using the informer, followed by a 1-second sleep. Please refer to YUNIKORN-1998 for more details

func WaitForQueueTS added in v1.1.0 

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
	Failing    string
	Completing 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) GetAllAppInfos added in v1.2.0 

func (c *RClient) GetAllAppInfos() (*dao.ApplicationsDAOInfo, error)

func (*RClient) GetAllocationLog added in v1.1.0 

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) ([]*dao.ApplicationDAOInfo, error)

func (*RClient) GetCompletedAppInfo added in v1.5.0 

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

func (*RClient) GetConfig added in v1.5.0 

func (c *RClient) GetConfig() (*dao.ConfigDAOInfo, error)

func (*RClient) GetFullStateDump added in v1.5.0 

func (c *RClient) GetFullStateDump() (string, error)

func (*RClient) GetGroupUsage added in v1.4.0 

func (c *RClient) GetGroupUsage(partition string, groupName string) (*dao.GroupResourceUsageDAOInfo, error)

func (*RClient) GetHealthCheck 

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

func (*RClient) GetNodes added in v1.2.0 

func (c *RClient) GetNodes(partition string) (*[]dao.NodeDAOInfo, error)

func (*RClient) GetPartitions 

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

func (*RClient) GetQueue added in v1.1.0 

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) GetUserUsage added in v1.4.0 

func (c *RClient) GetUserUsage(partition string, userName string) (*dao.UserResourceUsageDAOInfo, error)

func (*RClient) IsQueuePresent added in v1.3.0 

func (c *RClient) IsQueuePresent(partition string, queueName string) wait.ConditionFunc

func (*RClient) LogAppsInfo added in v1.2.0 

func (c *RClient) LogAppsInfo(ns string) error

func (*RClient) LogNodesInfo added in v1.2.0 

func (c *RClient) LogNodesInfo() error

func (*RClient) LogQueuesInfo added in v1.2.0 

func (c *RClient) LogQueuesInfo() error

func (*RClient) ValidateSchedulerConfig 

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

func (*RClient) WaitForAllocationLog added in v1.1.0 

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

func (*RClient) WaitForAppStateTransition 

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

func (*RClient) WaitForCompletedAppStateTransition added in v1.5.0 

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

func (*RClient) WaitforQueueToAppear added in v1.3.0 

func (c *RClient) WaitforQueueToAppear(partition string, queueName string, timeout int) error

type ResourceUsage 

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

func (*ResourceUsage) GetCPU added in v1.3.0 

func (r *ResourceUsage) GetCPU() res.Quantity

func (*ResourceUsage) GetMemory 

func (r *ResourceUsage) GetMemory() res.Quantity

func (*ResourceUsage) GetResourceValue added in v1.2.0 

func (r *ResourceUsage) GetResourceValue(resourceName string) int64

func (*ResourceUsage) ParseResourceUsage 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.