v1

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Nov 14, 2022 License: MIT Imports: 5 Imported by: 1

Documentation

Overview

Package v1 is the v1 version of the API. +groupName=kubernetes.dask.org

Index

Constants

View Source 
const (
	Version = "v1"
)

Variables

View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: daskoperator.GroupName, Version: Version}

SchemeGroupVersion is the group version used to register these objects.

Functions

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group-qualified GroupResource.

Types

type DaskAutoscaler 

type DaskAutoscaler struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              DaskAutoscalerSpec `json:"spec"`
}

+genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:defaulter-gen=true

func (*DaskAutoscaler) DeepCopy 

func (in *DaskAutoscaler) DeepCopy() *DaskAutoscaler

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskAutoscaler.

func (*DaskAutoscaler) DeepCopyInto 

func (in *DaskAutoscaler) DeepCopyInto(out *DaskAutoscaler)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DaskAutoscaler) DeepCopyObject 

func (in *DaskAutoscaler) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DaskAutoscalerList 

type DaskAutoscalerList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DaskAutoscaler `json:"items,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*DaskAutoscalerList) DeepCopy 

func (in *DaskAutoscalerList) DeepCopy() *DaskAutoscalerList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskAutoscalerList.

func (*DaskAutoscalerList) DeepCopyInto 

func (in *DaskAutoscalerList) DeepCopyInto(out *DaskAutoscalerList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DaskAutoscalerList) DeepCopyObject 

func (in *DaskAutoscalerList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DaskAutoscalerSpec 

type DaskAutoscalerSpec struct {
	// Name of the cluster to associate this autoscaler with
	Cluster string `json:"cluster"`
	// Minimum number of workers
	Minimum string `json:"minimum"`
	// Maximum number of workers
	Maximum string `json:"maximum"`
}

func (*DaskAutoscalerSpec) DeepCopy 

func (in *DaskAutoscalerSpec) DeepCopy() *DaskAutoscalerSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskAutoscalerSpec.

func (*DaskAutoscalerSpec) DeepCopyInto 

func (in *DaskAutoscalerSpec) DeepCopyInto(out *DaskAutoscalerSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DaskCluster 

type DaskCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              DaskClusterSpec   `json:"spec"`
	Status            DaskClusterStatus `json:"status,omitempty"`
}

+genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:defaulter-gen=true

func (*DaskCluster) DeepCopy 

func (in *DaskCluster) DeepCopy() *DaskCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskCluster.

func (*DaskCluster) DeepCopyInto 

func (in *DaskCluster) DeepCopyInto(out *DaskCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DaskCluster) DeepCopyObject 

func (in *DaskCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DaskClusterList 

type DaskClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DaskCluster `json:"items,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*DaskClusterList) DeepCopy 

func (in *DaskClusterList) DeepCopy() *DaskClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskClusterList.

func (*DaskClusterList) DeepCopyInto 

func (in *DaskClusterList) DeepCopyInto(out *DaskClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DaskClusterList) DeepCopyObject 

func (in *DaskClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DaskClusterPhase 

type DaskClusterPhase string
const (
	DaskClusterCreated DaskClusterPhase = "Created"
	DaskClusterRunning DaskClusterPhase = "Running"
)

type DaskClusterSpec 

type DaskClusterSpec struct {
	Worker    WorkerSpec    `json:"worker"`
	Scheduler SchedulerSpec `json:"scheduler"`
}

func (*DaskClusterSpec) DeepCopy 

func (in *DaskClusterSpec) DeepCopy() *DaskClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskClusterSpec.

func (*DaskClusterSpec) DeepCopyInto 

func (in *DaskClusterSpec) DeepCopyInto(out *DaskClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DaskClusterStatus 

type DaskClusterStatus struct {
	// The phase the cluster is in right now
	Phase DaskClusterPhase `json:"phase,omitempty"`
}

func (*DaskClusterStatus) DeepCopy 

func (in *DaskClusterStatus) DeepCopy() *DaskClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskClusterStatus.

func (*DaskClusterStatus) DeepCopyInto 

func (in *DaskClusterStatus) DeepCopyInto(out *DaskClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DaskJob 

type DaskJob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              DaskJobSpec   `json:"spec"`
	Status            DaskJobStatus `json:"status,omitempty"`
}

+genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:defaulter-gen=true

func (*DaskJob) DeepCopy 

func (in *DaskJob) DeepCopy() *DaskJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskJob.

func (*DaskJob) DeepCopyInto 

func (in *DaskJob) DeepCopyInto(out *DaskJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DaskJob) DeepCopyObject 

func (in *DaskJob) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DaskJobList 

type DaskJobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DaskJob `json:"items,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*DaskJobList) DeepCopy 

func (in *DaskJobList) DeepCopy() *DaskJobList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskJobList.

func (*DaskJobList) DeepCopyInto 

func (in *DaskJobList) DeepCopyInto(out *DaskJobList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DaskJobList) DeepCopyObject 

func (in *DaskJobList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DaskJobSpec 

type DaskJobSpec struct {
	Job     JobSpec     `json:"job"`
	Cluster DaskCluster `json:"cluster"`
}

func (*DaskJobSpec) DeepCopy 

func (in *DaskJobSpec) DeepCopy() *DaskJobSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskJobSpec.

func (*DaskJobSpec) DeepCopyInto 

func (in *DaskJobSpec) DeepCopyInto(out *DaskJobSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DaskJobStatus 

type DaskJobStatus struct {
	// The name of the cluster the job is executed on
	ClusterName string `json:"clusterName,omitempty"`
	// The time the job runner pod changed to either Successful or Failing
	EndTime metav1.Time `json:"endTime,omitempty"`
	// The name of the job-runner pod
	JobRunnerPodName string `json:"jobRunnerPodName,omitempty"`
	// JobStatus describes the current status of the job
	JobStatus JobStatus `json:"jobStatus"`
	// Start time records the time the job-runner pod changed into a `running` state
	StartTime metav1.Time `json:"startTime"`
}

DaskJobStatus describes the current status of a Dask Job

func (*DaskJobStatus) DeepCopy 

func (in *DaskJobStatus) DeepCopy() *DaskJobStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskJobStatus.

func (*DaskJobStatus) DeepCopyInto 

func (in *DaskJobStatus) DeepCopyInto(out *DaskJobStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DaskWorkerGroup 

type DaskWorkerGroup struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              DaskWorkerGroupSpec `json:"spec"`
}

+genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:defaulter-gen=true

func (*DaskWorkerGroup) DeepCopy 

func (in *DaskWorkerGroup) DeepCopy() *DaskWorkerGroup

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskWorkerGroup.

func (*DaskWorkerGroup) DeepCopyInto 

func (in *DaskWorkerGroup) DeepCopyInto(out *DaskWorkerGroup)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DaskWorkerGroup) DeepCopyObject 

func (in *DaskWorkerGroup) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DaskWorkerGroupList 

type DaskWorkerGroupList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DaskWorkerGroup `json:"items,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*DaskWorkerGroupList) DeepCopy 

func (in *DaskWorkerGroupList) DeepCopy() *DaskWorkerGroupList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskWorkerGroupList.

func (*DaskWorkerGroupList) DeepCopyInto 

func (in *DaskWorkerGroupList) DeepCopyInto(out *DaskWorkerGroupList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DaskWorkerGroupList) DeepCopyObject 

func (in *DaskWorkerGroupList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type DaskWorkerGroupSpec 

type DaskWorkerGroupSpec struct {
	Cluster string     `json:"cluster"`
	Worker  WorkerSpec `json:"worker"`
}

func (*DaskWorkerGroupSpec) DeepCopy 

func (in *DaskWorkerGroupSpec) DeepCopy() *DaskWorkerGroupSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaskWorkerGroupSpec.

func (*DaskWorkerGroupSpec) DeepCopyInto 

func (in *DaskWorkerGroupSpec) DeepCopyInto(out *DaskWorkerGroupSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JobSpec 

type JobSpec struct {
	Spec v1.PodSpec `json:"spec"`
}

func (*JobSpec) DeepCopy 

func (in *JobSpec) DeepCopy() *JobSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobSpec.

func (*JobSpec) DeepCopyInto 

func (in *JobSpec) DeepCopyInto(out *JobSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JobStatus 

type JobStatus string
const (
	DaskJobCreated        JobStatus = "JobCreated"
	DaskJobClusterCreated JobStatus = "ClusterCreated"
	DaskJobRunning        JobStatus = "Running"
	DaskJobSuccessful     JobStatus = "Successful"
	DaskJobFailed         JobStatus = "Failed"
)

type SchedulerSpec 

type SchedulerSpec struct {
	Spec    v1.PodSpec     `json:"spec"`
	Service v1.ServiceSpec `json:"service"`
}

func (*SchedulerSpec) DeepCopy 

func (in *SchedulerSpec) DeepCopy() *SchedulerSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchedulerSpec.

func (*SchedulerSpec) DeepCopyInto 

func (in *SchedulerSpec) DeepCopyInto(out *SchedulerSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type WorkerSpec 

type WorkerSpec struct {
	Replicas int        `json:"replicas"`
	Spec     v1.PodSpec `json:"spec"`
}

func (*WorkerSpec) DeepCopy 

func (in *WorkerSpec) DeepCopy() *WorkerSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkerSpec.

func (*WorkerSpec) DeepCopyInto 

func (in *WorkerSpec) DeepCopyInto(out *WorkerSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

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.