v1alpha1

Documentation

Index

• Variables
• func Kind(kind string) schema.GroupKind
• func Resource(resource string) schema.GroupResource
• type Cluster
• type ClusterList
• type ClusterSpec
• type ClusterStatus
• type RetiredWorker
• type SchedulerSpec
• type SchedulerStatus
• type WorkerSpec
• type WorkerStatus

Variables

var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)

var SchemeGroupVersion = schema.GroupVersion{Group: dask.GroupName, Version: "v1alpha1"}

Functions

func Kind

func Kind(kind string) schema.GroupKind

func Resource

func Resource(resource string) schema.GroupResource

Types

type Cluster

type Cluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ClusterSpec   `json:"spec,omitempty"`
	Status ClusterStatus `json:"status,omitempty"`
}

+genclient +kubebuilder:subresource:status +kubebuilder:subresource:scale:specpath=.spec.workers.replicas,statuspath=.status.workers.count,selectorpath=.status.workers.selector +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

type ClusterList

type ClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`

	Items []Cluster `json:"items"`
}

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

type ClusterSpec

type ClusterSpec struct {
	Scheduler SchedulerSpec `json:"scheduler,omitempty"`
	Workers   WorkerSpec    `json:"workers,omitempty"`
}

type ClusterStatus

type ClusterStatus struct {
	Scheduler SchedulerStatus `json:"scheduler,omitempty"`
	Workers   WorkerStatus    `json:"workers,omitempty"`
}

type RetiredWorker

type RetiredWorker struct {
	Id string `json:"id,omitEmpty"`
	// The time the pod was retired, so we can kill it if it takes too long.
	Time metav1.Time `json:"time,omitEmpty"`
}

type SchedulerSpec

type SchedulerSpec struct {
	Template v1.PodTemplateSpec `json:"template,omitempty"`
	Service  v1.ServiceSpec     `json:"service,omitempty"`
}

type SchedulerStatus

type SchedulerStatus struct {
	Address string `json:"address,omitempty"`
}

type WorkerSpec

type WorkerSpec struct {
	Replicas int32              `json:"replicas"`
	Template v1.PodTemplateSpec `json:"template,omitempty"`
}

type WorkerStatus

type WorkerStatus struct {
	Replicas int32 `json:"count"`
	// To support the horizontal pod autoscaler
	Selector string `json:"selector,omitEmpty"`
	// +listType=map
	// +listMapKey=id
	Retiring []RetiredWorker `json:"retiring,omitempty"`
}