v1alpha3

package
v0.30.1 Latest Latest
Warning

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

 Go to latest Published: May 15, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

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")
)

Functions

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"`
	// 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 (*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) GetResourceHandle 

func (m *Claim) GetResourceHandle() string

func (*Claim) GetStructuredResourceHandle added in v0.30.0 

func (m *Claim) GetStructuredResourceHandle() []*v1alpha2.StructuredResourceHandle

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 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)
	// NodeListAndWatchResources returns a stream of NodeResourcesResponse objects.
	// At the start and whenever resource availability changes, the
	// plugin must send one such object with all information to the Kubelet.
	NodeListAndWatchResources(ctx context.Context, in *NodeListAndWatchResourcesRequest, opts ...grpc.CallOption) (Node_NodeListAndWatchResourcesClient, 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 NodeListAndWatchResourcesRequest added in v0.30.0 

type NodeListAndWatchResourcesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeListAndWatchResourcesRequest) Descriptor added in v0.30.0 

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

func (*NodeListAndWatchResourcesRequest) Marshal added in v0.30.0 

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

func (*NodeListAndWatchResourcesRequest) MarshalTo added in v0.30.0 

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

func (*NodeListAndWatchResourcesRequest) MarshalToSizedBuffer added in v0.30.0 

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

func (*NodeListAndWatchResourcesRequest) ProtoMessage added in v0.30.0 

func (*NodeListAndWatchResourcesRequest) ProtoMessage()

func (*NodeListAndWatchResourcesRequest) Reset added in v0.30.0 

func (m *NodeListAndWatchResourcesRequest) Reset()

func (*NodeListAndWatchResourcesRequest) Size added in v0.30.0 

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

func (*NodeListAndWatchResourcesRequest) String added in v0.30.0 

func (this *NodeListAndWatchResourcesRequest) String() string

func (*NodeListAndWatchResourcesRequest) Unmarshal added in v0.30.0 

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

func (*NodeListAndWatchResourcesRequest) XXX_DiscardUnknown added in v0.30.0 

func (m *NodeListAndWatchResourcesRequest) XXX_DiscardUnknown()

func (*NodeListAndWatchResourcesRequest) XXX_Marshal added in v0.30.0 

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

func (*NodeListAndWatchResourcesRequest) XXX_Merge added in v0.30.0 

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

func (*NodeListAndWatchResourcesRequest) XXX_Size added in v0.30.0 

func (m *NodeListAndWatchResourcesRequest) XXX_Size() int

func (*NodeListAndWatchResourcesRequest) XXX_Unmarshal added in v0.30.0 

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

type NodeListAndWatchResourcesResponse added in v0.30.0 

type NodeListAndWatchResourcesResponse struct {
	Resources            []*v1alpha2.ResourceModel `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*NodeListAndWatchResourcesResponse) Descriptor added in v0.30.0 

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

func (*NodeListAndWatchResourcesResponse) GetResources added in v0.30.0 

func (m *NodeListAndWatchResourcesResponse) GetResources() []*v1alpha2.ResourceModel

func (*NodeListAndWatchResourcesResponse) Marshal added in v0.30.0 

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

func (*NodeListAndWatchResourcesResponse) MarshalTo added in v0.30.0 

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

func (*NodeListAndWatchResourcesResponse) MarshalToSizedBuffer added in v0.30.0 

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

func (*NodeListAndWatchResourcesResponse) ProtoMessage added in v0.30.0 

func (*NodeListAndWatchResourcesResponse) ProtoMessage()

func (*NodeListAndWatchResourcesResponse) Reset added in v0.30.0 

func (m *NodeListAndWatchResourcesResponse) Reset()

func (*NodeListAndWatchResourcesResponse) Size added in v0.30.0 

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

func (*NodeListAndWatchResourcesResponse) String added in v0.30.0 

func (this *NodeListAndWatchResourcesResponse) String() string

func (*NodeListAndWatchResourcesResponse) Unmarshal added in v0.30.0 

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

func (*NodeListAndWatchResourcesResponse) XXX_DiscardUnknown added in v0.30.0 

func (m *NodeListAndWatchResourcesResponse) XXX_DiscardUnknown()

func (*NodeListAndWatchResourcesResponse) XXX_Marshal added in v0.30.0 

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

func (*NodeListAndWatchResourcesResponse) XXX_Merge added in v0.30.0 

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

func (*NodeListAndWatchResourcesResponse) XXX_Size added in v0.30.0 

func (m *NodeListAndWatchResourcesResponse) XXX_Size() int

func (*NodeListAndWatchResourcesResponse) XXX_Unmarshal added in v0.30.0 

func (m *NodeListAndWatchResourcesResponse) 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"`
	// If non-empty, preparing the ResourceClaim failed.
	// cdi_devices is 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) GetCDIDevices 

func (m *NodePrepareResourceResponse) GetCDIDevices() []string

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)
	// NodeListAndWatchResources returns a stream of NodeResourcesResponse objects.
	// At the start and whenever resource availability changes, the
	// plugin must send one such object with all information to the Kubelet.
	NodeListAndWatchResources(*NodeListAndWatchResourcesRequest, Node_NodeListAndWatchResourcesServer) 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 Node_NodeListAndWatchResourcesClient added in v0.30.0 

type Node_NodeListAndWatchResourcesClient interface {
	Recv() (*NodeListAndWatchResourcesResponse, error)
	grpc.ClientStream
}

type Node_NodeListAndWatchResourcesServer added in v0.30.0 

type Node_NodeListAndWatchResourcesServer interface {
	Send(*NodeListAndWatchResourcesResponse) error
	grpc.ServerStream
}

type UnimplementedNodeServer 

type UnimplementedNodeServer struct {
}

UnimplementedNodeServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodeServer) NodeListAndWatchResources added in v0.30.0 

func (*UnimplementedNodeServer) NodeListAndWatchResources(req *NodeListAndWatchResourcesRequest, srv Node_NodeListAndWatchResourcesServer) error

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)

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.