ray

package

v0.0.8-internal Latest Latest Go to latest Published: Feb 17, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/silogen/kaiwo

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const EntrypointFilename = "entrypoint"

View Source

const ServeconfigFilename = "serveconfig"

Variables ¶

View Source

var DeploymentTemplate []byte

View Source

var JobTemplate []byte

Functions ¶

This section is empty.

Types ¶

type Deployment ¶

type Deployment struct {
	workloads.WorkloadBase
	RayService rayv1.RayService
	RayCluster *rayv1.RayCluster
	HeadPod    *corev1.Pod
	WorkerPods []*corev1.Pod
}

func (*Deployment) DefaultTemplate ¶

func (d *Deployment) DefaultTemplate() ([]byte, error)

func (*Deployment) GenerateTemplateContext ¶

func (d *Deployment) GenerateTemplateContext(execFlags workloads.ExecFlags) (any, error)

func (*Deployment) GetObject ¶

func (d *Deployment) GetObject() client.Object

func (*Deployment) GetServices ¶

func (d *Deployment) GetServices(ctx context.Context, k8sClient client.Client) ([]corev1.Service, error)

func (*Deployment) GetStatus ¶

func (d *Deployment) GetStatus() string

func (*Deployment) IgnoreFiles ¶

func (d *Deployment) IgnoreFiles() []string

func (*Deployment) ListKnownPods ¶

func (d *Deployment) ListKnownPods() []workloads.WorkloadPod

func (*Deployment) ResolveStructure ¶

func (d *Deployment) ResolveStructure(ctx context.Context, k8sClient client.Client) error

func (*Deployment) SetFromObject ¶

func (d *Deployment) SetFromObject(obj client.Object) error

type DeploymentFlags ¶

type DeploymentFlags struct {
	Serveconfig string
}

type Job ¶

type Job struct {
	workloads.WorkloadBase
	RayJob       rayv1.RayJob
	SubmitterPod *corev1.Pod
	HeadPod      *corev1.Pod
	WorkerPods   []*corev1.Pod
}

func (*Job) ConvertObject ¶

func (j *Job) ConvertObject(object runtime.Object) (client.Object, bool)

func (*Job) DefaultTemplate ¶

func (j *Job) DefaultTemplate() ([]byte, error)

func (*Job) GenerateAdditionalResourceManifests ¶

func (j *Job) GenerateAdditionalResourceManifests(ctx context.Context, k8sClient client.Client, templateContext workloads.WorkloadTemplateConfig) ([]client.Object, error)

func (*Job) GenerateTemplateContext ¶

func (j *Job) GenerateTemplateContext(execFlags workloads.ExecFlags) (any, error)

func (*Job) GetObject ¶

func (j *Job) GetObject() client.Object

func (*Job) GetServices ¶

func (j *Job) GetServices(ctx context.Context, k8sClient client.Client) ([]corev1.Service, error)

func (*Job) GetStatus ¶

func (j *Job) GetStatus() string

func (*Job) IgnoreFiles ¶

func (j *Job) IgnoreFiles() []string

func (*Job) ListKnownPods ¶

func (j *Job) ListKnownPods() []workloads.WorkloadPod

func (*Job) ResolveStructure ¶

func (j *Job) ResolveStructure(ctx context.Context, k8sClient client.Client) error

func (*Job) SetFromObject ¶

func (j *Job) SetFromObject(obj client.Object) error

type JobFlags ¶

type JobFlags struct {
	Entrypoint string
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL