Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterClientInterface ¶
type ClusterClientInterface interface {
RayClusterClient(namespace string) rayv1.RayClusterInterface
}
func NewRayClusterClientOrFatal ¶
func NewRayClusterClientOrFatal(initConnectionTimeout time.Duration, options util.ClientOptions) ClusterClientInterface
type JobClientInterface ¶
type JobClientInterface interface {
RayJobClient(namespace string) rayv1.RayJobInterface
}
func NewRayJobClientOrFatal ¶
func NewRayJobClientOrFatal(initConnectionTimeout time.Duration, options util.ClientOptions) JobClientInterface
type KubernetesClient ¶
type KubernetesClient struct {
// contains filtered or unexported fields
}
func (*KubernetesClient) ConfigMapClient ¶
func (c *KubernetesClient) ConfigMapClient(namespace string) v1.ConfigMapInterface
func (*KubernetesClient) EventsClient ¶
func (c *KubernetesClient) EventsClient(namespace string) v1.EventInterface
func (*KubernetesClient) NamespaceClient ¶
func (c *KubernetesClient) NamespaceClient() v1.NamespaceInterface
func (*KubernetesClient) PodClient ¶
func (c *KubernetesClient) PodClient(namespace string) v1.PodInterface
type KubernetesClientInterface ¶
type KubernetesClientInterface interface { PodClient(namespace string) v1.PodInterface ConfigMapClient(namespace string) v1.ConfigMapInterface NamespaceClient() v1.NamespaceInterface EventsClient(namespace string) v1.EventInterface }
func CreateKubernetesCoreOrFatal ¶
func CreateKubernetesCoreOrFatal(initConnectionTimeout time.Duration, options util.ClientOptions) KubernetesClientInterface
CreateKubernetesCoreOrFatal creates a new client for the Kubernetes pod.
type RayClusterClient ¶
type RayClusterClient struct {
// contains filtered or unexported fields
}
func (RayClusterClient) RayClusterClient ¶
func (cc RayClusterClient) RayClusterClient(namespace string) rayv1.RayClusterInterface
type RayJobClient ¶
type RayJobClient struct {
// contains filtered or unexported fields
}
func (RayJobClient) RayJobClient ¶
func (cc RayJobClient) RayJobClient(namespace string) rayv1.RayJobInterface
type RayServiceClient ¶
type RayServiceClient struct {
// contains filtered or unexported fields
}
func (RayServiceClient) RayServiceClient ¶
func (cc RayServiceClient) RayServiceClient(namespace string) rayv1.RayServiceInterface
type ServiceClientInterface ¶
type ServiceClientInterface interface {
RayServiceClient(namespace string) rayv1.RayServiceInterface
}
func NewRayServiceClientOrFatal ¶
func NewRayServiceClientOrFatal(initConnectionTimeout time.Duration, options util.ClientOptions) ServiceClientInterface
Click to show internal directories.
Click to hide internal directories.