v1beta1

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: 13 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	// DRAPluginService needs to be listed in the "supported versions"
	// array during plugin registration by a DRA plugin which provides
	// an implementation of the v1beta1 DRAPlugin service.
	DRAPluginService = "v1beta1.DRAPlugin"
)

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 RegisterDRAPluginServer 

func RegisterDRAPluginServer(s *grpc.Server, srv DRAPluginServer)

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 DRAPluginClient 

type DRAPluginClient 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)
}

DRAPluginClient is the client API for DRAPlugin service.

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

func NewDRAPluginClient 

func NewDRAPluginClient(cc *grpc.ClientConn) DRAPluginClient

type DRAPluginServer 

type DRAPluginServer 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)
}

DRAPluginServer is the server API for DRAPlugin service.

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

type UnimplementedDRAPluginServer struct {
}

UnimplementedDRAPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedDRAPluginServer) NodePrepareResources 

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

func (*UnimplementedDRAPluginServer) NodeUnprepareResources 

func (*UnimplementedDRAPluginServer) 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.