cpuadvisor

package

Go to main page

Versions in this module

v0

v0.5.3

May 27, 2024

v0.5.2

May 22, 2024

v0.5.1

May 10, 2024

Changes in this version

type ListAndWatchResponse

+ AllowSharedCoresOverlapReclaimedCores bool

+ func (m *ListAndWatchResponse) GetAllowSharedCoresOverlapReclaimedCores() bool

v0.5.0

Apr 28, 2024

v0.4.2

Apr 24, 2024

v0.4.1

Apr 11, 2024

v0.4.0

Jan 9, 2024

v0.3.5

Apr 23, 2024

v0.3.4

Dec 15, 2023

v0.3.3

Nov 20, 2023

v0.3.2

Sep 8, 2023

v0.3.1

Aug 10, 2023

v0.3.0

Aug 8, 2023

Changes in this version

+ const NameSeparator

v0.2.0

Jun 13, 2023

Changes in this version

+ const EmptyOwnerPoolName

+ const FakedContainerName

+ const FakedNUMAID

+ type BlockCPUSet map[string]machine.CPUSet

+ func NewBlockCPUSet() BlockCPUSet

+ func (b BlockCPUSet) GetCPUSet() machine.CPUSet

type CalculationEntries

+ func (ce *CalculationEntries) GetNUMACalculationResult(container string, numa int64) (*NumaCalculationResult, bool)

type CalculationInfo

+ func (ci *CalculationInfo) GetCPUSet(entry, subEntry string, b BlockCPUSet) (machine.CPUSet, error)

+ func (ci *CalculationInfo) GetNUMAQuantities() (map[int]int, error)

+ func (ci *CalculationInfo) GetTotalQuantity() (int, error)

type ListAndWatchResponse

+ func (lwr *ListAndWatchResponse) FilterCalculationInfo(pool string) map[string]map[string]*CalculationInfo

+ func (lwr *ListAndWatchResponse) GeEntryNUMABlocks(entry, subEntry string, numa int64) ([]*Block, bool)

+ func (lwr *ListAndWatchResponse) GetBlocks() (map[int]map[string]*Block, error)

+ func (lwr *ListAndWatchResponse) GetCalculationInfo(entry, subEntry string) (*CalculationInfo, bool)

v0.1.0

Feb 27, 2023

Changes in this version

+ var ErrIntOverflowCpu = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthCpu = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupCpu = fmt.Errorf("proto: unexpected end of group")

+ var OverlapType_name = map[int32]string

+ var OverlapType_value = map[string]int32

+ func RegisterCPUAdvisorServer(s *grpc.Server, srv CPUAdvisorServer)

+ func RegisterCPUPluginServer(s *grpc.Server, srv CPUPluginServer)

+ type AddContainerRequest struct

+ Annotations map[string]string

+ ContainerIndex uint64

+ ContainerName string

+ ContainerType v1alpha1.ContainerType

+ Labels map[string]string

+ PodName string

+ PodNamespace string

+ PodUid string

+ QosLevel string

+ RequestQuantity uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*AddContainerRequest) Descriptor() ([]byte, []int)

+ func (*AddContainerRequest) ProtoMessage()

+ func (m *AddContainerRequest) GetAnnotations() map[string]string

+ func (m *AddContainerRequest) GetContainerIndex() uint64

+ func (m *AddContainerRequest) GetContainerName() string

+ func (m *AddContainerRequest) GetContainerType() v1alpha1.ContainerType

+ func (m *AddContainerRequest) GetLabels() map[string]string

+ func (m *AddContainerRequest) GetPodName() string

+ func (m *AddContainerRequest) GetPodNamespace() string

+ func (m *AddContainerRequest) GetPodUid() string

+ func (m *AddContainerRequest) GetQosLevel() string

+ func (m *AddContainerRequest) GetRequestQuantity() uint64

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

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

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

+ func (m *AddContainerRequest) Reset()

+ func (m *AddContainerRequest) Size() (n int)

+ func (m *AddContainerRequest) Unmarshal(dAtA []byte) error

+ func (m *AddContainerRequest) XXX_DiscardUnknown()

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

+ func (m *AddContainerRequest) XXX_Merge(src proto.Message)

+ func (m *AddContainerRequest) XXX_Size() int

+ func (m *AddContainerRequest) XXX_Unmarshal(b []byte) error

+ func (this *AddContainerRequest) String() string

+ type AddContainerResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*AddContainerResponse) Descriptor() ([]byte, []int)

+ func (*AddContainerResponse) ProtoMessage()

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

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

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

+ func (m *AddContainerResponse) Reset()

+ func (m *AddContainerResponse) Size() (n int)

+ func (m *AddContainerResponse) Unmarshal(dAtA []byte) error

+ func (m *AddContainerResponse) XXX_DiscardUnknown()

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

+ func (m *AddContainerResponse) XXX_Merge(src proto.Message)

+ func (m *AddContainerResponse) XXX_Size() int

+ func (m *AddContainerResponse) XXX_Unmarshal(b []byte) error

+ func (this *AddContainerResponse) String() string

+ type AllocationEntries struct

+ Entries map[string]*AllocationInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*AllocationEntries) Descriptor() ([]byte, []int)

+ func (*AllocationEntries) ProtoMessage()

+ func (m *AllocationEntries) GetEntries() map[string]*AllocationInfo

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

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

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

+ func (m *AllocationEntries) Reset()

+ func (m *AllocationEntries) Size() (n int)

+ func (m *AllocationEntries) Unmarshal(dAtA []byte) error

+ func (m *AllocationEntries) XXX_DiscardUnknown()

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

+ func (m *AllocationEntries) XXX_Merge(src proto.Message)

+ func (m *AllocationEntries) XXX_Size() int

+ func (m *AllocationEntries) XXX_Unmarshal(b []byte) error

+ func (this *AllocationEntries) String() string

+ type AllocationInfo struct

+ OriginalTopologyAwareAssignments map[uint64]string

+ OwnerPoolName string

+ RampUp bool

+ TopologyAwareAssignments map[uint64]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*AllocationInfo) Descriptor() ([]byte, []int)

+ func (*AllocationInfo) ProtoMessage()

+ func (m *AllocationInfo) GetOriginalTopologyAwareAssignments() map[uint64]string

+ func (m *AllocationInfo) GetOwnerPoolName() string

+ func (m *AllocationInfo) GetRampUp() bool

+ func (m *AllocationInfo) GetTopologyAwareAssignments() map[uint64]string

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

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

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

+ func (m *AllocationInfo) Reset()

+ func (m *AllocationInfo) Size() (n int)

+ func (m *AllocationInfo) Unmarshal(dAtA []byte) error

+ func (m *AllocationInfo) XXX_DiscardUnknown()

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

+ func (m *AllocationInfo) XXX_Merge(src proto.Message)

+ func (m *AllocationInfo) XXX_Size() int

+ func (m *AllocationInfo) XXX_Unmarshal(b []byte) error

+ func (this *AllocationInfo) String() string

+ type Block struct

+ BlockId string

+ OverlapTargets []*OverlapTarget

+ Result uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*Block) Descriptor() ([]byte, []int)

+ func (*Block) ProtoMessage()

+ func (m *Block) GetBlockId() string

+ func (m *Block) GetOverlapTargets() []*OverlapTarget

+ func (m *Block) GetResult() uint64

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

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

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

+ func (m *Block) Reset()

+ func (m *Block) Size() (n int)

+ func (m *Block) Unmarshal(dAtA []byte) error

+ func (m *Block) XXX_DiscardUnknown()

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

+ func (m *Block) XXX_Merge(src proto.Message)

+ func (m *Block) XXX_Size() int

+ func (m *Block) XXX_Unmarshal(b []byte) error

+ func (this *Block) String() string

+ type CPUAdvisorClient interface

+ AddContainer func(ctx context.Context, in *AddContainerRequest, opts ...grpc.CallOption) (*AddContainerResponse, error)

+ ListAndWatch func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (CPUAdvisor_ListAndWatchClient, error)

+ RemovePod func(ctx context.Context, in *RemovePodRequest, opts ...grpc.CallOption) (*RemovePodResponse, error)

+ func NewCPUAdvisorClient(cc *grpc.ClientConn) CPUAdvisorClient

+ func NewCPUAdvisorClientStub() CPUAdvisorClient

+ type CPUAdvisorServer interface

+ AddContainer func(context.Context, *AddContainerRequest) (*AddContainerResponse, error)

+ ListAndWatch func(*Empty, CPUAdvisor_ListAndWatchServer) error

+ RemovePod func(context.Context, *RemovePodRequest) (*RemovePodResponse, error)

+ type CPUAdvisor_ListAndWatchClient interface

+ Recv func() (*ListAndWatchResponse, error)

+ type CPUAdvisor_ListAndWatchServer interface

+ Send func(*ListAndWatchResponse) error

+ type CPUPluginClient interface

+ GetCheckpoint func(ctx context.Context, in *GetCheckpointRequest, opts ...grpc.CallOption) (*GetCheckpointResponse, error)

+ func NewCPUPluginClient(cc *grpc.ClientConn) CPUPluginClient

+ type CPUPluginServer interface

+ GetCheckpoint func(context.Context, *GetCheckpointRequest) (*GetCheckpointResponse, error)

+ type CalculationEntries struct

+ Entries map[string]*CalculationInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*CalculationEntries) Descriptor() ([]byte, []int)

+ func (*CalculationEntries) ProtoMessage()

+ func (m *CalculationEntries) GetEntries() map[string]*CalculationInfo

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

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

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

+ func (m *CalculationEntries) Reset()

+ func (m *CalculationEntries) Size() (n int)

+ func (m *CalculationEntries) Unmarshal(dAtA []byte) error

+ func (m *CalculationEntries) XXX_DiscardUnknown()

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

+ func (m *CalculationEntries) XXX_Merge(src proto.Message)

+ func (m *CalculationEntries) XXX_Size() int

+ func (m *CalculationEntries) XXX_Unmarshal(b []byte) error

+ func (this *CalculationEntries) String() string

+ type CalculationInfo struct

+ CalculationResultsByNumas map[int64]*NumaCalculationResult

+ OwnerPoolName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*CalculationInfo) Descriptor() ([]byte, []int)

+ func (*CalculationInfo) ProtoMessage()

+ func (m *CalculationInfo) GetCalculationResultsByNumas() map[int64]*NumaCalculationResult

+ func (m *CalculationInfo) GetOwnerPoolName() string

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

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

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

+ func (m *CalculationInfo) Reset()

+ func (m *CalculationInfo) Size() (n int)

+ func (m *CalculationInfo) Unmarshal(dAtA []byte) error

+ func (m *CalculationInfo) XXX_DiscardUnknown()

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

+ func (m *CalculationInfo) XXX_Merge(src proto.Message)

+ func (m *CalculationInfo) XXX_Size() int

+ func (m *CalculationInfo) XXX_Unmarshal(b []byte) error

+ func (this *CalculationInfo) String() string

+ type Empty struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

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

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

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

+ func (m *Empty) Reset()

+ func (m *Empty) Size() (n int)

+ func (m *Empty) Unmarshal(dAtA []byte) error

+ func (m *Empty) XXX_DiscardUnknown()

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

+ func (m *Empty) XXX_Merge(src proto.Message)

+ func (m *Empty) XXX_Size() int

+ func (m *Empty) XXX_Unmarshal(b []byte) error

+ func (this *Empty) String() string

+ type GetCheckpointRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*GetCheckpointRequest) Descriptor() ([]byte, []int)

+ func (*GetCheckpointRequest) ProtoMessage()

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

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

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

+ func (m *GetCheckpointRequest) Reset()

+ func (m *GetCheckpointRequest) Size() (n int)

+ func (m *GetCheckpointRequest) Unmarshal(dAtA []byte) error

+ func (m *GetCheckpointRequest) XXX_DiscardUnknown()

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

+ func (m *GetCheckpointRequest) XXX_Merge(src proto.Message)

+ func (m *GetCheckpointRequest) XXX_Size() int

+ func (m *GetCheckpointRequest) XXX_Unmarshal(b []byte) error

+ func (this *GetCheckpointRequest) String() string

+ type GetCheckpointResponse struct

+ Entries map[string]*AllocationEntries

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*GetCheckpointResponse) Descriptor() ([]byte, []int)

+ func (*GetCheckpointResponse) ProtoMessage()

+ func (m *GetCheckpointResponse) GetEntries() map[string]*AllocationEntries

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

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

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

+ func (m *GetCheckpointResponse) Reset()

+ func (m *GetCheckpointResponse) Size() (n int)

+ func (m *GetCheckpointResponse) Unmarshal(dAtA []byte) error

+ func (m *GetCheckpointResponse) XXX_DiscardUnknown()

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

+ func (m *GetCheckpointResponse) XXX_Merge(src proto.Message)

+ func (m *GetCheckpointResponse) XXX_Size() int

+ func (m *GetCheckpointResponse) XXX_Unmarshal(b []byte) error

+ func (this *GetCheckpointResponse) String() string

+ type ListAndWatchResponse struct

+ Entries map[string]*CalculationEntries

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*ListAndWatchResponse) Descriptor() ([]byte, []int)

+ func (*ListAndWatchResponse) ProtoMessage()

+ func (m *ListAndWatchResponse) GetEntries() map[string]*CalculationEntries

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

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

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

+ func (m *ListAndWatchResponse) Reset()

+ func (m *ListAndWatchResponse) Size() (n int)

+ func (m *ListAndWatchResponse) Unmarshal(dAtA []byte) error

+ func (m *ListAndWatchResponse) XXX_DiscardUnknown()

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

+ func (m *ListAndWatchResponse) XXX_Merge(src proto.Message)

+ func (m *ListAndWatchResponse) XXX_Size() int

+ func (m *ListAndWatchResponse) XXX_Unmarshal(b []byte) error

+ func (this *ListAndWatchResponse) String() string

+ type NumaCalculationResult struct

+ Blocks []*Block

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*NumaCalculationResult) Descriptor() ([]byte, []int)

+ func (*NumaCalculationResult) ProtoMessage()

+ func (m *NumaCalculationResult) GetBlocks() []*Block

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

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

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

+ func (m *NumaCalculationResult) Reset()

+ func (m *NumaCalculationResult) Size() (n int)

+ func (m *NumaCalculationResult) Unmarshal(dAtA []byte) error

+ func (m *NumaCalculationResult) XXX_DiscardUnknown()

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

+ func (m *NumaCalculationResult) XXX_Merge(src proto.Message)

+ func (m *NumaCalculationResult) XXX_Size() int

+ func (m *NumaCalculationResult) XXX_Unmarshal(b []byte) error

+ func (this *NumaCalculationResult) String() string

+ type OverlapTarget struct

+ OverlapTargetContainerName string

+ OverlapTargetPodUid string

+ OverlapTargetPoolName string

+ OverlapType OverlapType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*OverlapTarget) Descriptor() ([]byte, []int)

+ func (*OverlapTarget) ProtoMessage()

+ func (m *OverlapTarget) GetOverlapTargetContainerName() string

+ func (m *OverlapTarget) GetOverlapTargetPodUid() string

+ func (m *OverlapTarget) GetOverlapTargetPoolName() string

+ func (m *OverlapTarget) GetOverlapType() OverlapType

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

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

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

+ func (m *OverlapTarget) Reset()

+ func (m *OverlapTarget) Size() (n int)

+ func (m *OverlapTarget) Unmarshal(dAtA []byte) error

+ func (m *OverlapTarget) XXX_DiscardUnknown()

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

+ func (m *OverlapTarget) XXX_Merge(src proto.Message)

+ func (m *OverlapTarget) XXX_Size() int

+ func (m *OverlapTarget) XXX_Unmarshal(b []byte) error

+ func (this *OverlapTarget) String() string

+ type OverlapType int32

+ const OverlapType_OverlapWithPod

+ const OverlapType_OverlapWithPool

+ func (OverlapType) EnumDescriptor() ([]byte, []int)

+ func (x OverlapType) String() string

+ type RemovePodRequest struct

+ PodUid string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*RemovePodRequest) Descriptor() ([]byte, []int)

+ func (*RemovePodRequest) ProtoMessage()

+ func (m *RemovePodRequest) GetPodUid() string

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

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

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

+ func (m *RemovePodRequest) Reset()

+ func (m *RemovePodRequest) Size() (n int)

+ func (m *RemovePodRequest) Unmarshal(dAtA []byte) error

+ func (m *RemovePodRequest) XXX_DiscardUnknown()

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

+ func (m *RemovePodRequest) XXX_Merge(src proto.Message)

+ func (m *RemovePodRequest) XXX_Size() int

+ func (m *RemovePodRequest) XXX_Unmarshal(b []byte) error

+ func (this *RemovePodRequest) String() string

+ type RemovePodResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ func (*RemovePodResponse) Descriptor() ([]byte, []int)

+ func (*RemovePodResponse) ProtoMessage()

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

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

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

+ func (m *RemovePodResponse) Reset()

+ func (m *RemovePodResponse) Size() (n int)

+ func (m *RemovePodResponse) Unmarshal(dAtA []byte) error

+ func (m *RemovePodResponse) XXX_DiscardUnknown()

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

+ func (m *RemovePodResponse) XXX_Merge(src proto.Message)

+ func (m *RemovePodResponse) XXX_Size() int

+ func (m *RemovePodResponse) XXX_Unmarshal(b []byte) error

+ func (this *RemovePodResponse) String() string

+ type UnimplementedCPUAdvisorServer struct

+ func (*UnimplementedCPUAdvisorServer) AddContainer(ctx context.Context, req *AddContainerRequest) (*AddContainerResponse, error)

+ func (*UnimplementedCPUAdvisorServer) ListAndWatch(req *Empty, srv CPUAdvisor_ListAndWatchServer) error

+ func (*UnimplementedCPUAdvisorServer) RemovePod(ctx context.Context, req *RemovePodRequest) (*RemovePodResponse, error)

+ type UnimplementedCPUPluginServer struct

+ func (*UnimplementedCPUPluginServer) GetCheckpoint(ctx context.Context, req *GetCheckpointRequest) (*GetCheckpointResponse, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL