Documentation
¶
Index ¶
Constants ¶
View Source
const ( // GroupIndex indexes pods within the specified group in RayCluster GroupIndex = "group" // RayClusterIndex indexes pods within the RayCluster RayClusterIndex = "raycluster" )
View Source
const HeadGroup = ""
Variables ¶
View Source
var ExpectationsTimeout = time.Second * 30
Functions ¶
This section is empty.
Types ¶
type RayClusterScaleExpectation ¶
type RayClusterScaleExpectation interface {
ExpectScalePod(namespace, rayClusterName, group, podName string, action ScaleAction)
IsSatisfied(ctx context.Context, namespace, rayClusterName, group string) bool
Delete(rayClusterName, namespace string)
}
RayClusterScaleExpectation is an interface that to set and wait on expectations of RayCluster groups scale.
func NewFakeRayClusterScaleExpectation ¶
func NewFakeRayClusterScaleExpectation() RayClusterScaleExpectation
func NewRayClusterScaleExpectation ¶
func NewRayClusterScaleExpectation(client client.Client) RayClusterScaleExpectation
type ScaleAction ¶
type ScaleAction string
ScaleAction is the action of scale, like create and delete.
const ( // Create action Create ScaleAction = "create" // Delete action Delete ScaleAction = "delete" )
Source Files
Click to show internal directories.
Click to hide internal directories.