v1beta1

Documentation

Index

• Constants
• Variables
• func Resource(resource string) schema.GroupResource
• func ResourceReservationCustomResourceDefinition() *apiextensionsv1beta1.CustomResourceDefinition
• type Reservation
  • func (in *Reservation) DeepCopy() *Reservation
  • func (in *Reservation) DeepCopyInto(out *Reservation)
• type ResourceReservation
  • 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"
)

const GroupName = "sparkscheduler.palantir.com"

GroupName defines the kubernetes group name for resource reservations

const ResourceReservationPlural = "resourcereservations"

ResourceReservationPlural defines how to refer to multiple resource reservations

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: 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() *apiextensionsv1beta1.CustomResourceDefinition

ResourceReservationCustomResourceDefinition returns the CRD definition 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) 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.