v1beta1

Documentation

Index

• Constants
• Variables
• func Resource(resource string) schema.GroupResource
• func ResourceReservationCustomResourceDefinition() *v1.CustomResourceDefinition
• func ResourceReservationCustomResourceDefinitionVersion() v1.CustomResourceDefinitionVersion
• type Reservation
  • func (in *Reservation) DeepCopy() *Reservation
  • func (in *Reservation) DeepCopyInto(out *Reservation)
• type ResourceReservation
  • func (rr *ResourceReservation) ConvertFrom(srcRaw conversion.Hub) error
  • func (rr *ResourceReservation) ConvertTo(dstRaw conversion.Hub) error
  • func (in *ResourceReservation) DeepCopy() *ResourceReservation
  • func (in *ResourceReservation) DeepCopyInto(out *ResourceReservation)
  • func (in *ResourceReservation) DeepCopyObject() runtime.Object
• type ResourceReservationList
  • func (in *ResourceReservationList) DeepCopy() *ResourceReservationList
  • func (in *ResourceReservationList) DeepCopyInto(out *ResourceReservationList)
  • func (in *ResourceReservationList) DeepCopyObject() runtime.Object
• type ResourceReservationSpec
  • func (in *ResourceReservationSpec) DeepCopy() *ResourceReservationSpec
  • func (in *ResourceReservationSpec) DeepCopyInto(out *ResourceReservationSpec)
• type ResourceReservationStatus
  • func (in *ResourceReservationStatus) DeepCopy() *ResourceReservationStatus
  • func (in *ResourceReservationStatus) DeepCopyInto(out *ResourceReservationStatus)

Constants

const (
	// InstanceGroupLabel represents the key of a label that defines the name of the instance group
	InstanceGroupLabel = "instance-group"
	// AppIDLabel represents the key of a label that defines the application ID of a pod
	AppIDLabel = "app-id"
)

Variables

var (
	// SchemeBuilder is the SchemeBuilder instance for the v1beta1 group
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	// AddToScheme applies all the stored functions to the scheme. A non-nil error
	// indicates that one function failed and the attempt was abandoned.
	AddToScheme = SchemeBuilder.AddToScheme
)

var SchemeGroupVersion = schema.GroupVersion{Group: sparkscheduler.GroupName, Version: "v1beta1"}

SchemeGroupVersion represents the kubernetes GroupVersion

Functions

func Resource

func Resource(resource string) schema.GroupResource

Resource returns the GroupResource for a given resource

func ResourceReservationCustomResourceDefinition

func ResourceReservationCustomResourceDefinition() *v1.CustomResourceDefinition

ResourceReservationCustomResourceDefinition returns the CRD definition for resource reservations

func ResourceReservationCustomResourceDefinitionVersion

func ResourceReservationCustomResourceDefinitionVersion() v1.CustomResourceDefinitionVersion

ResourceReservationCustomResourceDefinitionVersion returns the CustomResourceDefinitionVersion for resource reservations

Types

type Reservation

type Reservation struct {
	Node   string            `json:"node"`
	CPU    resource.Quantity `json:"cpu"`
	Memory resource.Quantity `json:"memory"`
}

Reservation represents the reserved node and resources for a single process of a distributed application

func (*Reservation) DeepCopy

func (in *Reservation) DeepCopy() *Reservation

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

func (*Reservation) DeepCopyInto

func (in *Reservation) DeepCopyInto(out *Reservation)

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

type ResourceReservation

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

	Spec   ResourceReservationSpec   `json:"spec"`
	Status ResourceReservationStatus `json:"status"`
}

ResourceReservation is a collection of reservation objects for a distributed application

func (*ResourceReservation) ConvertFrom

func (rr *ResourceReservation) ConvertFrom(srcRaw conversion.Hub) error

ConvertFrom converts from storage version v1beta2 to v1beta1

func (*ResourceReservation) ConvertTo

func (rr *ResourceReservation) ConvertTo(dstRaw conversion.Hub) error

ConvertTo converts from v1beta1 to the storage version v1beta2 We first try to take values the v1beta1 struct, we then take all remaining values from the annotations.

func (*ResourceReservation) DeepCopy

func (in *ResourceReservation) DeepCopy() *ResourceReservation

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

func (*ResourceReservation) DeepCopyInto

func (in *ResourceReservation) DeepCopyInto(out *ResourceReservation)

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

func (*ResourceReservation) DeepCopyObject

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

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

type ResourceReservationList

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

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

ResourceReservationList represents a list of ResourceReservations

func (*ResourceReservationList) DeepCopy

func (in *ResourceReservationList) DeepCopy() *ResourceReservationList

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

func (*ResourceReservationList) DeepCopyInto

func (in *ResourceReservationList) DeepCopyInto(out *ResourceReservationList)

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

func (*ResourceReservationList) DeepCopyObject

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

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

type ResourceReservationSpec

type ResourceReservationSpec struct {
	Reservations map[string]Reservation `json:"reservations"`
}

ResourceReservationSpec represents reservations for the driver and executors of an application

func (*ResourceReservationSpec) DeepCopy

func (in *ResourceReservationSpec) DeepCopy() *ResourceReservationSpec

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

func (*ResourceReservationSpec) DeepCopyInto

func (in *ResourceReservationSpec) DeepCopyInto(out *ResourceReservationSpec)

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

type ResourceReservationStatus

type ResourceReservationStatus struct {
	Pods map[string]string `json:"pods"`
}

ResourceReservationStatus shows which reservations are bound to which pod names

func (*ResourceReservationStatus) DeepCopy

func (in *ResourceReservationStatus) DeepCopy() *ResourceReservationStatus

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

func (*ResourceReservationStatus) DeepCopyInto

func (in *ResourceReservationStatus) DeepCopyInto(out *ResourceReservationStatus)

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