Documentation
¶
Index ¶
- Constants
- Variables
- func Resource(resource string) schema.GroupResource
- func ResourceReservationCustomResourceDefinition() *v1.CustomResourceDefinition
- func ResourceReservationCustomResourceDefinitionVersion() v1.CustomResourceDefinitionVersion
- type 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
- type ResourceReservationSpec
- type 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 ¶ added in v0.2.16
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 ¶ added in v0.2.16
func (rr *ResourceReservation) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from storage version v1beta2 to v1beta1
func (*ResourceReservation) ConvertTo ¶ added in v0.2.16
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 ¶
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.
Source Files