AllocationResultResourceHandlesMaxSize represents the maximum number of entries in allocation.resourceHandles.
const AllocationResultResourceHandlesMaxSize = 32
const (
// Finalizer is the finalizer that gets set for claims
// which were allocated through a builtin controller.
Finalizer = "dra.k8s.io/delete-protection"
)
GroupName is the group name use in this package
const GroupName = "resource.k8s.io"
PodSchedulingNodeListMaxSize defines the maximum number of entries in the node lists that are stored in PodSchedulingContext objects. This limit is part of the API.
const PodSchedulingNodeListMaxSize = 128
ReservedForMaxSize is the maximum number of entries in claim.status.reservedFor.
const ResourceClaimReservedForMaxSize = 32
ResourceHandleDataMaxSize represents the maximum size of resourceHandle.data.
const ResourceHandleDataMaxSize = 16 * 1024
var (
ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow")
ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
var (
// We only register manually written functions here. The registration of the
// generated functions takes place in the generated files. The separation
// makes the code compile even when the generated files are missing.
SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
AddToScheme = SchemeBuilder.AddToScheme
)
SchemeGroupVersion is group version used to register these objects
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1alpha2"}
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
AllocationMode describes whether a ResourceClaim gets allocated immediately when it gets created (AllocationModeImmediate) or whether allocation is delayed until it is needed for a Pod (AllocationModeWaitForFirstConsumer). Other modes might get added in the future.
type AllocationMode string
const (
// When a ResourceClaim has AllocationModeWaitForFirstConsumer, allocation is
// delayed until a Pod gets scheduled that needs the ResourceClaim. The
// scheduler will consider all resource requirements of that Pod and
// trigger allocation for a node that fits the Pod.
AllocationModeWaitForFirstConsumer AllocationMode = "WaitForFirstConsumer"
// When a ResourceClaim has AllocationModeImmediate, allocation starts
// as soon as the ResourceClaim gets created. This is done without
// considering the needs of Pods that will use the ResourceClaim
// because those Pods are not known yet.
AllocationModeImmediate AllocationMode = "Immediate"
)
AllocationResult contains attributes of an allocated resource.
type AllocationResult struct {
// ResourceHandles contain the state associated with an allocation that
// should be maintained throughout the lifetime of a claim. Each
// ResourceHandle contains data that should be passed to a specific kubelet
// plugin once it lands on a node. This data is returned by the driver
// after a successful allocation and is opaque to Kubernetes. Driver
// documentation may explain to users how to interpret this data if needed.
//
// Setting this field is optional. It has a maximum size of 32 entries.
// If null (or empty), it is assumed this allocation will be processed by a
// single kubelet plugin with no ResourceHandle data attached. The name of
// the kubelet plugin invoked will match the DriverName set in the
// ResourceClaimStatus this AllocationResult is embedded in.
//
// +listType=atomic
// +optional
ResourceHandles []ResourceHandle `json:"resourceHandles,omitempty" protobuf:"bytes,1,opt,name=resourceHandles"`
// This field will get set by the resource driver after it has allocated
// the resource to inform the scheduler where it can schedule Pods using
// the ResourceClaim.
//
// Setting this field is optional. If null, the resource is available
// everywhere.
// +optional
AvailableOnNodes *v1.NodeSelector `json:"availableOnNodes,omitempty" protobuf:"bytes,2,opt,name=availableOnNodes"`
// Shareable determines whether the resource supports more
// than one consumer at a time.
// +optional
Shareable bool `json:"shareable,omitempty" protobuf:"varint,3,opt,name=shareable"`
}
func (in *AllocationResult) DeepCopy() *AllocationResult
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AllocationResult.
func (in *AllocationResult) DeepCopyInto(out *AllocationResult)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AllocationResult) Descriptor() ([]byte, []int)
func (m *AllocationResult) Marshal() (dAtA []byte, err error)
func (m *AllocationResult) MarshalTo(dAtA []byte) (int, error)
func (m *AllocationResult) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AllocationResult) ProtoMessage()
func (m *AllocationResult) Reset()
func (m *AllocationResult) Size() (n int)
func (this *AllocationResult) String() string
func (AllocationResult) SwaggerDoc() map[string]string
func (m *AllocationResult) Unmarshal(dAtA []byte) error
func (m *AllocationResult) XXX_DiscardUnknown()
func (m *AllocationResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *AllocationResult) XXX_Merge(src proto.Message)
func (m *AllocationResult) XXX_Size() int
func (m *AllocationResult) XXX_Unmarshal(b []byte) error
AllocationResultModel must have one and only one field set.
type AllocationResultModel struct {
// NamedResources describes the allocation result when using the named resources model.
//
// +optional
NamedResources *NamedResourcesAllocationResult `json:"namedResources,omitempty" protobuf:"bytes,1,opt,name=namedResources"`
}
func (in *AllocationResultModel) DeepCopy() *AllocationResultModel
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AllocationResultModel.
func (in *AllocationResultModel) DeepCopyInto(out *AllocationResultModel)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AllocationResultModel) Descriptor() ([]byte, []int)
func (m *AllocationResultModel) Marshal() (dAtA []byte, err error)
func (m *AllocationResultModel) MarshalTo(dAtA []byte) (int, error)
func (m *AllocationResultModel) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AllocationResultModel) ProtoMessage()
func (m *AllocationResultModel) Reset()
func (m *AllocationResultModel) Size() (n int)
func (this *AllocationResultModel) String() string
func (AllocationResultModel) SwaggerDoc() map[string]string
func (m *AllocationResultModel) Unmarshal(dAtA []byte) error
func (m *AllocationResultModel) XXX_DiscardUnknown()
func (m *AllocationResultModel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *AllocationResultModel) XXX_Merge(src proto.Message)
func (m *AllocationResultModel) XXX_Size() int
func (m *AllocationResultModel) XXX_Unmarshal(b []byte) error
DriverAllocationResult contains vendor parameters and the allocation result for one request.
type DriverAllocationResult struct {
// VendorRequestParameters are the per-request configuration parameters
// from the time that the claim was allocated.
//
// +optional
VendorRequestParameters runtime.RawExtension `json:"vendorRequestParameters,omitempty" protobuf:"bytes,1,opt,name=vendorRequestParameters"`
AllocationResultModel `json:",inline" protobuf:"bytes,2,name=allocationResultModel"`
}
func (in *DriverAllocationResult) DeepCopy() *DriverAllocationResult
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DriverAllocationResult.
func (in *DriverAllocationResult) DeepCopyInto(out *DriverAllocationResult)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DriverAllocationResult) Descriptor() ([]byte, []int)
func (m *DriverAllocationResult) Marshal() (dAtA []byte, err error)
func (m *DriverAllocationResult) MarshalTo(dAtA []byte) (int, error)
func (m *DriverAllocationResult) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DriverAllocationResult) ProtoMessage()
func (m *DriverAllocationResult) Reset()
func (m *DriverAllocationResult) Size() (n int)
func (this *DriverAllocationResult) String() string
func (DriverAllocationResult) SwaggerDoc() map[string]string
func (m *DriverAllocationResult) Unmarshal(dAtA []byte) error
func (m *DriverAllocationResult) XXX_DiscardUnknown()
func (m *DriverAllocationResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *DriverAllocationResult) XXX_Merge(src proto.Message)
func (m *DriverAllocationResult) XXX_Size() int
func (m *DriverAllocationResult) XXX_Unmarshal(b []byte) error
DriverRequests describes all resources that are needed from one particular driver.
type DriverRequests struct {
// DriverName is the name used by the DRA driver kubelet plugin.
DriverName string `json:"driverName,omitempty" protobuf:"bytes,1,opt,name=driverName"`
// VendorParameters are arbitrary setup parameters for all requests of the
// claim. They are ignored while allocating the claim.
//
// +optional
VendorParameters runtime.RawExtension `json:"vendorParameters,omitempty" protobuf:"bytes,2,opt,name=vendorParameters"`
// Requests describes all resources that are needed from the driver.
// +listType=atomic
Requests []ResourceRequest `json:"requests,omitempty" protobuf:"bytes,3,opt,name=requests"`
}
func (in *DriverRequests) DeepCopy() *DriverRequests
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DriverRequests.
func (in *DriverRequests) DeepCopyInto(out *DriverRequests)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DriverRequests) Descriptor() ([]byte, []int)
func (m *DriverRequests) Marshal() (dAtA []byte, err error)
func (m *DriverRequests) MarshalTo(dAtA []byte) (int, error)
func (m *DriverRequests) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DriverRequests) ProtoMessage()
func (m *DriverRequests) Reset()
func (m *DriverRequests) Size() (n int)
func (this *DriverRequests) String() string
func (DriverRequests) SwaggerDoc() map[string]string
func (m *DriverRequests) Unmarshal(dAtA []byte) error
func (m *DriverRequests) XXX_DiscardUnknown()
func (m *DriverRequests) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *DriverRequests) XXX_Merge(src proto.Message)
func (m *DriverRequests) XXX_Size() int
func (m *DriverRequests) XXX_Unmarshal(b []byte) error
NamedResourcesAllocationResult is used in AllocationResultModel.
type NamedResourcesAllocationResult struct {
// Name is the name of the selected resource instance.
Name string `json:"name" protobuf:"bytes,1,name=name"`
}
func (in *NamedResourcesAllocationResult) DeepCopy() *NamedResourcesAllocationResult
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NamedResourcesAllocationResult.
func (in *NamedResourcesAllocationResult) DeepCopyInto(out *NamedResourcesAllocationResult)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NamedResourcesAllocationResult) Descriptor() ([]byte, []int)
func (m *NamedResourcesAllocationResult) Marshal() (dAtA []byte, err error)
func (m *NamedResourcesAllocationResult) MarshalTo(dAtA []byte) (int, error)
func (m *NamedResourcesAllocationResult) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamedResourcesAllocationResult) ProtoMessage()
func (m *NamedResourcesAllocationResult) Reset()
func (m *NamedResourcesAllocationResult) Size() (n int)
func (this *NamedResourcesAllocationResult) String() string
func (m *NamedResourcesAllocationResult) Unmarshal(dAtA []byte) error
func (m *NamedResourcesAllocationResult) XXX_DiscardUnknown()
func (m *NamedResourcesAllocationResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *NamedResourcesAllocationResult) XXX_Merge(src proto.Message)
func (m *NamedResourcesAllocationResult) XXX_Size() int
func (m *NamedResourcesAllocationResult) XXX_Unmarshal(b []byte) error
NamedResourcesAttribute is a combination of an attribute name and its value.
type NamedResourcesAttribute struct {
// Name is unique identifier among all resource instances managed by
// the driver on the node. It must be a DNS subdomain.
Name string `json:"name" protobuf:"bytes,1,name=name"`
NamedResourcesAttributeValue `json:",inline" protobuf:"bytes,2,opt,name=attributeValue"`
}
func (in *NamedResourcesAttribute) DeepCopy() *NamedResourcesAttribute
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NamedResourcesAttribute.
func (in *NamedResourcesAttribute) DeepCopyInto(out *NamedResourcesAttribute)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NamedResourcesAttribute) Descriptor() ([]byte, []int)
func (m *NamedResourcesAttribute) Marshal() (dAtA []byte, err error)
func (m *NamedResourcesAttribute) MarshalTo(dAtA []byte) (int, error)
func (m *NamedResourcesAttribute) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamedResourcesAttribute) ProtoMessage()
func (m *NamedResourcesAttribute) Reset()
func (m *NamedResourcesAttribute) Size() (n int)
func (this *NamedResourcesAttribute) String() string
func (m *NamedResourcesAttribute) Unmarshal(dAtA []byte) error
func (m *NamedResourcesAttribute) XXX_DiscardUnknown()
func (m *NamedResourcesAttribute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *NamedResourcesAttribute) XXX_Merge(src proto.Message)
func (m *NamedResourcesAttribute) XXX_Size() int
func (m *NamedResourcesAttribute) XXX_Unmarshal(b []byte) error
NamedResourcesAttributeValue must have one and only one field set.
type NamedResourcesAttributeValue struct {
// QuantityValue is a quantity.
QuantityValue *resource.Quantity `json:"quantity,omitempty" protobuf:"bytes,6,opt,name=quantity"`
// BoolValue is a true/false value.
BoolValue *bool `json:"bool,omitempty" protobuf:"bytes,2,opt,name=bool"`
// IntValue is a 64-bit integer.
IntValue *int64 `json:"int,omitempty" protobuf:"varint,7,opt,name=int"`
// IntSliceValue is an array of 64-bit integers.
IntSliceValue *NamedResourcesIntSlice `json:"intSlice,omitempty" protobuf:"varint,8,rep,name=intSlice"`
// StringValue is a string.
StringValue *string `json:"string,omitempty" protobuf:"bytes,5,opt,name=string"`
// StringSliceValue is an array of strings.
StringSliceValue *NamedResourcesStringSlice `json:"stringSlice,omitempty" protobuf:"bytes,9,rep,name=stringSlice"`
// VersionValue is a semantic version according to semver.org spec 2.0.0.
VersionValue *string `json:"version,omitempty" protobuf:"bytes,10,opt,name=version"`
}
func (in *NamedResourcesAttributeValue) DeepCopy() *NamedResourcesAttributeValue
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NamedResourcesAttributeValue.
func (in *NamedResourcesAttributeValue) DeepCopyInto(out *NamedResourcesAttributeValue)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NamedResourcesAttributeValue) Descriptor() ([]byte, []int)
func (m *NamedResourcesAttributeValue) Marshal() (dAtA []byte, err error)
func (m *NamedResourcesAttributeValue) MarshalTo(dAtA []byte) (int, error)
func (m *NamedResourcesAttributeValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamedResourcesAttributeValue) ProtoMessage()
func (m *NamedResourcesAttributeValue) Reset()
func (m *NamedResourcesAttributeValue) Size() (n int)
func (this *NamedResourcesAttributeValue) String() string
func (m *NamedResourcesAttributeValue) Unmarshal(dAtA []byte) error
func (m *NamedResourcesAttributeValue) XXX_DiscardUnknown()
func (m *NamedResourcesAttributeValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *NamedResourcesAttributeValue) XXX_Merge(src proto.Message)
func (m *NamedResourcesAttributeValue) XXX_Size() int
func (m *NamedResourcesAttributeValue) XXX_Unmarshal(b []byte) error
NamedResourcesFilter is used in ResourceFilterModel.
type NamedResourcesFilter struct {
// Selector is a CEL expression which must evaluate to true if a
// resource instance is suitable. The language is as defined in
// https://kubernetes.io/docs/reference/using-api/cel/
//
// In addition, for each type NamedResourcesin AttributeValue there is a map that
// resolves to the corresponding value of the instance under evaluation.
// For example:
//
// attributes.quantity["a"].isGreaterThan(quantity("0")) &&
// attributes.stringslice["b"].isSorted()
Selector string `json:"selector" protobuf:"bytes,1,name=selector"`
}
func (in *NamedResourcesFilter) DeepCopy() *NamedResourcesFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NamedResourcesFilter.
func (in *NamedResourcesFilter) DeepCopyInto(out *NamedResourcesFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NamedResourcesFilter) Descriptor() ([]byte, []int)
func (m *NamedResourcesFilter) Marshal() (dAtA []byte, err error)
func (m *NamedResourcesFilter) MarshalTo(dAtA []byte) (int, error)
func (m *NamedResourcesFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamedResourcesFilter) ProtoMessage()
func (m *NamedResourcesFilter) Reset()
func (m *NamedResourcesFilter) Size() (n int)
func (this *NamedResourcesFilter) String() string
func (m *NamedResourcesFilter) Unmarshal(dAtA []byte) error
func (m *NamedResourcesFilter) XXX_DiscardUnknown()
func (m *NamedResourcesFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *NamedResourcesFilter) XXX_Merge(src proto.Message)
func (m *NamedResourcesFilter) XXX_Size() int
func (m *NamedResourcesFilter) XXX_Unmarshal(b []byte) error
NamedResourcesInstance represents one individual hardware instance that can be selected based on its attributes.
type NamedResourcesInstance struct {
// Name is unique identifier among all resource instances managed by
// the driver on the node. It must be a DNS subdomain.
Name string `json:"name" protobuf:"bytes,1,name=name"`
// Attributes defines the attributes of this resource instance.
// The name of each attribute must be unique.
//
// +listType=atomic
// +optional
Attributes []NamedResourcesAttribute `json:"attributes,omitempty" protobuf:"bytes,2,opt,name=attributes"`
}
func (in *NamedResourcesInstance) DeepCopy() *NamedResourcesInstance
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NamedResourcesInstance.
func (in *NamedResourcesInstance) DeepCopyInto(out *NamedResourcesInstance)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NamedResourcesInstance) Descriptor() ([]byte, []int)
func (m *NamedResourcesInstance) Marshal() (dAtA []byte, err error)
func (m *NamedResourcesInstance) MarshalTo(dAtA []byte) (int, error)
func (m *NamedResourcesInstance) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamedResourcesInstance) ProtoMessage()
func (m *NamedResourcesInstance) Reset()
func (m *NamedResourcesInstance) Size() (n int)
func (this *NamedResourcesInstance) String() string
func (m *NamedResourcesInstance) Unmarshal(dAtA []byte) error
func (m *NamedResourcesInstance) XXX_DiscardUnknown()
func (m *NamedResourcesInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *NamedResourcesInstance) XXX_Merge(src proto.Message)
func (m *NamedResourcesInstance) XXX_Size() int
func (m *NamedResourcesInstance) XXX_Unmarshal(b []byte) error
NamedResourcesIntSlice contains a slice of 64-bit integers.
type NamedResourcesIntSlice struct {
// Ints is the slice of 64-bit integers.
//
// +listType=atomic
Ints []int64 `json:"ints" protobuf:"bytes,1,opt,name=ints"`
}
func (in *NamedResourcesIntSlice) DeepCopy() *NamedResourcesIntSlice
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NamedResourcesIntSlice.
func (in *NamedResourcesIntSlice) DeepCopyInto(out *NamedResourcesIntSlice)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NamedResourcesIntSlice) Descriptor() ([]byte, []int)
func (m *NamedResourcesIntSlice) Marshal() (dAtA []byte, err error)
func (m *NamedResourcesIntSlice) MarshalTo(dAtA []byte) (int, error)
func (m *NamedResourcesIntSlice) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamedResourcesIntSlice) ProtoMessage()
func (m *NamedResourcesIntSlice) Reset()
func (m *NamedResourcesIntSlice) Size() (n int)
func (this *NamedResourcesIntSlice) String() string
func (m *NamedResourcesIntSlice) Unmarshal(dAtA []byte) error
func (m *NamedResourcesIntSlice) XXX_DiscardUnknown()
func (m *NamedResourcesIntSlice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *NamedResourcesIntSlice) XXX_Merge(src proto.Message)
func (m *NamedResourcesIntSlice) XXX_Size() int
func (m *NamedResourcesIntSlice) XXX_Unmarshal(b []byte) error
NamedResourcesRequest is used in ResourceRequestModel.
type NamedResourcesRequest struct {
// Selector is a CEL expression which must evaluate to true if a
// resource instance is suitable. The language is as defined in
// https://kubernetes.io/docs/reference/using-api/cel/
//
// In addition, for each type NamedResourcesin AttributeValue there is a map that
// resolves to the corresponding value of the instance under evaluation.
// For example:
//
// attributes.quantity["a"].isGreaterThan(quantity("0")) &&
// attributes.stringslice["b"].isSorted()
Selector string `json:"selector" protobuf:"bytes,1,name=selector"`
}
func (in *NamedResourcesRequest) DeepCopy() *NamedResourcesRequest
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NamedResourcesRequest.
func (in *NamedResourcesRequest) DeepCopyInto(out *NamedResourcesRequest)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NamedResourcesRequest) Descriptor() ([]byte, []int)
func (m *NamedResourcesRequest) Marshal() (dAtA []byte, err error)
func (m *NamedResourcesRequest) MarshalTo(dAtA []byte) (int, error)
func (m *NamedResourcesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamedResourcesRequest) ProtoMessage()
func (m *NamedResourcesRequest) Reset()
func (m *NamedResourcesRequest) Size() (n int)
func (this *NamedResourcesRequest) String() string
func (m *NamedResourcesRequest) Unmarshal(dAtA []byte) error
func (m *NamedResourcesRequest) XXX_DiscardUnknown()
func (m *NamedResourcesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *NamedResourcesRequest) XXX_Merge(src proto.Message)
func (m *NamedResourcesRequest) XXX_Size() int
func (m *NamedResourcesRequest) XXX_Unmarshal(b []byte) error
NamedResourcesResources is used in ResourceModel.
type NamedResourcesResources struct {
// The list of all individual resources instances currently available.
//
// +listType=atomic
Instances []NamedResourcesInstance `json:"instances" protobuf:"bytes,1,name=instances"`
}
func (in *NamedResourcesResources) DeepCopy() *NamedResourcesResources
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NamedResourcesResources.
func (in *NamedResourcesResources) DeepCopyInto(out *NamedResourcesResources)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NamedResourcesResources) Descriptor() ([]byte, []int)
func (m *NamedResourcesResources) Marshal() (dAtA []byte, err error)
func (m *NamedResourcesResources) MarshalTo(dAtA []byte) (int, error)
func (m *NamedResourcesResources) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamedResourcesResources) ProtoMessage()
func (m *NamedResourcesResources) Reset()
func (m *NamedResourcesResources) Size() (n int)
func (this *NamedResourcesResources) String() string
func (m *NamedResourcesResources) Unmarshal(dAtA []byte) error
func (m *NamedResourcesResources) XXX_DiscardUnknown()
func (m *NamedResourcesResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *NamedResourcesResources) XXX_Merge(src proto.Message)
func (m *NamedResourcesResources) XXX_Size() int
func (m *NamedResourcesResources) XXX_Unmarshal(b []byte) error
NamedResourcesStringSlice contains a slice of strings.
type NamedResourcesStringSlice struct {
// Strings is the slice of strings.
//
// +listType=atomic
Strings []string `json:"strings" protobuf:"bytes,1,opt,name=strings"`
}
func (in *NamedResourcesStringSlice) DeepCopy() *NamedResourcesStringSlice
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NamedResourcesStringSlice.
func (in *NamedResourcesStringSlice) DeepCopyInto(out *NamedResourcesStringSlice)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NamedResourcesStringSlice) Descriptor() ([]byte, []int)
func (m *NamedResourcesStringSlice) Marshal() (dAtA []byte, err error)
func (m *NamedResourcesStringSlice) MarshalTo(dAtA []byte) (int, error)
func (m *NamedResourcesStringSlice) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamedResourcesStringSlice) ProtoMessage()
func (m *NamedResourcesStringSlice) Reset()
func (m *NamedResourcesStringSlice) Size() (n int)
func (this *NamedResourcesStringSlice) String() string
func (m *NamedResourcesStringSlice) Unmarshal(dAtA []byte) error
func (m *NamedResourcesStringSlice) XXX_DiscardUnknown()
func (m *NamedResourcesStringSlice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *NamedResourcesStringSlice) XXX_Merge(src proto.Message)
func (m *NamedResourcesStringSlice) XXX_Size() int
func (m *NamedResourcesStringSlice) XXX_Unmarshal(b []byte) error
PodSchedulingContext objects hold information that is needed to schedule a Pod with ResourceClaims that use "WaitForFirstConsumer" allocation mode.
This is an alpha type and requires enabling the DynamicResourceAllocation feature gate.
type PodSchedulingContext struct {
metav1.TypeMeta `json:",inline"`
// Standard object metadata
// +optional
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Spec describes where resources for the Pod are needed.
Spec PodSchedulingContextSpec `json:"spec" protobuf:"bytes,2,name=spec"`
// Status describes where resources for the Pod can be allocated.
// +optional
Status PodSchedulingContextStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}
func (in *PodSchedulingContext) DeepCopy() *PodSchedulingContext
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodSchedulingContext.
func (in *PodSchedulingContext) DeepCopyInto(out *PodSchedulingContext)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *PodSchedulingContext) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*PodSchedulingContext) Descriptor() ([]byte, []int)
func (m *PodSchedulingContext) Marshal() (dAtA []byte, err error)
func (m *PodSchedulingContext) MarshalTo(dAtA []byte) (int, error)
func (m *PodSchedulingContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PodSchedulingContext) ProtoMessage()
func (m *PodSchedulingContext) Reset()
func (m *PodSchedulingContext) Size() (n int)
func (this *PodSchedulingContext) String() string
func (PodSchedulingContext) SwaggerDoc() map[string]string
func (m *PodSchedulingContext) Unmarshal(dAtA []byte) error
func (m *PodSchedulingContext) XXX_DiscardUnknown()
func (m *PodSchedulingContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *PodSchedulingContext) XXX_Merge(src proto.Message)
func (m *PodSchedulingContext) XXX_Size() int
func (m *PodSchedulingContext) XXX_Unmarshal(b []byte) error
PodSchedulingContextList is a collection of Pod scheduling objects.
type PodSchedulingContextList struct {
metav1.TypeMeta `json:",inline"`
// Standard list metadata
// +optional
metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Items is the list of PodSchedulingContext objects.
Items []PodSchedulingContext `json:"items" protobuf:"bytes,2,rep,name=items"`
}
func (in *PodSchedulingContextList) DeepCopy() *PodSchedulingContextList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodSchedulingContextList.
func (in *PodSchedulingContextList) DeepCopyInto(out *PodSchedulingContextList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *PodSchedulingContextList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*PodSchedulingContextList) Descriptor() ([]byte, []int)
func (m *PodSchedulingContextList) Marshal() (dAtA []byte, err error)
func (m *PodSchedulingContextList) MarshalTo(dAtA []byte) (int, error)
func (m *PodSchedulingContextList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PodSchedulingContextList) ProtoMessage()
func (m *PodSchedulingContextList) Reset()
func (m *PodSchedulingContextList) Size() (n int)
func (this *PodSchedulingContextList) String() string
func (PodSchedulingContextList) SwaggerDoc() map[string]string
func (m *PodSchedulingContextList) Unmarshal(dAtA []byte) error
func (m *PodSchedulingContextList) XXX_DiscardUnknown()
func (m *PodSchedulingContextList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *PodSchedulingContextList) XXX_Merge(src proto.Message)
func (m *PodSchedulingContextList) XXX_Size() int
func (m *PodSchedulingContextList) XXX_Unmarshal(b []byte) error
PodSchedulingContextSpec describes where resources for the Pod are needed.
type PodSchedulingContextSpec struct {
// SelectedNode is the node for which allocation of ResourceClaims that
// are referenced by the Pod and that use "WaitForFirstConsumer"
// allocation is to be attempted.
// +optional
SelectedNode string `json:"selectedNode,omitempty" protobuf:"bytes,1,opt,name=selectedNode"`
// PotentialNodes lists nodes where the Pod might be able to run.
//
// The size of this field is limited to 128. This is large enough for
// many clusters. Larger clusters may need more attempts to find a node
// that suits all pending resources. This may get increased in the
// future, but not reduced.
//
// +listType=atomic
// +optional
PotentialNodes []string `json:"potentialNodes,omitempty" protobuf:"bytes,2,opt,name=potentialNodes"`
}
func (in *PodSchedulingContextSpec) DeepCopy() *PodSchedulingContextSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodSchedulingContextSpec.
func (in *PodSchedulingContextSpec) DeepCopyInto(out *PodSchedulingContextSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PodSchedulingContextSpec) Descriptor() ([]byte, []int)
func (m *PodSchedulingContextSpec) Marshal() (dAtA []byte, err error)
func (m *PodSchedulingContextSpec) MarshalTo(dAtA []byte) (int, error)
func (m *PodSchedulingContextSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PodSchedulingContextSpec) ProtoMessage()
func (m *PodSchedulingContextSpec) Reset()
func (m *PodSchedulingContextSpec) Size() (n int)
func (this *PodSchedulingContextSpec) String() string
func (PodSchedulingContextSpec) SwaggerDoc() map[string]string
func (m *PodSchedulingContextSpec) Unmarshal(dAtA []byte) error
func (m *PodSchedulingContextSpec) XXX_DiscardUnknown()
func (m *PodSchedulingContextSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *PodSchedulingContextSpec) XXX_Merge(src proto.Message)
func (m *PodSchedulingContextSpec) XXX_Size() int
func (m *PodSchedulingContextSpec) XXX_Unmarshal(b []byte) error
PodSchedulingContextStatus describes where resources for the Pod can be allocated.
type PodSchedulingContextStatus struct {
// ResourceClaims describes resource availability for each
// pod.spec.resourceClaim entry where the corresponding ResourceClaim
// uses "WaitForFirstConsumer" allocation mode.
//
// +listType=map
// +listMapKey=name
// +optional
ResourceClaims []ResourceClaimSchedulingStatus `json:"resourceClaims,omitempty" protobuf:"bytes,1,opt,name=resourceClaims"`
}
func (in *PodSchedulingContextStatus) DeepCopy() *PodSchedulingContextStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodSchedulingContextStatus.
func (in *PodSchedulingContextStatus) DeepCopyInto(out *PodSchedulingContextStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PodSchedulingContextStatus) Descriptor() ([]byte, []int)
func (m *PodSchedulingContextStatus) Marshal() (dAtA []byte, err error)
func (m *PodSchedulingContextStatus) MarshalTo(dAtA []byte) (int, error)
func (m *PodSchedulingContextStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PodSchedulingContextStatus) ProtoMessage()
func (m *PodSchedulingContextStatus) Reset()
func (m *PodSchedulingContextStatus) Size() (n int)
func (this *PodSchedulingContextStatus) String() string
func (PodSchedulingContextStatus) SwaggerDoc() map[string]string
func (m *PodSchedulingContextStatus) Unmarshal(dAtA []byte) error
func (m *PodSchedulingContextStatus) XXX_DiscardUnknown()
func (m *PodSchedulingContextStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *PodSchedulingContextStatus) XXX_Merge(src proto.Message)
func (m *PodSchedulingContextStatus) XXX_Size() int
func (m *PodSchedulingContextStatus) XXX_Unmarshal(b []byte) error
ResourceClaim describes which resources are needed by a resource consumer. Its status tracks whether the resource has been allocated and what the resulting attributes are.
This is an alpha type and requires enabling the DynamicResourceAllocation feature gate.
type ResourceClaim struct {
metav1.TypeMeta `json:",inline"`
// Standard object metadata
// +optional
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Spec describes the desired attributes of a resource that then needs
// to be allocated. It can only be set once when creating the
// ResourceClaim.
Spec ResourceClaimSpec `json:"spec" protobuf:"bytes,2,name=spec"`
// Status describes whether the resource is available and with which
// attributes.
// +optional
Status ResourceClaimStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}
func (in *ResourceClaim) DeepCopy() *ResourceClaim
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClaim.
func (in *ResourceClaim) DeepCopyInto(out *ResourceClaim)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ResourceClaim) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ResourceClaim) Descriptor() ([]byte, []int)
func (m *ResourceClaim) Marshal() (dAtA []byte, err error)
func (m *ResourceClaim) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClaim) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClaim) ProtoMessage()
func (m *ResourceClaim) Reset()
func (m *ResourceClaim) Size() (n int)
func (this *ResourceClaim) String() string
func (ResourceClaim) SwaggerDoc() map[string]string
func (m *ResourceClaim) Unmarshal(dAtA []byte) error
func (m *ResourceClaim) XXX_DiscardUnknown()
func (m *ResourceClaim) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClaim) XXX_Merge(src proto.Message)
func (m *ResourceClaim) XXX_Size() int
func (m *ResourceClaim) XXX_Unmarshal(b []byte) error
ResourceClaimConsumerReference contains enough information to let you locate the consumer of a ResourceClaim. The user must be a resource in the same namespace as the ResourceClaim.
type ResourceClaimConsumerReference struct {
// APIGroup is the group for the resource being referenced. It is
// empty for the core API. This matches the group in the APIVersion
// that is used when creating the resources.
// +optional
APIGroup string `json:"apiGroup,omitempty" protobuf:"bytes,1,opt,name=apiGroup"`
// Resource is the type of resource being referenced, for example "pods".
Resource string `json:"resource" protobuf:"bytes,3,name=resource"`
// Name is the name of resource being referenced.
Name string `json:"name" protobuf:"bytes,4,name=name"`
// UID identifies exactly one incarnation of the resource.
UID types.UID `json:"uid" protobuf:"bytes,5,name=uid"`
}
func (in *ResourceClaimConsumerReference) DeepCopy() *ResourceClaimConsumerReference
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClaimConsumerReference.
func (in *ResourceClaimConsumerReference) DeepCopyInto(out *ResourceClaimConsumerReference)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceClaimConsumerReference) Descriptor() ([]byte, []int)
func (m *ResourceClaimConsumerReference) Marshal() (dAtA []byte, err error)
func (m *ResourceClaimConsumerReference) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClaimConsumerReference) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClaimConsumerReference) ProtoMessage()
func (m *ResourceClaimConsumerReference) Reset()
func (m *ResourceClaimConsumerReference) Size() (n int)
func (this *ResourceClaimConsumerReference) String() string
func (ResourceClaimConsumerReference) SwaggerDoc() map[string]string
func (m *ResourceClaimConsumerReference) Unmarshal(dAtA []byte) error
func (m *ResourceClaimConsumerReference) XXX_DiscardUnknown()
func (m *ResourceClaimConsumerReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClaimConsumerReference) XXX_Merge(src proto.Message)
func (m *ResourceClaimConsumerReference) XXX_Size() int
func (m *ResourceClaimConsumerReference) XXX_Unmarshal(b []byte) error
ResourceClaimList is a collection of claims.
type ResourceClaimList struct {
metav1.TypeMeta `json:",inline"`
// Standard list metadata
// +optional
metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Items is the list of resource claims.
Items []ResourceClaim `json:"items" protobuf:"bytes,2,rep,name=items"`
}
func (in *ResourceClaimList) DeepCopy() *ResourceClaimList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClaimList.
func (in *ResourceClaimList) DeepCopyInto(out *ResourceClaimList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ResourceClaimList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ResourceClaimList) Descriptor() ([]byte, []int)
func (m *ResourceClaimList) Marshal() (dAtA []byte, err error)
func (m *ResourceClaimList) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClaimList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClaimList) ProtoMessage()
func (m *ResourceClaimList) Reset()
func (m *ResourceClaimList) Size() (n int)
func (this *ResourceClaimList) String() string
func (ResourceClaimList) SwaggerDoc() map[string]string
func (m *ResourceClaimList) Unmarshal(dAtA []byte) error
func (m *ResourceClaimList) XXX_DiscardUnknown()
func (m *ResourceClaimList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClaimList) XXX_Merge(src proto.Message)
func (m *ResourceClaimList) XXX_Size() int
func (m *ResourceClaimList) XXX_Unmarshal(b []byte) error
ResourceClaimParameters defines resource requests for a ResourceClaim in an in-tree format understood by Kubernetes.
type ResourceClaimParameters struct {
metav1.TypeMeta `json:",inline"`
// Standard object metadata
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// If this object was created from some other resource, then this links
// back to that resource. This field is used to find the in-tree representation
// of the claim parameters when the parameter reference of the claim refers
// to some unknown type.
// +optional
GeneratedFrom *ResourceClaimParametersReference `json:"generatedFrom,omitempty" protobuf:"bytes,2,opt,name=generatedFrom"`
// Shareable indicates whether the allocated claim is meant to be shareable
// by multiple consumers at the same time.
// +optional
Shareable bool `json:"shareable,omitempty" protobuf:"bytes,3,opt,name=shareable"`
// DriverRequests describes all resources that are needed for the
// allocated claim. A single claim may use resources coming from
// different drivers. For each driver, this array has at most one
// entry which then may have one or more per-driver requests.
//
// May be empty, in which case the claim can always be allocated.
//
// +listType=atomic
DriverRequests []DriverRequests `json:"driverRequests,omitempty" protobuf:"bytes,4,opt,name=driverRequests"`
}
func (in *ResourceClaimParameters) DeepCopy() *ResourceClaimParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClaimParameters.
func (in *ResourceClaimParameters) DeepCopyInto(out *ResourceClaimParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ResourceClaimParameters) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ResourceClaimParameters) Descriptor() ([]byte, []int)
func (m *ResourceClaimParameters) Marshal() (dAtA []byte, err error)
func (m *ResourceClaimParameters) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClaimParameters) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClaimParameters) ProtoMessage()
func (m *ResourceClaimParameters) Reset()
func (m *ResourceClaimParameters) Size() (n int)
func (this *ResourceClaimParameters) String() string
func (ResourceClaimParameters) SwaggerDoc() map[string]string
func (m *ResourceClaimParameters) Unmarshal(dAtA []byte) error
func (m *ResourceClaimParameters) XXX_DiscardUnknown()
func (m *ResourceClaimParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClaimParameters) XXX_Merge(src proto.Message)
func (m *ResourceClaimParameters) XXX_Size() int
func (m *ResourceClaimParameters) XXX_Unmarshal(b []byte) error
ResourceClaimParametersList is a collection of ResourceClaimParameters.
type ResourceClaimParametersList struct {
metav1.TypeMeta `json:",inline"`
// Standard list metadata
// +optional
metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Items is the list of node resource capacity objects.
Items []ResourceClaimParameters `json:"items" protobuf:"bytes,2,rep,name=items"`
}
func (in *ResourceClaimParametersList) DeepCopy() *ResourceClaimParametersList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClaimParametersList.
func (in *ResourceClaimParametersList) DeepCopyInto(out *ResourceClaimParametersList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ResourceClaimParametersList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ResourceClaimParametersList) Descriptor() ([]byte, []int)
func (m *ResourceClaimParametersList) Marshal() (dAtA []byte, err error)
func (m *ResourceClaimParametersList) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClaimParametersList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClaimParametersList) ProtoMessage()
func (m *ResourceClaimParametersList) Reset()
func (m *ResourceClaimParametersList) Size() (n int)
func (this *ResourceClaimParametersList) String() string
func (ResourceClaimParametersList) SwaggerDoc() map[string]string
func (m *ResourceClaimParametersList) Unmarshal(dAtA []byte) error
func (m *ResourceClaimParametersList) XXX_DiscardUnknown()
func (m *ResourceClaimParametersList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClaimParametersList) XXX_Merge(src proto.Message)
func (m *ResourceClaimParametersList) XXX_Size() int
func (m *ResourceClaimParametersList) XXX_Unmarshal(b []byte) error
ResourceClaimParametersReference contains enough information to let you locate the parameters for a ResourceClaim. The object must be in the same namespace as the ResourceClaim.
type ResourceClaimParametersReference struct {
// APIGroup is the group for the resource being referenced. It is
// empty for the core API. This matches the group in the APIVersion
// that is used when creating the resources.
// +optional
APIGroup string `json:"apiGroup,omitempty" protobuf:"bytes,1,opt,name=apiGroup"`
// Kind is the type of resource being referenced. This is the same
// value as in the parameter object's metadata, for example "ConfigMap".
Kind string `json:"kind" protobuf:"bytes,2,name=kind"`
// Name is the name of resource being referenced.
Name string `json:"name" protobuf:"bytes,3,name=name"`
}
func (in *ResourceClaimParametersReference) DeepCopy() *ResourceClaimParametersReference
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClaimParametersReference.
func (in *ResourceClaimParametersReference) DeepCopyInto(out *ResourceClaimParametersReference)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceClaimParametersReference) Descriptor() ([]byte, []int)
func (m *ResourceClaimParametersReference) Marshal() (dAtA []byte, err error)
func (m *ResourceClaimParametersReference) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClaimParametersReference) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClaimParametersReference) ProtoMessage()
func (m *ResourceClaimParametersReference) Reset()
func (m *ResourceClaimParametersReference) Size() (n int)
func (this *ResourceClaimParametersReference) String() string
func (ResourceClaimParametersReference) SwaggerDoc() map[string]string
func (m *ResourceClaimParametersReference) Unmarshal(dAtA []byte) error
func (m *ResourceClaimParametersReference) XXX_DiscardUnknown()
func (m *ResourceClaimParametersReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClaimParametersReference) XXX_Merge(src proto.Message)
func (m *ResourceClaimParametersReference) XXX_Size() int
func (m *ResourceClaimParametersReference) XXX_Unmarshal(b []byte) error
ResourceClaimSchedulingStatus contains information about one particular ResourceClaim with "WaitForFirstConsumer" allocation mode.
type ResourceClaimSchedulingStatus struct {
// Name matches the pod.spec.resourceClaims[*].Name field.
// +optional
Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
// UnsuitableNodes lists nodes that the ResourceClaim cannot be
// allocated for.
//
// The size of this field is limited to 128, the same as for
// PodSchedulingSpec.PotentialNodes. This may get increased in the
// future, but not reduced.
//
// +listType=atomic
// +optional
UnsuitableNodes []string `json:"unsuitableNodes,omitempty" protobuf:"bytes,2,opt,name=unsuitableNodes"`
}
func (in *ResourceClaimSchedulingStatus) DeepCopy() *ResourceClaimSchedulingStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClaimSchedulingStatus.
func (in *ResourceClaimSchedulingStatus) DeepCopyInto(out *ResourceClaimSchedulingStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceClaimSchedulingStatus) Descriptor() ([]byte, []int)
func (m *ResourceClaimSchedulingStatus) Marshal() (dAtA []byte, err error)
func (m *ResourceClaimSchedulingStatus) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClaimSchedulingStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClaimSchedulingStatus) ProtoMessage()
func (m *ResourceClaimSchedulingStatus) Reset()
func (m *ResourceClaimSchedulingStatus) Size() (n int)
func (this *ResourceClaimSchedulingStatus) String() string
func (ResourceClaimSchedulingStatus) SwaggerDoc() map[string]string
func (m *ResourceClaimSchedulingStatus) Unmarshal(dAtA []byte) error
func (m *ResourceClaimSchedulingStatus) XXX_DiscardUnknown()
func (m *ResourceClaimSchedulingStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClaimSchedulingStatus) XXX_Merge(src proto.Message)
func (m *ResourceClaimSchedulingStatus) XXX_Size() int
func (m *ResourceClaimSchedulingStatus) XXX_Unmarshal(b []byte) error
ResourceClaimSpec defines how a resource is to be allocated.
type ResourceClaimSpec struct {
// ResourceClassName references the driver and additional parameters
// via the name of a ResourceClass that was created as part of the
// driver deployment.
ResourceClassName string `json:"resourceClassName" protobuf:"bytes,1,name=resourceClassName"`
// ParametersRef references a separate object with arbitrary parameters
// that will be used by the driver when allocating a resource for the
// claim.
//
// The object must be in the same namespace as the ResourceClaim.
// +optional
ParametersRef *ResourceClaimParametersReference `json:"parametersRef,omitempty" protobuf:"bytes,2,opt,name=parametersRef"`
// Allocation can start immediately or when a Pod wants to use the
// resource. "WaitForFirstConsumer" is the default.
// +optional
AllocationMode AllocationMode `json:"allocationMode,omitempty" protobuf:"bytes,3,opt,name=allocationMode"`
}
func (in *ResourceClaimSpec) DeepCopy() *ResourceClaimSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClaimSpec.
func (in *ResourceClaimSpec) DeepCopyInto(out *ResourceClaimSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceClaimSpec) Descriptor() ([]byte, []int)
func (m *ResourceClaimSpec) Marshal() (dAtA []byte, err error)
func (m *ResourceClaimSpec) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClaimSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClaimSpec) ProtoMessage()
func (m *ResourceClaimSpec) Reset()
func (m *ResourceClaimSpec) Size() (n int)
func (this *ResourceClaimSpec) String() string
func (ResourceClaimSpec) SwaggerDoc() map[string]string
func (m *ResourceClaimSpec) Unmarshal(dAtA []byte) error
func (m *ResourceClaimSpec) XXX_DiscardUnknown()
func (m *ResourceClaimSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClaimSpec) XXX_Merge(src proto.Message)
func (m *ResourceClaimSpec) XXX_Size() int
func (m *ResourceClaimSpec) XXX_Unmarshal(b []byte) error
ResourceClaimStatus tracks whether the resource has been allocated and what the resulting attributes are.
type ResourceClaimStatus struct {
// DriverName is a copy of the driver name from the ResourceClass at
// the time when allocation started.
// +optional
DriverName string `json:"driverName,omitempty" protobuf:"bytes,1,opt,name=driverName"`
// Allocation is set by the resource driver once a resource or set of
// resources has been allocated successfully. If this is not specified, the
// resources have not been allocated yet.
// +optional
Allocation *AllocationResult `json:"allocation,omitempty" protobuf:"bytes,2,opt,name=allocation"`
// ReservedFor indicates which entities are currently allowed to use
// the claim. A Pod which references a ResourceClaim which is not
// reserved for that Pod will not be started.
//
// There can be at most 32 such reservations. This may get increased in
// the future, but not reduced.
//
// +listType=map
// +listMapKey=uid
// +patchStrategy=merge
// +patchMergeKey=uid
// +optional
ReservedFor []ResourceClaimConsumerReference `json:"reservedFor,omitempty" protobuf:"bytes,3,opt,name=reservedFor" patchStrategy:"merge" patchMergeKey:"uid"`
// DeallocationRequested indicates that a ResourceClaim is to be
// deallocated.
//
// The driver then must deallocate this claim and reset the field
// together with clearing the Allocation field.
//
// While DeallocationRequested is set, no new consumers may be added to
// ReservedFor.
// +optional
DeallocationRequested bool `json:"deallocationRequested,omitempty" protobuf:"varint,4,opt,name=deallocationRequested"`
}
func (in *ResourceClaimStatus) DeepCopy() *ResourceClaimStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClaimStatus.
func (in *ResourceClaimStatus) DeepCopyInto(out *ResourceClaimStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceClaimStatus) Descriptor() ([]byte, []int)
func (m *ResourceClaimStatus) Marshal() (dAtA []byte, err error)
func (m *ResourceClaimStatus) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClaimStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClaimStatus) ProtoMessage()
func (m *ResourceClaimStatus) Reset()
func (m *ResourceClaimStatus) Size() (n int)
func (this *ResourceClaimStatus) String() string
func (ResourceClaimStatus) SwaggerDoc() map[string]string
func (m *ResourceClaimStatus) Unmarshal(dAtA []byte) error
func (m *ResourceClaimStatus) XXX_DiscardUnknown()
func (m *ResourceClaimStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClaimStatus) XXX_Merge(src proto.Message)
func (m *ResourceClaimStatus) XXX_Size() int
func (m *ResourceClaimStatus) XXX_Unmarshal(b []byte) error
ResourceClaimTemplate is used to produce ResourceClaim objects.
type ResourceClaimTemplate struct {
metav1.TypeMeta `json:",inline"`
// Standard object metadata
// +optional
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Describes the ResourceClaim that is to be generated.
//
// This field is immutable. A ResourceClaim will get created by the
// control plane for a Pod when needed and then not get updated
// anymore.
Spec ResourceClaimTemplateSpec `json:"spec" protobuf:"bytes,2,name=spec"`
}
func (in *ResourceClaimTemplate) DeepCopy() *ResourceClaimTemplate
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClaimTemplate.
func (in *ResourceClaimTemplate) DeepCopyInto(out *ResourceClaimTemplate)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ResourceClaimTemplate) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ResourceClaimTemplate) Descriptor() ([]byte, []int)
func (m *ResourceClaimTemplate) Marshal() (dAtA []byte, err error)
func (m *ResourceClaimTemplate) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClaimTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClaimTemplate) ProtoMessage()
func (m *ResourceClaimTemplate) Reset()
func (m *ResourceClaimTemplate) Size() (n int)
func (this *ResourceClaimTemplate) String() string
func (ResourceClaimTemplate) SwaggerDoc() map[string]string
func (m *ResourceClaimTemplate) Unmarshal(dAtA []byte) error
func (m *ResourceClaimTemplate) XXX_DiscardUnknown()
func (m *ResourceClaimTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClaimTemplate) XXX_Merge(src proto.Message)
func (m *ResourceClaimTemplate) XXX_Size() int
func (m *ResourceClaimTemplate) XXX_Unmarshal(b []byte) error
ResourceClaimTemplateList is a collection of claim templates.
type ResourceClaimTemplateList struct {
metav1.TypeMeta `json:",inline"`
// Standard list metadata
// +optional
metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Items is the list of resource claim templates.
Items []ResourceClaimTemplate `json:"items" protobuf:"bytes,2,rep,name=items"`
}
func (in *ResourceClaimTemplateList) DeepCopy() *ResourceClaimTemplateList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClaimTemplateList.
func (in *ResourceClaimTemplateList) DeepCopyInto(out *ResourceClaimTemplateList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ResourceClaimTemplateList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ResourceClaimTemplateList) Descriptor() ([]byte, []int)
func (m *ResourceClaimTemplateList) Marshal() (dAtA []byte, err error)
func (m *ResourceClaimTemplateList) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClaimTemplateList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClaimTemplateList) ProtoMessage()
func (m *ResourceClaimTemplateList) Reset()
func (m *ResourceClaimTemplateList) Size() (n int)
func (this *ResourceClaimTemplateList) String() string
func (ResourceClaimTemplateList) SwaggerDoc() map[string]string
func (m *ResourceClaimTemplateList) Unmarshal(dAtA []byte) error
func (m *ResourceClaimTemplateList) XXX_DiscardUnknown()
func (m *ResourceClaimTemplateList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClaimTemplateList) XXX_Merge(src proto.Message)
func (m *ResourceClaimTemplateList) XXX_Size() int
func (m *ResourceClaimTemplateList) XXX_Unmarshal(b []byte) error
ResourceClaimTemplateSpec contains the metadata and fields for a ResourceClaim.
type ResourceClaimTemplateSpec struct {
// ObjectMeta may contain labels and annotations that will be copied into the PVC
// when creating it. No other fields are allowed and will be rejected during
// validation.
// +optional
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Spec for the ResourceClaim. The entire content is copied unchanged
// into the ResourceClaim that gets created from this template. The
// same fields as in a ResourceClaim are also valid here.
Spec ResourceClaimSpec `json:"spec" protobuf:"bytes,2,name=spec"`
}
func (in *ResourceClaimTemplateSpec) DeepCopy() *ResourceClaimTemplateSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClaimTemplateSpec.
func (in *ResourceClaimTemplateSpec) DeepCopyInto(out *ResourceClaimTemplateSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceClaimTemplateSpec) Descriptor() ([]byte, []int)
func (m *ResourceClaimTemplateSpec) Marshal() (dAtA []byte, err error)
func (m *ResourceClaimTemplateSpec) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClaimTemplateSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClaimTemplateSpec) ProtoMessage()
func (m *ResourceClaimTemplateSpec) Reset()
func (m *ResourceClaimTemplateSpec) Size() (n int)
func (this *ResourceClaimTemplateSpec) String() string
func (ResourceClaimTemplateSpec) SwaggerDoc() map[string]string
func (m *ResourceClaimTemplateSpec) Unmarshal(dAtA []byte) error
func (m *ResourceClaimTemplateSpec) XXX_DiscardUnknown()
func (m *ResourceClaimTemplateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClaimTemplateSpec) XXX_Merge(src proto.Message)
func (m *ResourceClaimTemplateSpec) XXX_Size() int
func (m *ResourceClaimTemplateSpec) XXX_Unmarshal(b []byte) error
ResourceClass is used by administrators to influence how resources are allocated.
This is an alpha type and requires enabling the DynamicResourceAllocation feature gate.
type ResourceClass struct {
metav1.TypeMeta `json:",inline"`
// Standard object metadata
// +optional
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// DriverName defines the name of the dynamic resource driver that is
// used for allocation of a ResourceClaim that uses this class.
//
// Resource drivers have a unique name in forward domain order
// (acme.example.com).
DriverName string `json:"driverName" protobuf:"bytes,2,name=driverName"`
// ParametersRef references an arbitrary separate object that may hold
// parameters that will be used by the driver when allocating a
// resource that uses this class. A dynamic resource driver can
// distinguish between parameters stored here and and those stored in
// ResourceClaimSpec.
// +optional
ParametersRef *ResourceClassParametersReference `json:"parametersRef,omitempty" protobuf:"bytes,3,opt,name=parametersRef"`
// Only nodes matching the selector will be considered by the scheduler
// when trying to find a Node that fits a Pod when that Pod uses
// a ResourceClaim that has not been allocated yet.
//
// Setting this field is optional. If null, all nodes are candidates.
// +optional
SuitableNodes *v1.NodeSelector `json:"suitableNodes,omitempty" protobuf:"bytes,4,opt,name=suitableNodes"`
// If and only if allocation of claims using this class is handled
// via structured parameters, then StructuredParameters must be set to true.
// +optional
StructuredParameters *bool `json:"structuredParameters,omitempty" protobuf:"bytes,5,opt,name=structuredParameters"`
}
func (in *ResourceClass) DeepCopy() *ResourceClass
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClass.
func (in *ResourceClass) DeepCopyInto(out *ResourceClass)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ResourceClass) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ResourceClass) Descriptor() ([]byte, []int)
func (m *ResourceClass) Marshal() (dAtA []byte, err error)
func (m *ResourceClass) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClass) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClass) ProtoMessage()
func (m *ResourceClass) Reset()
func (m *ResourceClass) Size() (n int)
func (this *ResourceClass) String() string
func (ResourceClass) SwaggerDoc() map[string]string
func (m *ResourceClass) Unmarshal(dAtA []byte) error
func (m *ResourceClass) XXX_DiscardUnknown()
func (m *ResourceClass) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClass) XXX_Merge(src proto.Message)
func (m *ResourceClass) XXX_Size() int
func (m *ResourceClass) XXX_Unmarshal(b []byte) error
ResourceClassList is a collection of classes.
type ResourceClassList struct {
metav1.TypeMeta `json:",inline"`
// Standard list metadata
// +optional
metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Items is the list of resource classes.
Items []ResourceClass `json:"items" protobuf:"bytes,2,rep,name=items"`
}
func (in *ResourceClassList) DeepCopy() *ResourceClassList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClassList.
func (in *ResourceClassList) DeepCopyInto(out *ResourceClassList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ResourceClassList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ResourceClassList) Descriptor() ([]byte, []int)
func (m *ResourceClassList) Marshal() (dAtA []byte, err error)
func (m *ResourceClassList) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClassList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClassList) ProtoMessage()
func (m *ResourceClassList) Reset()
func (m *ResourceClassList) Size() (n int)
func (this *ResourceClassList) String() string
func (ResourceClassList) SwaggerDoc() map[string]string
func (m *ResourceClassList) Unmarshal(dAtA []byte) error
func (m *ResourceClassList) XXX_DiscardUnknown()
func (m *ResourceClassList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClassList) XXX_Merge(src proto.Message)
func (m *ResourceClassList) XXX_Size() int
func (m *ResourceClassList) XXX_Unmarshal(b []byte) error
ResourceClassParameters defines resource requests for a ResourceClass in an in-tree format understood by Kubernetes.
type ResourceClassParameters struct {
metav1.TypeMeta `json:",inline"`
// Standard object metadata
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// If this object was created from some other resource, then this links
// back to that resource. This field is used to find the in-tree representation
// of the class parameters when the parameter reference of the class refers
// to some unknown type.
// +optional
GeneratedFrom *ResourceClassParametersReference `json:"generatedFrom,omitempty" protobuf:"bytes,2,opt,name=generatedFrom"`
// VendorParameters are arbitrary setup parameters for all claims using
// this class. They are ignored while allocating the claim. There must
// not be more than one entry per driver.
//
// +listType=atomic
// +optional
VendorParameters []VendorParameters `json:"vendorParameters,omitempty" protobuf:"bytes,3,opt,name=vendorParameters"`
// Filters describes additional contraints that must be met when using the class.
//
// +listType=atomic
Filters []ResourceFilter `json:"filters,omitempty" protobuf:"bytes,4,opt,name=filters"`
}
func (in *ResourceClassParameters) DeepCopy() *ResourceClassParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClassParameters.
func (in *ResourceClassParameters) DeepCopyInto(out *ResourceClassParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ResourceClassParameters) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ResourceClassParameters) Descriptor() ([]byte, []int)
func (m *ResourceClassParameters) Marshal() (dAtA []byte, err error)
func (m *ResourceClassParameters) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClassParameters) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClassParameters) ProtoMessage()
func (m *ResourceClassParameters) Reset()
func (m *ResourceClassParameters) Size() (n int)
func (this *ResourceClassParameters) String() string
func (ResourceClassParameters) SwaggerDoc() map[string]string
func (m *ResourceClassParameters) Unmarshal(dAtA []byte) error
func (m *ResourceClassParameters) XXX_DiscardUnknown()
func (m *ResourceClassParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClassParameters) XXX_Merge(src proto.Message)
func (m *ResourceClassParameters) XXX_Size() int
func (m *ResourceClassParameters) XXX_Unmarshal(b []byte) error
ResourceClassParametersList is a collection of ResourceClassParameters.
type ResourceClassParametersList struct {
metav1.TypeMeta `json:",inline"`
// Standard list metadata
// +optional
metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Items is the list of node resource capacity objects.
Items []ResourceClassParameters `json:"items" protobuf:"bytes,2,rep,name=items"`
}
func (in *ResourceClassParametersList) DeepCopy() *ResourceClassParametersList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClassParametersList.
func (in *ResourceClassParametersList) DeepCopyInto(out *ResourceClassParametersList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ResourceClassParametersList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ResourceClassParametersList) Descriptor() ([]byte, []int)
func (m *ResourceClassParametersList) Marshal() (dAtA []byte, err error)
func (m *ResourceClassParametersList) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClassParametersList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClassParametersList) ProtoMessage()
func (m *ResourceClassParametersList) Reset()
func (m *ResourceClassParametersList) Size() (n int)
func (this *ResourceClassParametersList) String() string
func (ResourceClassParametersList) SwaggerDoc() map[string]string
func (m *ResourceClassParametersList) Unmarshal(dAtA []byte) error
func (m *ResourceClassParametersList) XXX_DiscardUnknown()
func (m *ResourceClassParametersList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClassParametersList) XXX_Merge(src proto.Message)
func (m *ResourceClassParametersList) XXX_Size() int
func (m *ResourceClassParametersList) XXX_Unmarshal(b []byte) error
ResourceClassParametersReference contains enough information to let you locate the parameters for a ResourceClass.
type ResourceClassParametersReference struct {
// APIGroup is the group for the resource being referenced. It is
// empty for the core API. This matches the group in the APIVersion
// that is used when creating the resources.
// +optional
APIGroup string `json:"apiGroup,omitempty" protobuf:"bytes,1,opt,name=apiGroup"`
// Kind is the type of resource being referenced. This is the same
// value as in the parameter object's metadata.
Kind string `json:"kind" protobuf:"bytes,2,name=kind"`
// Name is the name of resource being referenced.
Name string `json:"name" protobuf:"bytes,3,name=name"`
// Namespace that contains the referenced resource. Must be empty
// for cluster-scoped resources and non-empty for namespaced
// resources.
// +optional
Namespace string `json:"namespace,omitempty" protobuf:"bytes,4,opt,name=namespace"`
}
func (in *ResourceClassParametersReference) DeepCopy() *ResourceClassParametersReference
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceClassParametersReference.
func (in *ResourceClassParametersReference) DeepCopyInto(out *ResourceClassParametersReference)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceClassParametersReference) Descriptor() ([]byte, []int)
func (m *ResourceClassParametersReference) Marshal() (dAtA []byte, err error)
func (m *ResourceClassParametersReference) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceClassParametersReference) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceClassParametersReference) ProtoMessage()
func (m *ResourceClassParametersReference) Reset()
func (m *ResourceClassParametersReference) Size() (n int)
func (this *ResourceClassParametersReference) String() string
func (ResourceClassParametersReference) SwaggerDoc() map[string]string
func (m *ResourceClassParametersReference) Unmarshal(dAtA []byte) error
func (m *ResourceClassParametersReference) XXX_DiscardUnknown()
func (m *ResourceClassParametersReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceClassParametersReference) XXX_Merge(src proto.Message)
func (m *ResourceClassParametersReference) XXX_Size() int
func (m *ResourceClassParametersReference) XXX_Unmarshal(b []byte) error
ResourceFilter is a filter for resources from one particular driver.
type ResourceFilter struct {
// DriverName is the name used by the DRA driver kubelet plugin.
DriverName string `json:"driverName,omitempty" protobuf:"bytes,1,opt,name=driverName"`
ResourceFilterModel `json:",inline" protobuf:"bytes,2,name=resourceFilterModel"`
}
func (in *ResourceFilter) DeepCopy() *ResourceFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceFilter.
func (in *ResourceFilter) DeepCopyInto(out *ResourceFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceFilter) Descriptor() ([]byte, []int)
func (m *ResourceFilter) Marshal() (dAtA []byte, err error)
func (m *ResourceFilter) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceFilter) ProtoMessage()
func (m *ResourceFilter) Reset()
func (m *ResourceFilter) Size() (n int)
func (this *ResourceFilter) String() string
func (ResourceFilter) SwaggerDoc() map[string]string
func (m *ResourceFilter) Unmarshal(dAtA []byte) error
func (m *ResourceFilter) XXX_DiscardUnknown()
func (m *ResourceFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceFilter) XXX_Merge(src proto.Message)
func (m *ResourceFilter) XXX_Size() int
func (m *ResourceFilter) XXX_Unmarshal(b []byte) error
ResourceFilterModel must have one and only one field set.
type ResourceFilterModel struct {
// NamedResources describes a resource filter using the named resources model.
//
// +optional
NamedResources *NamedResourcesFilter `json:"namedResources,omitempty" protobuf:"bytes,1,opt,name=namedResources"`
}
func (in *ResourceFilterModel) DeepCopy() *ResourceFilterModel
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceFilterModel.
func (in *ResourceFilterModel) DeepCopyInto(out *ResourceFilterModel)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceFilterModel) Descriptor() ([]byte, []int)
func (m *ResourceFilterModel) Marshal() (dAtA []byte, err error)
func (m *ResourceFilterModel) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceFilterModel) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceFilterModel) ProtoMessage()
func (m *ResourceFilterModel) Reset()
func (m *ResourceFilterModel) Size() (n int)
func (this *ResourceFilterModel) String() string
func (ResourceFilterModel) SwaggerDoc() map[string]string
func (m *ResourceFilterModel) Unmarshal(dAtA []byte) error
func (m *ResourceFilterModel) XXX_DiscardUnknown()
func (m *ResourceFilterModel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceFilterModel) XXX_Merge(src proto.Message)
func (m *ResourceFilterModel) XXX_Size() int
func (m *ResourceFilterModel) XXX_Unmarshal(b []byte) error
ResourceHandle holds opaque resource data for processing by a specific kubelet plugin.
type ResourceHandle struct {
// DriverName specifies the name of the resource driver whose kubelet
// plugin should be invoked to process this ResourceHandle's data once it
// lands on a node. This may differ from the DriverName set in
// ResourceClaimStatus this ResourceHandle is embedded in.
DriverName string `json:"driverName,omitempty" protobuf:"bytes,1,opt,name=driverName"`
// Data contains the opaque data associated with this ResourceHandle. It is
// set by the controller component of the resource driver whose name
// matches the DriverName set in the ResourceClaimStatus this
// ResourceHandle is embedded in. It is set at allocation time and is
// intended for processing by the kubelet plugin whose name matches
// the DriverName set in this ResourceHandle.
//
// The maximum size of this field is 16KiB. This may get increased in the
// future, but not reduced.
// +optional
Data string `json:"data,omitempty" protobuf:"bytes,2,opt,name=data"`
// If StructuredData is set, then it needs to be used instead of Data.
//
// +optional
StructuredData *StructuredResourceHandle `json:"structuredData,omitempty" protobuf:"bytes,5,opt,name=structuredData"`
}
func (in *ResourceHandle) DeepCopy() *ResourceHandle
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceHandle.
func (in *ResourceHandle) DeepCopyInto(out *ResourceHandle)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceHandle) Descriptor() ([]byte, []int)
func (m *ResourceHandle) Marshal() (dAtA []byte, err error)
func (m *ResourceHandle) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceHandle) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceHandle) ProtoMessage()
func (m *ResourceHandle) Reset()
func (m *ResourceHandle) Size() (n int)
func (this *ResourceHandle) String() string
func (ResourceHandle) SwaggerDoc() map[string]string
func (m *ResourceHandle) Unmarshal(dAtA []byte) error
func (m *ResourceHandle) XXX_DiscardUnknown()
func (m *ResourceHandle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceHandle) XXX_Merge(src proto.Message)
func (m *ResourceHandle) XXX_Size() int
func (m *ResourceHandle) XXX_Unmarshal(b []byte) error
ResourceModel must have one and only one field set.
type ResourceModel struct {
// NamedResources describes available resources using the named resources model.
//
// +optional
NamedResources *NamedResourcesResources `json:"namedResources,omitempty" protobuf:"bytes,1,opt,name=namedResources"`
}
func (in *ResourceModel) DeepCopy() *ResourceModel
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceModel.
func (in *ResourceModel) DeepCopyInto(out *ResourceModel)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceModel) Descriptor() ([]byte, []int)
func (m *ResourceModel) Marshal() (dAtA []byte, err error)
func (m *ResourceModel) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceModel) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceModel) ProtoMessage()
func (m *ResourceModel) Reset()
func (m *ResourceModel) Size() (n int)
func (this *ResourceModel) String() string
func (ResourceModel) SwaggerDoc() map[string]string
func (m *ResourceModel) Unmarshal(dAtA []byte) error
func (m *ResourceModel) XXX_DiscardUnknown()
func (m *ResourceModel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceModel) XXX_Merge(src proto.Message)
func (m *ResourceModel) XXX_Size() int
func (m *ResourceModel) XXX_Unmarshal(b []byte) error
ResourceRequest is a request for resources from one particular driver.
type ResourceRequest struct {
// VendorParameters are arbitrary setup parameters for the requested
// resource. They are ignored while allocating a claim.
//
// +optional
VendorParameters runtime.RawExtension `json:"vendorParameters,omitempty" protobuf:"bytes,1,opt,name=vendorParameters"`
ResourceRequestModel `json:",inline" protobuf:"bytes,2,name=resourceRequestModel"`
}
func (in *ResourceRequest) DeepCopy() *ResourceRequest
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceRequest.
func (in *ResourceRequest) DeepCopyInto(out *ResourceRequest)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceRequest) Descriptor() ([]byte, []int)
func (m *ResourceRequest) Marshal() (dAtA []byte, err error)
func (m *ResourceRequest) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceRequest) ProtoMessage()
func (m *ResourceRequest) Reset()
func (m *ResourceRequest) Size() (n int)
func (this *ResourceRequest) String() string
func (ResourceRequest) SwaggerDoc() map[string]string
func (m *ResourceRequest) Unmarshal(dAtA []byte) error
func (m *ResourceRequest) XXX_DiscardUnknown()
func (m *ResourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceRequest) XXX_Merge(src proto.Message)
func (m *ResourceRequest) XXX_Size() int
func (m *ResourceRequest) XXX_Unmarshal(b []byte) error
ResourceRequestModel must have one and only one field set.
type ResourceRequestModel struct {
// NamedResources describes a request for resources with the named resources model.
//
// +optional
NamedResources *NamedResourcesRequest `json:"namedResources,omitempty" protobuf:"bytes,1,opt,name=namedResources"`
}
func (in *ResourceRequestModel) DeepCopy() *ResourceRequestModel
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceRequestModel.
func (in *ResourceRequestModel) DeepCopyInto(out *ResourceRequestModel)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceRequestModel) Descriptor() ([]byte, []int)
func (m *ResourceRequestModel) Marshal() (dAtA []byte, err error)
func (m *ResourceRequestModel) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceRequestModel) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceRequestModel) ProtoMessage()
func (m *ResourceRequestModel) Reset()
func (m *ResourceRequestModel) Size() (n int)
func (this *ResourceRequestModel) String() string
func (ResourceRequestModel) SwaggerDoc() map[string]string
func (m *ResourceRequestModel) Unmarshal(dAtA []byte) error
func (m *ResourceRequestModel) XXX_DiscardUnknown()
func (m *ResourceRequestModel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceRequestModel) XXX_Merge(src proto.Message)
func (m *ResourceRequestModel) XXX_Size() int
func (m *ResourceRequestModel) XXX_Unmarshal(b []byte) error
ResourceSlice provides information about available resources on individual nodes.
type ResourceSlice struct {
metav1.TypeMeta `json:",inline"`
// Standard object metadata
// +optional
metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// NodeName identifies the node which provides the resources
// if they are local to a node.
//
// A field selector can be used to list only ResourceSlice
// objects with a certain node name.
//
// +optional
NodeName string `json:"nodeName,omitempty" protobuf:"bytes,2,opt,name=nodeName"`
// DriverName identifies the DRA driver providing the capacity information.
// A field selector can be used to list only ResourceSlice
// objects with a certain driver name.
DriverName string `json:"driverName" protobuf:"bytes,3,name=driverName"`
ResourceModel `json:",inline" protobuf:"bytes,4,name=resourceModel"`
}
func (in *ResourceSlice) DeepCopy() *ResourceSlice
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceSlice.
func (in *ResourceSlice) DeepCopyInto(out *ResourceSlice)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ResourceSlice) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ResourceSlice) Descriptor() ([]byte, []int)
func (m *ResourceSlice) Marshal() (dAtA []byte, err error)
func (m *ResourceSlice) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceSlice) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceSlice) ProtoMessage()
func (m *ResourceSlice) Reset()
func (m *ResourceSlice) Size() (n int)
func (this *ResourceSlice) String() string
func (ResourceSlice) SwaggerDoc() map[string]string
func (m *ResourceSlice) Unmarshal(dAtA []byte) error
func (m *ResourceSlice) XXX_DiscardUnknown()
func (m *ResourceSlice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceSlice) XXX_Merge(src proto.Message)
func (m *ResourceSlice) XXX_Size() int
func (m *ResourceSlice) XXX_Unmarshal(b []byte) error
ResourceSliceList is a collection of ResourceSlices.
type ResourceSliceList struct {
metav1.TypeMeta `json:",inline"`
// Standard list metadata
// +optional
metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
// Items is the list of node resource capacity objects.
Items []ResourceSlice `json:"items" protobuf:"bytes,2,rep,name=items"`
}
func (in *ResourceSliceList) DeepCopy() *ResourceSliceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceSliceList.
func (in *ResourceSliceList) DeepCopyInto(out *ResourceSliceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ResourceSliceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ResourceSliceList) Descriptor() ([]byte, []int)
func (m *ResourceSliceList) Marshal() (dAtA []byte, err error)
func (m *ResourceSliceList) MarshalTo(dAtA []byte) (int, error)
func (m *ResourceSliceList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceSliceList) ProtoMessage()
func (m *ResourceSliceList) Reset()
func (m *ResourceSliceList) Size() (n int)
func (this *ResourceSliceList) String() string
func (ResourceSliceList) SwaggerDoc() map[string]string
func (m *ResourceSliceList) Unmarshal(dAtA []byte) error
func (m *ResourceSliceList) XXX_DiscardUnknown()
func (m *ResourceSliceList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *ResourceSliceList) XXX_Merge(src proto.Message)
func (m *ResourceSliceList) XXX_Size() int
func (m *ResourceSliceList) XXX_Unmarshal(b []byte) error
StructuredResourceHandle is the in-tree representation of the allocation result.
type StructuredResourceHandle struct {
// VendorClassParameters are the per-claim configuration parameters
// from the resource class at the time that the claim was allocated.
//
// +optional
VendorClassParameters runtime.RawExtension `json:"vendorClassParameters,omitempty" protobuf:"bytes,1,opt,name=vendorClassParameters"`
// VendorClaimParameters are the per-claim configuration parameters
// from the resource claim parameters at the time that the claim was
// allocated.
//
// +optional
VendorClaimParameters runtime.RawExtension `json:"vendorClaimParameters,omitempty" protobuf:"bytes,2,opt,name=vendorClaimParameters"`
// NodeName is the name of the node providing the necessary resources
// if the resources are local to a node.
//
// +optional
NodeName string `json:"nodeName,omitempty" protobuf:"bytes,4,name=nodeName"`
// Results lists all allocated driver resources.
//
// +listType=atomic
Results []DriverAllocationResult `json:"results" protobuf:"bytes,5,name=results"`
}
func (in *StructuredResourceHandle) DeepCopy() *StructuredResourceHandle
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StructuredResourceHandle.
func (in *StructuredResourceHandle) DeepCopyInto(out *StructuredResourceHandle)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StructuredResourceHandle) Descriptor() ([]byte, []int)
func (m *StructuredResourceHandle) Marshal() (dAtA []byte, err error)
func (m *StructuredResourceHandle) MarshalTo(dAtA []byte) (int, error)
func (m *StructuredResourceHandle) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StructuredResourceHandle) ProtoMessage()
func (m *StructuredResourceHandle) Reset()
func (m *StructuredResourceHandle) Size() (n int)
func (this *StructuredResourceHandle) String() string
func (StructuredResourceHandle) SwaggerDoc() map[string]string
func (m *StructuredResourceHandle) Unmarshal(dAtA []byte) error
func (m *StructuredResourceHandle) XXX_DiscardUnknown()
func (m *StructuredResourceHandle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *StructuredResourceHandle) XXX_Merge(src proto.Message)
func (m *StructuredResourceHandle) XXX_Size() int
func (m *StructuredResourceHandle) XXX_Unmarshal(b []byte) error
VendorParameters are opaque parameters for one particular driver.
type VendorParameters struct {
// DriverName is the name used by the DRA driver kubelet plugin.
DriverName string `json:"driverName,omitempty" protobuf:"bytes,1,opt,name=driverName"`
// Parameters can be arbitrary setup parameters. They are ignored while
// allocating a claim.
//
// +optional
Parameters runtime.RawExtension `json:"parameters,omitempty" protobuf:"bytes,2,opt,name=parameters"`
}
func (in *VendorParameters) DeepCopy() *VendorParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VendorParameters.
func (in *VendorParameters) DeepCopyInto(out *VendorParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*VendorParameters) Descriptor() ([]byte, []int)
func (m *VendorParameters) Marshal() (dAtA []byte, err error)
func (m *VendorParameters) MarshalTo(dAtA []byte) (int, error)
func (m *VendorParameters) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*VendorParameters) ProtoMessage()
func (m *VendorParameters) Reset()
func (m *VendorParameters) Size() (n int)
func (this *VendorParameters) String() string
func (VendorParameters) SwaggerDoc() map[string]string
func (m *VendorParameters) Unmarshal(dAtA []byte) error
func (m *VendorParameters) XXX_DiscardUnknown()
func (m *VendorParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (m *VendorParameters) XXX_Merge(src proto.Message)
func (m *VendorParameters) XXX_Size() int
func (m *VendorParameters) XXX_Unmarshal(b []byte) error