dra

package
v0.26.15 Latest Latest
Warning

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

 Go to latest Published: Mar 14, 2024 License: Apache-2.0 Imports: 12 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 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.ResourceHandle)
	// This field is REQUIRED.
	ResourceHandle       string   `protobuf:"bytes,4,opt,name=resource_handle,json=resourceHandle,proto3" json:"resource_handle,omitempty"`
	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) 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"`
	// List of fully qualified CDI device names
	// Kubelet plugin returns them in the NodePrepareResourceResponse
	CdiDevices           []string `protobuf:"bytes,4,rep,name=cdi_devices,json=cdiDevices,proto3" json:"cdi_devices,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeUnprepareResourceRequest) Descriptor 

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

func (*NodeUnprepareResourceRequest) GetCdiDevices 

func (m *NodeUnprepareResourceRequest) GetCdiDevices() []string

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

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.