client

Documentation

Index

• type Client
  • func NewClient(factory cmdutil.Factory) (Client, error)
  • func NewClientForTesting(kubeClient kubernetes.Interface, rayClient rayclient.Interface) Client

Types

type Client

type Client interface {
	KubernetesClient() kubernetes.Interface
	RayClient() rayclient.Interface
	// GetRayHeadSvcName retrieves the name of RayHead service for the given RayCluster, RayJob, or RayService.
	GetRayHeadSvcName(ctx context.Context, namespace string, resourceType util.ResourceType, name string) (string, error)
	GetKubeRayOperatorVersion(ctx context.Context) (string, error)
	WaitRayClusterProvisioned(ctx context.Context, namespace, name string, timeout time.Duration) error
}

func NewClient

func NewClient(factory cmdutil.Factory) (Client, error)

func NewClientForTesting

func NewClientForTesting(kubeClient kubernetes.Interface, rayClient rayclient.Interface) Client