Documentation ¶
Index ¶
- Variables
- func RegisterNodeServer(s *grpc.Server, srv NodeServer)
- type NodeClient
- type NodePrepareResourceRequest
- func (*NodePrepareResourceRequest) Descriptor() ([]byte, []int)
- func (m *NodePrepareResourceRequest) GetClaimName() string
- func (m *NodePrepareResourceRequest) GetClaimUid() string
- func (m *NodePrepareResourceRequest) GetNamespace() string
- func (m *NodePrepareResourceRequest) GetResourceHandle() string
- func (m *NodePrepareResourceRequest) GetStructuredResourceHandle() []*v1alpha2.StructuredResourceHandle
- func (m *NodePrepareResourceRequest) Marshal() (dAtA []byte, err error)
- func (m *NodePrepareResourceRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *NodePrepareResourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodePrepareResourceRequest) ProtoMessage()
- func (m *NodePrepareResourceRequest) Reset()
- func (m *NodePrepareResourceRequest) Size() (n int)
- func (this *NodePrepareResourceRequest) String() string
- func (m *NodePrepareResourceRequest) Unmarshal(dAtA []byte) error
- func (m *NodePrepareResourceRequest) XXX_DiscardUnknown()
- func (m *NodePrepareResourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodePrepareResourceRequest) XXX_Merge(src proto.Message)
- func (m *NodePrepareResourceRequest) XXX_Size() int
- func (m *NodePrepareResourceRequest) XXX_Unmarshal(b []byte) error
- type NodePrepareResourceResponse
- func (*NodePrepareResourceResponse) Descriptor() ([]byte, []int)
- func (m *NodePrepareResourceResponse) GetCdiDevices() []string
- func (m *NodePrepareResourceResponse) Marshal() (dAtA []byte, err error)
- func (m *NodePrepareResourceResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *NodePrepareResourceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodePrepareResourceResponse) ProtoMessage()
- func (m *NodePrepareResourceResponse) Reset()
- func (m *NodePrepareResourceResponse) Size() (n int)
- func (this *NodePrepareResourceResponse) String() string
- func (m *NodePrepareResourceResponse) Unmarshal(dAtA []byte) error
- func (m *NodePrepareResourceResponse) XXX_DiscardUnknown()
- func (m *NodePrepareResourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodePrepareResourceResponse) XXX_Merge(src proto.Message)
- func (m *NodePrepareResourceResponse) XXX_Size() int
- func (m *NodePrepareResourceResponse) XXX_Unmarshal(b []byte) error
- type NodeServer
- type NodeUnprepareResourceRequest
- func (*NodeUnprepareResourceRequest) Descriptor() ([]byte, []int)
- func (m *NodeUnprepareResourceRequest) GetClaimName() string
- func (m *NodeUnprepareResourceRequest) GetClaimUid() string
- func (m *NodeUnprepareResourceRequest) GetNamespace() string
- func (m *NodeUnprepareResourceRequest) GetResourceHandle() string
- func (m *NodeUnprepareResourceRequest) GetStructuredResourceHandle() []*v1alpha2.StructuredResourceHandle
- func (m *NodeUnprepareResourceRequest) Marshal() (dAtA []byte, err error)
- func (m *NodeUnprepareResourceRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeUnprepareResourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodeUnprepareResourceRequest) ProtoMessage()
- func (m *NodeUnprepareResourceRequest) Reset()
- func (m *NodeUnprepareResourceRequest) Size() (n int)
- func (this *NodeUnprepareResourceRequest) String() string
- func (m *NodeUnprepareResourceRequest) Unmarshal(dAtA []byte) error
- func (m *NodeUnprepareResourceRequest) XXX_DiscardUnknown()
- func (m *NodeUnprepareResourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeUnprepareResourceRequest) XXX_Merge(src proto.Message)
- func (m *NodeUnprepareResourceRequest) XXX_Size() int
- func (m *NodeUnprepareResourceRequest) XXX_Unmarshal(b []byte) error
- type NodeUnprepareResourceResponse
- func (*NodeUnprepareResourceResponse) Descriptor() ([]byte, []int)
- func (m *NodeUnprepareResourceResponse) Marshal() (dAtA []byte, err error)
- func (m *NodeUnprepareResourceResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeUnprepareResourceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodeUnprepareResourceResponse) ProtoMessage()
- func (m *NodeUnprepareResourceResponse) Reset()
- func (m *NodeUnprepareResourceResponse) Size() (n int)
- func (this *NodeUnprepareResourceResponse) String() string
- func (m *NodeUnprepareResourceResponse) Unmarshal(dAtA []byte) error
- func (m *NodeUnprepareResourceResponse) XXX_DiscardUnknown()
- func (m *NodeUnprepareResourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeUnprepareResourceResponse) XXX_Merge(src proto.Message)
- func (m *NodeUnprepareResourceResponse) XXX_Size() int
- func (m *NodeUnprepareResourceResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedNodeServer
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterNodeServer ¶
func RegisterNodeServer(s *grpc.Server, srv NodeServer)
Types ¶
type NodeClient ¶
type NodeClient interface { NodePrepareResource(ctx context.Context, in *NodePrepareResourceRequest, opts ...grpc.CallOption) (*NodePrepareResourceResponse, error) NodeUnprepareResource(ctx context.Context, in *NodeUnprepareResourceRequest, opts ...grpc.CallOption) (*NodeUnprepareResourceResponse, 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 NodePrepareResourceRequest ¶
type NodePrepareResourceRequest 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. ClaimUid string `protobuf:"bytes,2,opt,name=claim_uid,json=claimUid,proto3" json:"claim_uid,omitempty"` // The name of the Resource claim (ResourceClaim.meta.Name) // This field is REQUIRED. ClaimName string `protobuf:"bytes,3,opt,name=claim_name,json=claimName,proto3" json:"claim_name,omitempty"` // Resource handle (AllocationResult.ResourceHandles[*].Data) // This field is REQUIRED. ResourceHandle string `protobuf:"bytes,4,opt,name=resource_handle,json=resourceHandle,proto3" json:"resource_handle,omitempty"` // Structured parameter resource handle (AllocationResult.ResourceHandles[*].StructuredData). // This field is OPTIONAL. If present, it needs to be used // instead of resource_handle. It will only have a single entry. // // Using "repeated" instead of "optional" is a workaround for https://github.com/gogo/protobuf/issues/713. StructuredResourceHandle []*v1alpha2.StructuredResourceHandle `` /* 135-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodePrepareResourceRequest) Descriptor ¶
func (*NodePrepareResourceRequest) Descriptor() ([]byte, []int)
func (*NodePrepareResourceRequest) GetClaimName ¶
func (m *NodePrepareResourceRequest) GetClaimName() string
func (*NodePrepareResourceRequest) GetClaimUid ¶
func (m *NodePrepareResourceRequest) GetClaimUid() string
func (*NodePrepareResourceRequest) GetNamespace ¶
func (m *NodePrepareResourceRequest) GetNamespace() string
func (*NodePrepareResourceRequest) GetResourceHandle ¶
func (m *NodePrepareResourceRequest) GetResourceHandle() string
func (*NodePrepareResourceRequest) GetStructuredResourceHandle ¶ added in v0.30.0
func (m *NodePrepareResourceRequest) GetStructuredResourceHandle() []*v1alpha2.StructuredResourceHandle
func (*NodePrepareResourceRequest) Marshal ¶
func (m *NodePrepareResourceRequest) Marshal() (dAtA []byte, err error)
func (*NodePrepareResourceRequest) MarshalTo ¶
func (m *NodePrepareResourceRequest) MarshalTo(dAtA []byte) (int, error)
func (*NodePrepareResourceRequest) MarshalToSizedBuffer ¶
func (m *NodePrepareResourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NodePrepareResourceRequest) ProtoMessage ¶
func (*NodePrepareResourceRequest) ProtoMessage()
func (*NodePrepareResourceRequest) Reset ¶
func (m *NodePrepareResourceRequest) Reset()
func (*NodePrepareResourceRequest) Size ¶
func (m *NodePrepareResourceRequest) Size() (n int)
func (*NodePrepareResourceRequest) String ¶
func (this *NodePrepareResourceRequest) String() string
func (*NodePrepareResourceRequest) Unmarshal ¶
func (m *NodePrepareResourceRequest) Unmarshal(dAtA []byte) error
func (*NodePrepareResourceRequest) XXX_DiscardUnknown ¶
func (m *NodePrepareResourceRequest) XXX_DiscardUnknown()
func (*NodePrepareResourceRequest) XXX_Marshal ¶
func (m *NodePrepareResourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodePrepareResourceRequest) XXX_Merge ¶
func (m *NodePrepareResourceRequest) XXX_Merge(src proto.Message)
func (*NodePrepareResourceRequest) XXX_Size ¶
func (m *NodePrepareResourceRequest) XXX_Size() int
func (*NodePrepareResourceRequest) XXX_Unmarshal ¶
func (m *NodePrepareResourceRequest) XXX_Unmarshal(b []byte) error
type NodePrepareResourceResponse ¶
type NodePrepareResourceResponse struct { // These are the additional devices that kubelet must // make available via the container runtime. A resource // may have zero or more devices. CdiDevices []string `protobuf:"bytes,1,rep,name=cdi_devices,json=cdiDevices,proto3" json:"cdi_devices,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodePrepareResourceResponse) Descriptor ¶
func (*NodePrepareResourceResponse) Descriptor() ([]byte, []int)
func (*NodePrepareResourceResponse) GetCdiDevices ¶
func (m *NodePrepareResourceResponse) GetCdiDevices() []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 NodeServer ¶
type NodeServer interface { NodePrepareResource(context.Context, *NodePrepareResourceRequest) (*NodePrepareResourceResponse, error) NodeUnprepareResource(context.Context, *NodeUnprepareResourceRequest) (*NodeUnprepareResourceResponse, error) }
NodeServer is the server API for Node service.
type NodeUnprepareResourceRequest ¶
type NodeUnprepareResourceRequest 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. ClaimUid string `protobuf:"bytes,2,opt,name=claim_uid,json=claimUid,proto3" json:"claim_uid,omitempty"` // The name of the Resource claim (ResourceClaim.meta.Name) // This field is REQUIRED. ClaimName string `protobuf:"bytes,3,opt,name=claim_name,json=claimName,proto3" json:"claim_name,omitempty"` // Resource handle (AllocationResult.ResourceHandles[*].Data) // This field is REQUIRED. ResourceHandle string `protobuf:"bytes,4,opt,name=resource_handle,json=resourceHandle,proto3" json:"resource_handle,omitempty"` // Structured parameter resource handle (AllocationResult.ResourceHandles[*].StructuredData). // This field is OPTIONAL. If present, it needs to be used // instead of resource_handle. It will only have a single entry. StructuredResourceHandle []*v1alpha2.StructuredResourceHandle `` /* 135-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodeUnprepareResourceRequest) Descriptor ¶
func (*NodeUnprepareResourceRequest) Descriptor() ([]byte, []int)
func (*NodeUnprepareResourceRequest) GetClaimName ¶
func (m *NodeUnprepareResourceRequest) GetClaimName() string
func (*NodeUnprepareResourceRequest) GetClaimUid ¶
func (m *NodeUnprepareResourceRequest) GetClaimUid() string
func (*NodeUnprepareResourceRequest) GetNamespace ¶
func (m *NodeUnprepareResourceRequest) GetNamespace() string
func (*NodeUnprepareResourceRequest) GetResourceHandle ¶
func (m *NodeUnprepareResourceRequest) GetResourceHandle() string
func (*NodeUnprepareResourceRequest) GetStructuredResourceHandle ¶ added in v0.30.0
func (m *NodeUnprepareResourceRequest) GetStructuredResourceHandle() []*v1alpha2.StructuredResourceHandle
func (*NodeUnprepareResourceRequest) Marshal ¶
func (m *NodeUnprepareResourceRequest) Marshal() (dAtA []byte, err error)
func (*NodeUnprepareResourceRequest) MarshalTo ¶
func (m *NodeUnprepareResourceRequest) MarshalTo(dAtA []byte) (int, error)
func (*NodeUnprepareResourceRequest) MarshalToSizedBuffer ¶
func (m *NodeUnprepareResourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NodeUnprepareResourceRequest) ProtoMessage ¶
func (*NodeUnprepareResourceRequest) ProtoMessage()
func (*NodeUnprepareResourceRequest) Reset ¶
func (m *NodeUnprepareResourceRequest) Reset()
func (*NodeUnprepareResourceRequest) Size ¶
func (m *NodeUnprepareResourceRequest) Size() (n int)
func (*NodeUnprepareResourceRequest) String ¶
func (this *NodeUnprepareResourceRequest) String() string
func (*NodeUnprepareResourceRequest) Unmarshal ¶
func (m *NodeUnprepareResourceRequest) Unmarshal(dAtA []byte) error
func (*NodeUnprepareResourceRequest) XXX_DiscardUnknown ¶
func (m *NodeUnprepareResourceRequest) XXX_DiscardUnknown()
func (*NodeUnprepareResourceRequest) XXX_Marshal ¶
func (m *NodeUnprepareResourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodeUnprepareResourceRequest) XXX_Merge ¶
func (m *NodeUnprepareResourceRequest) XXX_Merge(src proto.Message)
func (*NodeUnprepareResourceRequest) XXX_Size ¶
func (m *NodeUnprepareResourceRequest) XXX_Size() int
func (*NodeUnprepareResourceRequest) XXX_Unmarshal ¶
func (m *NodeUnprepareResourceRequest) XXX_Unmarshal(b []byte) error
type NodeUnprepareResourceResponse ¶
type NodeUnprepareResourceResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodeUnprepareResourceResponse) Descriptor ¶
func (*NodeUnprepareResourceResponse) Descriptor() ([]byte, []int)
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 UnimplementedNodeServer ¶
type UnimplementedNodeServer struct { }
UnimplementedNodeServer can be embedded to have forward compatible implementations.
func (*UnimplementedNodeServer) NodePrepareResource ¶
func (*UnimplementedNodeServer) NodePrepareResource(ctx context.Context, req *NodePrepareResourceRequest) (*NodePrepareResourceResponse, error)
func (*UnimplementedNodeServer) NodeUnprepareResource ¶
func (*UnimplementedNodeServer) NodeUnprepareResource(ctx context.Context, req *NodeUnprepareResourceRequest) (*NodeUnprepareResourceResponse, error)
Click to show internal directories.
Click to hide internal directories.