v1alpha4

package
v0.32.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 11, 2024 License: Apache-2.0 Imports: 17 Imported by: 7

Documentation

Overview

Package v1alpha4 contains a legacy implementation of the DRA gRPC interface. Support for it in kubelet is provided via conversion.

+k8s:conversion-gen=k8s.io/kubelet/pkg/apis/dra/v1beta1

Index

Constants

View Source 
const (
	// NodeService should be listed in the "supported versions"
	// array during plugin registration by a DRA plugin which provides
	// an implementation of the v1alpha3 Node service.
	//
	// This convention was introduced in Kubernetes 1.32. Older DRA
	// plugins provide the implementation without advertising it.
	//
	// For historic reasons (= a mistake...) there is a mismatch between
	// the package name and gRPC version.
	NodeService = "v1alpha3.NodeService"
)

Variables

View Source 
var (
	ErrInvalidLengthApi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupApi = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	AddToScheme = localSchemeBuilder.AddToScheme
)

Functions

func Convert_v1alpha4_Claim_To_v1beta1_Claim added in v0.32.0 

func Convert_v1alpha4_Claim_To_v1beta1_Claim(in *Claim, out *v1beta1.Claim, s conversion.Scope) error

Convert_v1alpha4_Claim_To_v1beta1_Claim is an autogenerated conversion function.

func Convert_v1alpha4_Device_To_v1beta1_Device added in v0.32.0 

func Convert_v1alpha4_Device_To_v1beta1_Device(in *Device, out *v1beta1.Device, s conversion.Scope) error

Convert_v1alpha4_Device_To_v1beta1_Device is an autogenerated conversion function.

func Convert_v1alpha4_NodePrepareResourceResponse_To_v1beta1_NodePrepareResourceResponse added in v0.32.0 

func Convert_v1alpha4_NodePrepareResourceResponse_To_v1beta1_NodePrepareResourceResponse(in *NodePrepareResourceResponse, out *v1beta1.NodePrepareResourceResponse, s conversion.Scope) error

Convert_v1alpha4_NodePrepareResourceResponse_To_v1beta1_NodePrepareResourceResponse is an autogenerated conversion function.

func Convert_v1alpha4_NodePrepareResourcesRequest_To_v1beta1_NodePrepareResourcesRequest added in v0.32.0 

func Convert_v1alpha4_NodePrepareResourcesRequest_To_v1beta1_NodePrepareResourcesRequest(in *NodePrepareResourcesRequest, out *v1beta1.NodePrepareResourcesRequest, s conversion.Scope) error

Convert_v1alpha4_NodePrepareResourcesRequest_To_v1beta1_NodePrepareResourcesRequest is an autogenerated conversion function.

func Convert_v1alpha4_NodePrepareResourcesResponse_To_v1beta1_NodePrepareResourcesResponse added in v0.32.0 

func Convert_v1alpha4_NodePrepareResourcesResponse_To_v1beta1_NodePrepareResourcesResponse(in *NodePrepareResourcesResponse, out *v1beta1.NodePrepareResourcesResponse, s conversion.Scope) error

Convert_v1alpha4_NodePrepareResourcesResponse_To_v1beta1_NodePrepareResourcesResponse is an autogenerated conversion function.

func Convert_v1alpha4_NodeUnprepareResourceResponse_To_v1beta1_NodeUnprepareResourceResponse added in v0.32.0 

func Convert_v1alpha4_NodeUnprepareResourceResponse_To_v1beta1_NodeUnprepareResourceResponse(in *NodeUnprepareResourceResponse, out *v1beta1.NodeUnprepareResourceResponse, s conversion.Scope) error

Convert_v1alpha4_NodeUnprepareResourceResponse_To_v1beta1_NodeUnprepareResourceResponse is an autogenerated conversion function.

func Convert_v1alpha4_NodeUnprepareResourcesRequest_To_v1beta1_NodeUnprepareResourcesRequest added in v0.32.0 

func Convert_v1alpha4_NodeUnprepareResourcesRequest_To_v1beta1_NodeUnprepareResourcesRequest(in *NodeUnprepareResourcesRequest, out *v1beta1.NodeUnprepareResourcesRequest, s conversion.Scope) error

Convert_v1alpha4_NodeUnprepareResourcesRequest_To_v1beta1_NodeUnprepareResourcesRequest is an autogenerated conversion function.

func Convert_v1alpha4_NodeUnprepareResourcesResponse_To_v1beta1_NodeUnprepareResourcesResponse added in v0.32.0 

func Convert_v1alpha4_NodeUnprepareResourcesResponse_To_v1beta1_NodeUnprepareResourcesResponse(in *NodeUnprepareResourcesResponse, out *v1beta1.NodeUnprepareResourcesResponse, s conversion.Scope) error

Convert_v1alpha4_NodeUnprepareResourcesResponse_To_v1beta1_NodeUnprepareResourcesResponse is an autogenerated conversion function.

func Convert_v1beta1_Claim_To_v1alpha4_Claim added in v0.32.0 

func Convert_v1beta1_Claim_To_v1alpha4_Claim(in *v1beta1.Claim, out *Claim, s conversion.Scope) error

Convert_v1beta1_Claim_To_v1alpha4_Claim is an autogenerated conversion function.

func Convert_v1beta1_Device_To_v1alpha4_Device added in v0.32.0 

func Convert_v1beta1_Device_To_v1alpha4_Device(in *v1beta1.Device, out *Device, s conversion.Scope) error

Convert_v1beta1_Device_To_v1alpha4_Device is an autogenerated conversion function.

func Convert_v1beta1_NodePrepareResourceResponse_To_v1alpha4_NodePrepareResourceResponse added in v0.32.0 

func Convert_v1beta1_NodePrepareResourceResponse_To_v1alpha4_NodePrepareResourceResponse(in *v1beta1.NodePrepareResourceResponse, out *NodePrepareResourceResponse, s conversion.Scope) error

Convert_v1beta1_NodePrepareResourceResponse_To_v1alpha4_NodePrepareResourceResponse is an autogenerated conversion function.

func Convert_v1beta1_NodePrepareResourcesRequest_To_v1alpha4_NodePrepareResourcesRequest added in v0.32.0 

func Convert_v1beta1_NodePrepareResourcesRequest_To_v1alpha4_NodePrepareResourcesRequest(in *v1beta1.NodePrepareResourcesRequest, out *NodePrepareResourcesRequest, s conversion.Scope) error

Convert_v1beta1_NodePrepareResourcesRequest_To_v1alpha4_NodePrepareResourcesRequest is an autogenerated conversion function.

func Convert_v1beta1_NodePrepareResourcesResponse_To_v1alpha4_NodePrepareResourcesResponse added in v0.32.0 

func Convert_v1beta1_NodePrepareResourcesResponse_To_v1alpha4_NodePrepareResourcesResponse(in *v1beta1.NodePrepareResourcesResponse, out *NodePrepareResourcesResponse, s conversion.Scope) error

Convert_v1beta1_NodePrepareResourcesResponse_To_v1alpha4_NodePrepareResourcesResponse is an autogenerated conversion function.

func Convert_v1beta1_NodeUnprepareResourceResponse_To_v1alpha4_NodeUnprepareResourceResponse added in v0.32.0 

func Convert_v1beta1_NodeUnprepareResourceResponse_To_v1alpha4_NodeUnprepareResourceResponse(in *v1beta1.NodeUnprepareResourceResponse, out *NodeUnprepareResourceResponse, s conversion.Scope) error

Convert_v1beta1_NodeUnprepareResourceResponse_To_v1alpha4_NodeUnprepareResourceResponse is an autogenerated conversion function.

func Convert_v1beta1_NodeUnprepareResourcesRequest_To_v1alpha4_NodeUnprepareResourcesRequest added in v0.32.0 

func Convert_v1beta1_NodeUnprepareResourcesRequest_To_v1alpha4_NodeUnprepareResourcesRequest(in *v1beta1.NodeUnprepareResourcesRequest, out *NodeUnprepareResourcesRequest, s conversion.Scope) error

Convert_v1beta1_NodeUnprepareResourcesRequest_To_v1alpha4_NodeUnprepareResourcesRequest is an autogenerated conversion function.

func Convert_v1beta1_NodeUnprepareResourcesResponse_To_v1alpha4_NodeUnprepareResourcesResponse added in v0.32.0 

func Convert_v1beta1_NodeUnprepareResourcesResponse_To_v1alpha4_NodeUnprepareResourcesResponse(in *v1beta1.NodeUnprepareResourcesResponse, out *NodeUnprepareResourcesResponse, s conversion.Scope) error

Convert_v1beta1_NodeUnprepareResourcesResponse_To_v1alpha4_NodeUnprepareResourcesResponse is an autogenerated conversion function.

func RegisterConversions added in v0.32.0 

func RegisterConversions(s *runtime.Scheme) error

RegisterConversions adds conversion functions to the given scheme. Public to allow building arbitrary schemes.

func RegisterNodeServer 

func RegisterNodeServer(s *grpc.Server, srv NodeServer)

Types

type Claim 

type Claim struct {
	// The ResourceClaim namespace (ResourceClaim.meta.Namespace).
	// This field is REQUIRED.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The UID of the Resource claim (ResourceClaim.meta.UUID).
	// This field is REQUIRED.
	UID string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// The name of the Resource claim (ResourceClaim.meta.Name)
	// This field is REQUIRED.
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Claim) Descriptor 

func (*Claim) Descriptor() ([]byte, []int)

func (*Claim) GetName 

func (m *Claim) GetName() string

func (*Claim) GetNamespace 

func (m *Claim) GetNamespace() string

func (*Claim) GetUID 

func (m *Claim) GetUID() string

func (*Claim) Marshal 

func (m *Claim) Marshal() (dAtA []byte, err error)

func (*Claim) MarshalTo 

func (m *Claim) MarshalTo(dAtA []byte) (int, error)

func (*Claim) MarshalToSizedBuffer 

func (m *Claim) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Claim) ProtoMessage 

func (*Claim) ProtoMessage()

func (*Claim) Reset 

func (m *Claim) Reset()

func (*Claim) Size 

func (m *Claim) Size() (n int)

func (*Claim) String 

func (this *Claim) String() string

func (*Claim) Unmarshal 

func (m *Claim) Unmarshal(dAtA []byte) error

func (*Claim) XXX_DiscardUnknown 

func (m *Claim) XXX_DiscardUnknown()

func (*Claim) XXX_Marshal 

func (m *Claim) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Claim) XXX_Merge 

func (m *Claim) XXX_Merge(src proto.Message)

func (*Claim) XXX_Size 

func (m *Claim) XXX_Size() int

func (*Claim) XXX_Unmarshal 

func (m *Claim) XXX_Unmarshal(b []byte) error

type Device 

type Device struct {
	// The requests in the claim that this device is associated with.
	// Optional. If empty, the device is associated with all requests.
	RequestNames []string `protobuf:"bytes,1,rep,name=request_names,json=requestNames,proto3" json:"request_names,omitempty"`
	// The pool which contains the device. Required.
	PoolName string `protobuf:"bytes,2,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`
	// The device itself. Required.
	DeviceName string `protobuf:"bytes,3,opt,name=device_name,json=deviceName,proto3" json:"device_name,omitempty"`
	// A single device instance may map to several CDI device IDs.
	// None is also valid.
	CDIDeviceIDs         []string `protobuf:"bytes,4,rep,name=cdi_device_ids,json=cdiDeviceIds,proto3" json:"cdi_device_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Device) Descriptor 

func (*Device) Descriptor() ([]byte, []int)

func (*Device) GetCDIDeviceIDs 

func (m *Device) GetCDIDeviceIDs() []string

func (*Device) GetDeviceName 

func (m *Device) GetDeviceName() string

func (*Device) GetPoolName 

func (m *Device) GetPoolName() string

func (*Device) GetRequestNames 

func (m *Device) GetRequestNames() []string

func (*Device) Marshal 

func (m *Device) Marshal() (dAtA []byte, err error)

func (*Device) MarshalTo 

func (m *Device) MarshalTo(dAtA []byte) (int, error)

func (*Device) MarshalToSizedBuffer 

func (m *Device) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) Reset 

func (m *Device) Reset()

func (*Device) Size 

func (m *Device) Size() (n int)

func (*Device) String 

func (this *Device) String() string

func (*Device) Unmarshal 

func (m *Device) Unmarshal(dAtA []byte) error

func (*Device) XXX_DiscardUnknown 

func (m *Device) XXX_DiscardUnknown()

func (*Device) XXX_Marshal 

func (m *Device) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Device) XXX_Merge 

func (m *Device) XXX_Merge(src proto.Message)

func (*Device) XXX_Size 

func (m *Device) XXX_Size() int

func (*Device) XXX_Unmarshal 

func (m *Device) XXX_Unmarshal(b []byte) error

type NodeClient 

type NodeClient interface {
	// NodePrepareResources prepares several ResourceClaims
	// for use on the node. If an error is returned, the
	// response is ignored. Failures for individual claims
	// can be reported inside NodePrepareResourcesResponse.
	NodePrepareResources(ctx context.Context, in *NodePrepareResourcesRequest, opts ...grpc.CallOption) (*NodePrepareResourcesResponse, error)
	// NodeUnprepareResources is the opposite of NodePrepareResources.
	// The same error handling rules apply,
	NodeUnprepareResources(ctx context.Context, in *NodeUnprepareResourcesRequest, opts ...grpc.CallOption) (*NodeUnprepareResourcesResponse, error)
}

NodeClient is the client API for Node service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNodeClient 

func NewNodeClient(cc *grpc.ClientConn) NodeClient

type NodePrepareResourceResponse 

type NodePrepareResourceResponse struct {
	// These are the additional devices that kubelet must
	// make available via the container runtime. A claim
	// may have zero or more requests and each request
	// may have zero or more devices.
	Devices []*Device `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	// If non-empty, preparing the ResourceClaim failed.
	// Devices are ignored in that case.
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodePrepareResourceResponse) Descriptor 

func (*NodePrepareResourceResponse) Descriptor() ([]byte, []int)

func (*NodePrepareResourceResponse) GetDevices 

func (m *NodePrepareResourceResponse) GetDevices() []*Device

func (*NodePrepareResourceResponse) GetError 

func (m *NodePrepareResourceResponse) GetError() string

func (*NodePrepareResourceResponse) Marshal 

func (m *NodePrepareResourceResponse) Marshal() (dAtA []byte, err error)

func (*NodePrepareResourceResponse) MarshalTo 

func (m *NodePrepareResourceResponse) MarshalTo(dAtA []byte) (int, error)

func (*NodePrepareResourceResponse) MarshalToSizedBuffer 

func (m *NodePrepareResourceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodePrepareResourceResponse) ProtoMessage 

func (*NodePrepareResourceResponse) ProtoMessage()

func (*NodePrepareResourceResponse) Reset 

func (m *NodePrepareResourceResponse) Reset()

func (*NodePrepareResourceResponse) Size 

func (m *NodePrepareResourceResponse) Size() (n int)

func (*NodePrepareResourceResponse) String 

func (this *NodePrepareResourceResponse) String() string

func (*NodePrepareResourceResponse) Unmarshal 

func (m *NodePrepareResourceResponse) Unmarshal(dAtA []byte) error

func (*NodePrepareResourceResponse) XXX_DiscardUnknown 

func (m *NodePrepareResourceResponse) XXX_DiscardUnknown()

func (*NodePrepareResourceResponse) XXX_Marshal 

func (m *NodePrepareResourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodePrepareResourceResponse) XXX_Merge 

func (m *NodePrepareResourceResponse) XXX_Merge(src proto.Message)

func (*NodePrepareResourceResponse) XXX_Size 

func (m *NodePrepareResourceResponse) XXX_Size() int

func (*NodePrepareResourceResponse) XXX_Unmarshal 

func (m *NodePrepareResourceResponse) XXX_Unmarshal(b []byte) error

type NodePrepareResourcesRequest 

type NodePrepareResourcesRequest struct {
	// The list of ResourceClaims that are to be prepared.
	Claims               []*Claim `protobuf:"bytes,1,rep,name=claims,proto3" json:"claims,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodePrepareResourcesRequest) Descriptor 

func (*NodePrepareResourcesRequest) Descriptor() ([]byte, []int)

func (*NodePrepareResourcesRequest) GetClaims 

func (m *NodePrepareResourcesRequest) GetClaims() []*Claim

func (*NodePrepareResourcesRequest) Marshal 

func (m *NodePrepareResourcesRequest) Marshal() (dAtA []byte, err error)

func (*NodePrepareResourcesRequest) MarshalTo 

func (m *NodePrepareResourcesRequest) MarshalTo(dAtA []byte) (int, error)

func (*NodePrepareResourcesRequest) MarshalToSizedBuffer 

func (m *NodePrepareResourcesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodePrepareResourcesRequest) ProtoMessage 

func (*NodePrepareResourcesRequest) ProtoMessage()

func (*NodePrepareResourcesRequest) Reset 

func (m *NodePrepareResourcesRequest) Reset()

func (*NodePrepareResourcesRequest) Size 

func (m *NodePrepareResourcesRequest) Size() (n int)

func (*NodePrepareResourcesRequest) String 

func (this *NodePrepareResourcesRequest) String() string

func (*NodePrepareResourcesRequest) Unmarshal 

func (m *NodePrepareResourcesRequest) Unmarshal(dAtA []byte) error

func (*NodePrepareResourcesRequest) XXX_DiscardUnknown 

func (m *NodePrepareResourcesRequest) XXX_DiscardUnknown()

func (*NodePrepareResourcesRequest) XXX_Marshal 

func (m *NodePrepareResourcesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodePrepareResourcesRequest) XXX_Merge 

func (m *NodePrepareResourcesRequest) XXX_Merge(src proto.Message)

func (*NodePrepareResourcesRequest) XXX_Size 

func (m *NodePrepareResourcesRequest) XXX_Size() int

func (*NodePrepareResourcesRequest) XXX_Unmarshal 

func (m *NodePrepareResourcesRequest) XXX_Unmarshal(b []byte) error

type NodePrepareResourcesResponse 

type NodePrepareResourcesResponse struct {
	// The ResourceClaims for which preparation was done
	// or attempted, with claim_uid as key.
	//
	// It is an error if some claim listed in NodePrepareResourcesRequest
	// does not get prepared. NodePrepareResources
	// will be called again for those that are missing.
	Claims               map[string]*NodePrepareResourceResponse `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

func (*NodePrepareResourcesResponse) Descriptor 

func (*NodePrepareResourcesResponse) Descriptor() ([]byte, []int)

func (*NodePrepareResourcesResponse) GetClaims 

func (m *NodePrepareResourcesResponse) GetClaims() map[string]*NodePrepareResourceResponse

func (*NodePrepareResourcesResponse) Marshal 

func (m *NodePrepareResourcesResponse) Marshal() (dAtA []byte, err error)

func (*NodePrepareResourcesResponse) MarshalTo 

func (m *NodePrepareResourcesResponse) MarshalTo(dAtA []byte) (int, error)

func (*NodePrepareResourcesResponse) MarshalToSizedBuffer 

func (m *NodePrepareResourcesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodePrepareResourcesResponse) ProtoMessage 

func (*NodePrepareResourcesResponse) ProtoMessage()

func (*NodePrepareResourcesResponse) Reset 

func (m *NodePrepareResourcesResponse) Reset()

func (*NodePrepareResourcesResponse) Size 

func (m *NodePrepareResourcesResponse) Size() (n int)

func (*NodePrepareResourcesResponse) String 

func (this *NodePrepareResourcesResponse) String() string

func (*NodePrepareResourcesResponse) Unmarshal 

func (m *NodePrepareResourcesResponse) Unmarshal(dAtA []byte) error

func (*NodePrepareResourcesResponse) XXX_DiscardUnknown 

func (m *NodePrepareResourcesResponse) XXX_DiscardUnknown()

func (*NodePrepareResourcesResponse) XXX_Marshal 

func (m *NodePrepareResourcesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodePrepareResourcesResponse) XXX_Merge 

func (m *NodePrepareResourcesResponse) XXX_Merge(src proto.Message)

func (*NodePrepareResourcesResponse) XXX_Size 

func (m *NodePrepareResourcesResponse) XXX_Size() int

func (*NodePrepareResourcesResponse) XXX_Unmarshal 

func (m *NodePrepareResourcesResponse) XXX_Unmarshal(b []byte) error

type NodeServer 

type NodeServer interface {
	// NodePrepareResources prepares several ResourceClaims
	// for use on the node. If an error is returned, the
	// response is ignored. Failures for individual claims
	// can be reported inside NodePrepareResourcesResponse.
	NodePrepareResources(context.Context, *NodePrepareResourcesRequest) (*NodePrepareResourcesResponse, error)
	// NodeUnprepareResources is the opposite of NodePrepareResources.
	// The same error handling rules apply,
	NodeUnprepareResources(context.Context, *NodeUnprepareResourcesRequest) (*NodeUnprepareResourcesResponse, error)
}

NodeServer is the server API for Node service.

type NodeUnprepareResourceResponse 

type NodeUnprepareResourceResponse struct {
	// If non-empty, unpreparing the ResourceClaim failed.
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeUnprepareResourceResponse) Descriptor 

func (*NodeUnprepareResourceResponse) Descriptor() ([]byte, []int)

func (*NodeUnprepareResourceResponse) GetError 

func (m *NodeUnprepareResourceResponse) GetError() string

func (*NodeUnprepareResourceResponse) Marshal 

func (m *NodeUnprepareResourceResponse) Marshal() (dAtA []byte, err error)

func (*NodeUnprepareResourceResponse) MarshalTo 

func (m *NodeUnprepareResourceResponse) MarshalTo(dAtA []byte) (int, error)

func (*NodeUnprepareResourceResponse) MarshalToSizedBuffer 

func (m *NodeUnprepareResourceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeUnprepareResourceResponse) ProtoMessage 

func (*NodeUnprepareResourceResponse) ProtoMessage()

func (*NodeUnprepareResourceResponse) Reset 

func (m *NodeUnprepareResourceResponse) Reset()

func (*NodeUnprepareResourceResponse) Size 

func (m *NodeUnprepareResourceResponse) Size() (n int)

func (*NodeUnprepareResourceResponse) String 

func (this *NodeUnprepareResourceResponse) String() string

func (*NodeUnprepareResourceResponse) Unmarshal 

func (m *NodeUnprepareResourceResponse) Unmarshal(dAtA []byte) error

func (*NodeUnprepareResourceResponse) XXX_DiscardUnknown 

func (m *NodeUnprepareResourceResponse) XXX_DiscardUnknown()

func (*NodeUnprepareResourceResponse) XXX_Marshal 

func (m *NodeUnprepareResourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeUnprepareResourceResponse) XXX_Merge 

func (m *NodeUnprepareResourceResponse) XXX_Merge(src proto.Message)

func (*NodeUnprepareResourceResponse) XXX_Size 

func (m *NodeUnprepareResourceResponse) XXX_Size() int

func (*NodeUnprepareResourceResponse) XXX_Unmarshal 

func (m *NodeUnprepareResourceResponse) XXX_Unmarshal(b []byte) error

type NodeUnprepareResourcesRequest 

type NodeUnprepareResourcesRequest struct {
	// The list of ResourceClaims that are to be unprepared.
	Claims               []*Claim `protobuf:"bytes,1,rep,name=claims,proto3" json:"claims,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeUnprepareResourcesRequest) Descriptor 

func (*NodeUnprepareResourcesRequest) Descriptor() ([]byte, []int)

func (*NodeUnprepareResourcesRequest) GetClaims 

func (m *NodeUnprepareResourcesRequest) GetClaims() []*Claim

func (*NodeUnprepareResourcesRequest) Marshal 

func (m *NodeUnprepareResourcesRequest) Marshal() (dAtA []byte, err error)

func (*NodeUnprepareResourcesRequest) MarshalTo 

func (m *NodeUnprepareResourcesRequest) MarshalTo(dAtA []byte) (int, error)

func (*NodeUnprepareResourcesRequest) MarshalToSizedBuffer 

func (m *NodeUnprepareResourcesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeUnprepareResourcesRequest) ProtoMessage 

func (*NodeUnprepareResourcesRequest) ProtoMessage()

func (*NodeUnprepareResourcesRequest) Reset 

func (m *NodeUnprepareResourcesRequest) Reset()

func (*NodeUnprepareResourcesRequest) Size 

func (m *NodeUnprepareResourcesRequest) Size() (n int)

func (*NodeUnprepareResourcesRequest) String 

func (this *NodeUnprepareResourcesRequest) String() string

func (*NodeUnprepareResourcesRequest) Unmarshal 

func (m *NodeUnprepareResourcesRequest) Unmarshal(dAtA []byte) error

func (*NodeUnprepareResourcesRequest) XXX_DiscardUnknown 

func (m *NodeUnprepareResourcesRequest) XXX_DiscardUnknown()

func (*NodeUnprepareResourcesRequest) XXX_Marshal 

func (m *NodeUnprepareResourcesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeUnprepareResourcesRequest) XXX_Merge 

func (m *NodeUnprepareResourcesRequest) XXX_Merge(src proto.Message)

func (*NodeUnprepareResourcesRequest) XXX_Size 

func (m *NodeUnprepareResourcesRequest) XXX_Size() int

func (*NodeUnprepareResourcesRequest) XXX_Unmarshal 

func (m *NodeUnprepareResourcesRequest) XXX_Unmarshal(b []byte) error

type NodeUnprepareResourcesResponse 

type NodeUnprepareResourcesResponse struct {
	// The ResourceClaims for which preparation was reverted.
	// The same rules as for NodePrepareResourcesResponse.claims
	// apply.
	Claims               map[string]*NodeUnprepareResourceResponse `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                  `json:"-"`
	XXX_sizecache        int32                                     `json:"-"`
}

func (*NodeUnprepareResourcesResponse) Descriptor 

func (*NodeUnprepareResourcesResponse) Descriptor() ([]byte, []int)

func (*NodeUnprepareResourcesResponse) GetClaims 

func (m *NodeUnprepareResourcesResponse) GetClaims() map[string]*NodeUnprepareResourceResponse

func (*NodeUnprepareResourcesResponse) Marshal 

func (m *NodeUnprepareResourcesResponse) Marshal() (dAtA []byte, err error)

func (*NodeUnprepareResourcesResponse) MarshalTo 

func (m *NodeUnprepareResourcesResponse) MarshalTo(dAtA []byte) (int, error)

func (*NodeUnprepareResourcesResponse) MarshalToSizedBuffer 

func (m *NodeUnprepareResourcesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeUnprepareResourcesResponse) ProtoMessage 

func (*NodeUnprepareResourcesResponse) ProtoMessage()

func (*NodeUnprepareResourcesResponse) Reset 

func (m *NodeUnprepareResourcesResponse) Reset()

func (*NodeUnprepareResourcesResponse) Size 

func (m *NodeUnprepareResourcesResponse) Size() (n int)

func (*NodeUnprepareResourcesResponse) String 

func (this *NodeUnprepareResourcesResponse) String() string

func (*NodeUnprepareResourcesResponse) Unmarshal 

func (m *NodeUnprepareResourcesResponse) Unmarshal(dAtA []byte) error

func (*NodeUnprepareResourcesResponse) XXX_DiscardUnknown 

func (m *NodeUnprepareResourcesResponse) XXX_DiscardUnknown()

func (*NodeUnprepareResourcesResponse) XXX_Marshal 

func (m *NodeUnprepareResourcesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeUnprepareResourcesResponse) XXX_Merge 

func (m *NodeUnprepareResourcesResponse) XXX_Merge(src proto.Message)

func (*NodeUnprepareResourcesResponse) XXX_Size 

func (m *NodeUnprepareResourcesResponse) XXX_Size() int

func (*NodeUnprepareResourcesResponse) XXX_Unmarshal 

func (m *NodeUnprepareResourcesResponse) XXX_Unmarshal(b []byte) error

type UnimplementedNodeServer 

type UnimplementedNodeServer struct {
}

UnimplementedNodeServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodeServer) NodePrepareResources 

func (*UnimplementedNodeServer) NodePrepareResources(ctx context.Context, req *NodePrepareResourcesRequest) (*NodePrepareResourcesResponse, error)

func (*UnimplementedNodeServer) NodeUnprepareResources 

func (*UnimplementedNodeServer) NodeUnprepareResources(ctx context.Context, req *NodeUnprepareResourcesRequest) (*NodeUnprepareResourcesResponse, error)

type V1Alpha4ClientWrapper added in v0.32.0 

type V1Alpha4ClientWrapper struct {
	NodeClient
}

V1Alpha4ClientWrapper implements the v1beta1.DRAPluginClient interface by wrapping a NodeClient.

func (V1Alpha4ClientWrapper) NodePrepareResources added in v0.32.0 

func (w V1Alpha4ClientWrapper) NodePrepareResources(ctx context.Context, req *v1beta1.NodePrepareResourcesRequest, options ...grpc.CallOption) (*v1beta1.NodePrepareResourcesResponse, error)

func (V1Alpha4ClientWrapper) NodeUnprepareResources added in v0.32.0 

func (w V1Alpha4ClientWrapper) NodeUnprepareResources(ctx context.Context, req *v1beta1.NodeUnprepareResourcesRequest, options ...grpc.CallOption) (*v1beta1.NodeUnprepareResourcesResponse, error)

type V1Alpha4ServerWrapper added in v0.32.0 

type V1Alpha4ServerWrapper struct {
	NodeServer
}

V1Alpha4ServerWrapper implements the v1beta1.DRAPluginServer interface by wrapping a NodeServer.

func (V1Alpha4ServerWrapper) NodePrepareResources added in v0.32.0 

func (w V1Alpha4ServerWrapper) NodePrepareResources(ctx context.Context, req *v1beta1.NodePrepareResourcesRequest) (*v1beta1.NodePrepareResourcesResponse, error)

func (V1Alpha4ServerWrapper) NodeUnprepareResources added in v0.32.0 

func (w V1Alpha4ServerWrapper) NodeUnprepareResources(ctx context.Context, req *v1beta1.NodeUnprepareResourcesRequest) (*v1beta1.NodeUnprepareResourcesResponse, error)

type V1Beta1ClientWrapper added in v0.32.0 

type V1Beta1ClientWrapper struct {
	v1beta1.DRAPluginClient
}

V1Beta1ClientWrapper implements the NodeClient interface by wrapping a v1beta1.DRAPluginClient.

func (V1Beta1ClientWrapper) NodePrepareResources added in v0.32.0 

func (w V1Beta1ClientWrapper) NodePrepareResources(ctx context.Context, req *NodePrepareResourcesRequest, options ...grpc.CallOption) (*NodePrepareResourcesResponse, error)

func (V1Beta1ClientWrapper) NodeUnprepareResources added in v0.32.0 

func (w V1Beta1ClientWrapper) NodeUnprepareResources(ctx context.Context, req *NodeUnprepareResourcesRequest, options ...grpc.CallOption) (*NodeUnprepareResourcesResponse, error)

type V1Beta1ServerWrapper added in v0.32.0 

type V1Beta1ServerWrapper struct {
	v1beta1.DRAPluginServer
}

V1Beta1ServerWrapper implements the NodeServer interface by wrapping a v1beta1.DRAPluginServer.

func (V1Beta1ServerWrapper) NodePrepareResources added in v0.32.0 

func (w V1Beta1ServerWrapper) NodePrepareResources(ctx context.Context, req *NodePrepareResourcesRequest) (*NodePrepareResourcesResponse, error)

func (V1Beta1ServerWrapper) NodeUnprepareResources added in v0.32.0 

func (w V1Beta1ServerWrapper) NodeUnprepareResources(ctx context.Context, req *NodeUnprepareResourcesRequest) (*NodeUnprepareResourcesResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.