v1

package
v0.30.0 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2024 License: Apache-2.0 Imports: 12 Imported by: 47

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 RegisterPodResourcesListerServer 

func RegisterPodResourcesListerServer(s *grpc.Server, srv PodResourcesListerServer)

Types

type AllocatableResourcesRequest added in v0.21.0 

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

func (*AllocatableResourcesRequest) Descriptor added in v0.21.0 

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

func (*AllocatableResourcesRequest) Marshal added in v0.21.0 

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

func (*AllocatableResourcesRequest) MarshalTo added in v0.21.0 

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

func (*AllocatableResourcesRequest) MarshalToSizedBuffer added in v0.21.0 

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

func (*AllocatableResourcesRequest) ProtoMessage added in v0.21.0 

func (*AllocatableResourcesRequest) ProtoMessage()

func (*AllocatableResourcesRequest) Reset added in v0.21.0 

func (m *AllocatableResourcesRequest) Reset()

func (*AllocatableResourcesRequest) Size added in v0.21.0 

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

func (*AllocatableResourcesRequest) String added in v0.21.0 

func (this *AllocatableResourcesRequest) String() string

func (*AllocatableResourcesRequest) Unmarshal added in v0.21.0 

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

func (*AllocatableResourcesRequest) XXX_DiscardUnknown added in v0.21.0 

func (m *AllocatableResourcesRequest) XXX_DiscardUnknown()

func (*AllocatableResourcesRequest) XXX_Marshal added in v0.21.0 

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

func (*AllocatableResourcesRequest) XXX_Merge added in v0.21.0 

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

func (*AllocatableResourcesRequest) XXX_Size added in v0.21.0 

func (m *AllocatableResourcesRequest) XXX_Size() int

func (*AllocatableResourcesRequest) XXX_Unmarshal added in v0.21.0 

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

type AllocatableResourcesResponse added in v0.21.0 

type AllocatableResourcesResponse struct {
	Devices              []*ContainerDevices `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	CpuIds               []int64             `protobuf:"varint,2,rep,packed,name=cpu_ids,json=cpuIds,proto3" json:"cpu_ids,omitempty"`
	Memory               []*ContainerMemory  `protobuf:"bytes,3,rep,name=memory,proto3" json:"memory,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

AllocatableResourcesResponses contains informations about all the devices known by the kubelet

func (*AllocatableResourcesResponse) Descriptor added in v0.21.0 

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

func (*AllocatableResourcesResponse) GetCpuIds added in v0.21.0 

func (m *AllocatableResourcesResponse) GetCpuIds() []int64

func (*AllocatableResourcesResponse) GetDevices added in v0.21.0 

func (m *AllocatableResourcesResponse) GetDevices() []*ContainerDevices

func (*AllocatableResourcesResponse) GetMemory added in v0.22.0 

func (m *AllocatableResourcesResponse) GetMemory() []*ContainerMemory

func (*AllocatableResourcesResponse) Marshal added in v0.21.0 

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

func (*AllocatableResourcesResponse) MarshalTo added in v0.21.0 

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

func (*AllocatableResourcesResponse) MarshalToSizedBuffer added in v0.21.0 

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

func (*AllocatableResourcesResponse) ProtoMessage added in v0.21.0 

func (*AllocatableResourcesResponse) ProtoMessage()

func (*AllocatableResourcesResponse) Reset added in v0.21.0 

func (m *AllocatableResourcesResponse) Reset()

func (*AllocatableResourcesResponse) Size added in v0.21.0 

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

func (*AllocatableResourcesResponse) String added in v0.21.0 

func (this *AllocatableResourcesResponse) String() string

func (*AllocatableResourcesResponse) Unmarshal added in v0.21.0 

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

func (*AllocatableResourcesResponse) XXX_DiscardUnknown added in v0.21.0 

func (m *AllocatableResourcesResponse) XXX_DiscardUnknown()

func (*AllocatableResourcesResponse) XXX_Marshal added in v0.21.0 

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

func (*AllocatableResourcesResponse) XXX_Merge added in v0.21.0 

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

func (*AllocatableResourcesResponse) XXX_Size added in v0.21.0 

func (m *AllocatableResourcesResponse) XXX_Size() int

func (*AllocatableResourcesResponse) XXX_Unmarshal added in v0.21.0 

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

type CDIDevice added in v0.27.0 

type CDIDevice struct {
	// Fully qualified CDI device name
	// for example: vendor.com/gpu=gpudevice1
	// see more details in the CDI specification:
	// https://github.com/container-orchestrated-devices/container-device-interface/blob/main/SPEC.md
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CDIDevice specifies a CDI device information

func (*CDIDevice) Descriptor added in v0.27.0 

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

func (*CDIDevice) GetName added in v0.27.0 

func (m *CDIDevice) GetName() string

func (*CDIDevice) Marshal added in v0.27.0 

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

func (*CDIDevice) MarshalTo added in v0.27.0 

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

func (*CDIDevice) MarshalToSizedBuffer added in v0.27.0 

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

func (*CDIDevice) ProtoMessage added in v0.27.0 

func (*CDIDevice) ProtoMessage()

func (*CDIDevice) Reset added in v0.27.0 

func (m *CDIDevice) Reset()

func (*CDIDevice) Size added in v0.27.0 

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

func (*CDIDevice) String added in v0.27.0 

func (this *CDIDevice) String() string

func (*CDIDevice) Unmarshal added in v0.27.0 

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

func (*CDIDevice) XXX_DiscardUnknown added in v0.27.0 

func (m *CDIDevice) XXX_DiscardUnknown()

func (*CDIDevice) XXX_Marshal added in v0.27.0 

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

func (*CDIDevice) XXX_Merge added in v0.27.0 

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

func (*CDIDevice) XXX_Size added in v0.27.0 

func (m *CDIDevice) XXX_Size() int

func (*CDIDevice) XXX_Unmarshal added in v0.27.0 

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

type ClaimResource added in v0.27.0 

type ClaimResource struct {
	CDIDevices           []*CDIDevice `protobuf:"bytes,1,rep,name=cdi_devices,json=cdiDevices,proto3" json:"cdi_devices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

ClaimResource contains per plugin resource information

func (*ClaimResource) Descriptor added in v0.27.0 

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

func (*ClaimResource) GetCDIDevices added in v0.27.0 

func (m *ClaimResource) GetCDIDevices() []*CDIDevice

func (*ClaimResource) Marshal added in v0.27.0 

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

func (*ClaimResource) MarshalTo added in v0.27.0 

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

func (*ClaimResource) MarshalToSizedBuffer added in v0.27.0 

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

func (*ClaimResource) ProtoMessage added in v0.27.0 

func (*ClaimResource) ProtoMessage()

func (*ClaimResource) Reset added in v0.27.0 

func (m *ClaimResource) Reset()

func (*ClaimResource) Size added in v0.27.0 

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

func (*ClaimResource) String added in v0.27.0 

func (this *ClaimResource) String() string

func (*ClaimResource) Unmarshal added in v0.27.0 

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

func (*ClaimResource) XXX_DiscardUnknown added in v0.27.0 

func (m *ClaimResource) XXX_DiscardUnknown()

func (*ClaimResource) XXX_Marshal added in v0.27.0 

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

func (*ClaimResource) XXX_Merge added in v0.27.0 

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

func (*ClaimResource) XXX_Size added in v0.27.0 

func (m *ClaimResource) XXX_Size() int

func (*ClaimResource) XXX_Unmarshal added in v0.27.0 

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

type ContainerDevices 

type ContainerDevices struct {
	ResourceName         string        `protobuf:"bytes,1,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	DeviceIds            []string      `protobuf:"bytes,2,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"`
	Topology             *TopologyInfo `protobuf:"bytes,3,opt,name=topology,proto3" json:"topology,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

ContainerDevices contains information about the devices assigned to a container

func (*ContainerDevices) Descriptor 

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

func (*ContainerDevices) GetDeviceIds 

func (m *ContainerDevices) GetDeviceIds() []string

func (*ContainerDevices) GetResourceName 

func (m *ContainerDevices) GetResourceName() string

func (*ContainerDevices) GetTopology 

func (m *ContainerDevices) GetTopology() *TopologyInfo

func (*ContainerDevices) Marshal 

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

func (*ContainerDevices) MarshalTo 

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

func (*ContainerDevices) MarshalToSizedBuffer 

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

func (*ContainerDevices) ProtoMessage 

func (*ContainerDevices) ProtoMessage()

func (*ContainerDevices) Reset 

func (m *ContainerDevices) Reset()

func (*ContainerDevices) Size 

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

func (*ContainerDevices) String 

func (this *ContainerDevices) String() string

func (*ContainerDevices) Unmarshal 

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

func (*ContainerDevices) XXX_DiscardUnknown 

func (m *ContainerDevices) XXX_DiscardUnknown()

func (*ContainerDevices) XXX_Marshal 

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

func (*ContainerDevices) XXX_Merge 

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

func (*ContainerDevices) XXX_Size 

func (m *ContainerDevices) XXX_Size() int

func (*ContainerDevices) XXX_Unmarshal 

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

type ContainerMemory added in v0.22.0 

type ContainerMemory struct {
	MemoryType           string        `protobuf:"bytes,1,opt,name=memory_type,json=memoryType,proto3" json:"memory_type,omitempty"`
	Size_                uint64        `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Topology             *TopologyInfo `protobuf:"bytes,3,opt,name=topology,proto3" json:"topology,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

ContainerMemory contains information about memory and hugepages assigned to a container

func (*ContainerMemory) Descriptor added in v0.22.0 

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

func (*ContainerMemory) GetMemoryType added in v0.22.0 

func (m *ContainerMemory) GetMemoryType() string

func (*ContainerMemory) GetSize_ added in v0.22.0 

func (m *ContainerMemory) GetSize_() uint64

func (*ContainerMemory) GetTopology added in v0.22.0 

func (m *ContainerMemory) GetTopology() *TopologyInfo

func (*ContainerMemory) Marshal added in v0.22.0 

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

func (*ContainerMemory) MarshalTo added in v0.22.0 

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

func (*ContainerMemory) MarshalToSizedBuffer added in v0.22.0 

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

func (*ContainerMemory) ProtoMessage added in v0.22.0 

func (*ContainerMemory) ProtoMessage()

func (*ContainerMemory) Reset added in v0.22.0 

func (m *ContainerMemory) Reset()

func (*ContainerMemory) Size added in v0.22.0 

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

func (*ContainerMemory) String added in v0.22.0 

func (this *ContainerMemory) String() string

func (*ContainerMemory) Unmarshal added in v0.22.0 

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

func (*ContainerMemory) XXX_DiscardUnknown added in v0.22.0 

func (m *ContainerMemory) XXX_DiscardUnknown()

func (*ContainerMemory) XXX_Marshal added in v0.22.0 

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

func (*ContainerMemory) XXX_Merge added in v0.22.0 

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

func (*ContainerMemory) XXX_Size added in v0.22.0 

func (m *ContainerMemory) XXX_Size() int

func (*ContainerMemory) XXX_Unmarshal added in v0.22.0 

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

type ContainerResources 

type ContainerResources struct {
	Name                 string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Devices              []*ContainerDevices `protobuf:"bytes,2,rep,name=devices,proto3" json:"devices,omitempty"`
	CpuIds               []int64             `protobuf:"varint,3,rep,packed,name=cpu_ids,json=cpuIds,proto3" json:"cpu_ids,omitempty"`
	Memory               []*ContainerMemory  `protobuf:"bytes,4,rep,name=memory,proto3" json:"memory,omitempty"`
	DynamicResources     []*DynamicResource  `protobuf:"bytes,5,rep,name=dynamic_resources,json=dynamicResources,proto3" json:"dynamic_resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

ContainerResources contains information about the resources assigned to a container

func (*ContainerResources) Descriptor 

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

func (*ContainerResources) GetCpuIds 

func (m *ContainerResources) GetCpuIds() []int64

func (*ContainerResources) GetDevices 

func (m *ContainerResources) GetDevices() []*ContainerDevices

func (*ContainerResources) GetDynamicResources added in v0.27.0 

func (m *ContainerResources) GetDynamicResources() []*DynamicResource

func (*ContainerResources) GetMemory added in v0.22.0 

func (m *ContainerResources) GetMemory() []*ContainerMemory

func (*ContainerResources) GetName 

func (m *ContainerResources) GetName() string

func (*ContainerResources) Marshal 

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

func (*ContainerResources) MarshalTo 

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

func (*ContainerResources) MarshalToSizedBuffer 

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

func (*ContainerResources) ProtoMessage 

func (*ContainerResources) ProtoMessage()

func (*ContainerResources) Reset 

func (m *ContainerResources) Reset()

func (*ContainerResources) Size 

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

func (*ContainerResources) String 

func (this *ContainerResources) String() string

func (*ContainerResources) Unmarshal 

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

func (*ContainerResources) XXX_DiscardUnknown 

func (m *ContainerResources) XXX_DiscardUnknown()

func (*ContainerResources) XXX_Marshal 

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

func (*ContainerResources) XXX_Merge 

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

func (*ContainerResources) XXX_Size 

func (m *ContainerResources) XXX_Size() int

func (*ContainerResources) XXX_Unmarshal 

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

type DynamicResource added in v0.27.0 

type DynamicResource struct {
	ClassName            string           `protobuf:"bytes,1,opt,name=class_name,json=className,proto3" json:"class_name,omitempty"`
	ClaimName            string           `protobuf:"bytes,2,opt,name=claim_name,json=claimName,proto3" json:"claim_name,omitempty"`
	ClaimNamespace       string           `protobuf:"bytes,3,opt,name=claim_namespace,json=claimNamespace,proto3" json:"claim_namespace,omitempty"`
	ClaimResources       []*ClaimResource `protobuf:"bytes,4,rep,name=claim_resources,json=claimResources,proto3" json:"claim_resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

DynamicResource contains information about the devices assigned to a container by DRA

func (*DynamicResource) Descriptor added in v0.27.0 

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

func (*DynamicResource) GetClaimName added in v0.27.0 

func (m *DynamicResource) GetClaimName() string

func (*DynamicResource) GetClaimNamespace added in v0.27.0 

func (m *DynamicResource) GetClaimNamespace() string

func (*DynamicResource) GetClaimResources added in v0.27.0 

func (m *DynamicResource) GetClaimResources() []*ClaimResource

func (*DynamicResource) GetClassName added in v0.27.0 

func (m *DynamicResource) GetClassName() string

func (*DynamicResource) Marshal added in v0.27.0 

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

func (*DynamicResource) MarshalTo added in v0.27.0 

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

func (*DynamicResource) MarshalToSizedBuffer added in v0.27.0 

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

func (*DynamicResource) ProtoMessage added in v0.27.0 

func (*DynamicResource) ProtoMessage()

func (*DynamicResource) Reset added in v0.27.0 

func (m *DynamicResource) Reset()

func (*DynamicResource) Size added in v0.27.0 

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

func (*DynamicResource) String added in v0.27.0 

func (this *DynamicResource) String() string

func (*DynamicResource) Unmarshal added in v0.27.0 

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

func (*DynamicResource) XXX_DiscardUnknown added in v0.27.0 

func (m *DynamicResource) XXX_DiscardUnknown()

func (*DynamicResource) XXX_Marshal added in v0.27.0 

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

func (*DynamicResource) XXX_Merge added in v0.27.0 

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

func (*DynamicResource) XXX_Size added in v0.27.0 

func (m *DynamicResource) XXX_Size() int

func (*DynamicResource) XXX_Unmarshal added in v0.27.0 

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

type GetPodResourcesRequest added in v0.27.0 

type GetPodResourcesRequest struct {
	PodName              string   `protobuf:"bytes,1,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	PodNamespace         string   `protobuf:"bytes,2,opt,name=pod_namespace,json=podNamespace,proto3" json:"pod_namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetPodResourcesRequest contains information about the pod

func (*GetPodResourcesRequest) Descriptor added in v0.27.0 

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

func (*GetPodResourcesRequest) GetPodName added in v0.27.0 

func (m *GetPodResourcesRequest) GetPodName() string

func (*GetPodResourcesRequest) GetPodNamespace added in v0.27.0 

func (m *GetPodResourcesRequest) GetPodNamespace() string

func (*GetPodResourcesRequest) Marshal added in v0.27.0 

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

func (*GetPodResourcesRequest) MarshalTo added in v0.27.0 

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

func (*GetPodResourcesRequest) MarshalToSizedBuffer added in v0.27.0 

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

func (*GetPodResourcesRequest) ProtoMessage added in v0.27.0 

func (*GetPodResourcesRequest) ProtoMessage()

func (*GetPodResourcesRequest) Reset added in v0.27.0 

func (m *GetPodResourcesRequest) Reset()

func (*GetPodResourcesRequest) Size added in v0.27.0 

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

func (*GetPodResourcesRequest) String added in v0.27.0 

func (this *GetPodResourcesRequest) String() string

func (*GetPodResourcesRequest) Unmarshal added in v0.27.0 

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

func (*GetPodResourcesRequest) XXX_DiscardUnknown added in v0.27.0 

func (m *GetPodResourcesRequest) XXX_DiscardUnknown()

func (*GetPodResourcesRequest) XXX_Marshal added in v0.27.0 

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

func (*GetPodResourcesRequest) XXX_Merge added in v0.27.0 

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

func (*GetPodResourcesRequest) XXX_Size added in v0.27.0 

func (m *GetPodResourcesRequest) XXX_Size() int

func (*GetPodResourcesRequest) XXX_Unmarshal added in v0.27.0 

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

type GetPodResourcesResponse added in v0.27.0 

type GetPodResourcesResponse struct {
	PodResources         *PodResources `protobuf:"bytes,1,opt,name=pod_resources,json=podResources,proto3" json:"pod_resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

GetPodResourcesResponse contains information about the pod the devices

func (*GetPodResourcesResponse) Descriptor added in v0.27.0 

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

func (*GetPodResourcesResponse) GetPodResources added in v0.27.0 

func (m *GetPodResourcesResponse) GetPodResources() *PodResources

func (*GetPodResourcesResponse) Marshal added in v0.27.0 

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

func (*GetPodResourcesResponse) MarshalTo added in v0.27.0 

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

func (*GetPodResourcesResponse) MarshalToSizedBuffer added in v0.27.0 

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

func (*GetPodResourcesResponse) ProtoMessage added in v0.27.0 

func (*GetPodResourcesResponse) ProtoMessage()

func (*GetPodResourcesResponse) Reset added in v0.27.0 

func (m *GetPodResourcesResponse) Reset()

func (*GetPodResourcesResponse) Size added in v0.27.0 

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

func (*GetPodResourcesResponse) String added in v0.27.0 

func (this *GetPodResourcesResponse) String() string

func (*GetPodResourcesResponse) Unmarshal added in v0.27.0 

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

func (*GetPodResourcesResponse) XXX_DiscardUnknown added in v0.27.0 

func (m *GetPodResourcesResponse) XXX_DiscardUnknown()

func (*GetPodResourcesResponse) XXX_Marshal added in v0.27.0 

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

func (*GetPodResourcesResponse) XXX_Merge added in v0.27.0 

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

func (*GetPodResourcesResponse) XXX_Size added in v0.27.0 

func (m *GetPodResourcesResponse) XXX_Size() int

func (*GetPodResourcesResponse) XXX_Unmarshal added in v0.27.0 

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

type ListPodResourcesRequest 

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

ListPodResourcesRequest is the request made to the PodResourcesLister service

func (*ListPodResourcesRequest) Descriptor 

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

func (*ListPodResourcesRequest) Marshal 

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

func (*ListPodResourcesRequest) MarshalTo 

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

func (*ListPodResourcesRequest) MarshalToSizedBuffer 

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

func (*ListPodResourcesRequest) ProtoMessage 

func (*ListPodResourcesRequest) ProtoMessage()

func (*ListPodResourcesRequest) Reset 

func (m *ListPodResourcesRequest) Reset()

func (*ListPodResourcesRequest) Size 

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

func (*ListPodResourcesRequest) String 

func (this *ListPodResourcesRequest) String() string

func (*ListPodResourcesRequest) Unmarshal 

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

func (*ListPodResourcesRequest) XXX_DiscardUnknown 

func (m *ListPodResourcesRequest) XXX_DiscardUnknown()

func (*ListPodResourcesRequest) XXX_Marshal 

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

func (*ListPodResourcesRequest) XXX_Merge 

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

func (*ListPodResourcesRequest) XXX_Size 

func (m *ListPodResourcesRequest) XXX_Size() int

func (*ListPodResourcesRequest) XXX_Unmarshal 

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

type ListPodResourcesResponse 

type ListPodResourcesResponse struct {
	PodResources         []*PodResources `protobuf:"bytes,1,rep,name=pod_resources,json=podResources,proto3" json:"pod_resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

ListPodResourcesResponse is the response returned by List function

func (*ListPodResourcesResponse) Descriptor 

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

func (*ListPodResourcesResponse) GetPodResources 

func (m *ListPodResourcesResponse) GetPodResources() []*PodResources

func (*ListPodResourcesResponse) Marshal 

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

func (*ListPodResourcesResponse) MarshalTo 

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

func (*ListPodResourcesResponse) MarshalToSizedBuffer 

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

func (*ListPodResourcesResponse) ProtoMessage 

func (*ListPodResourcesResponse) ProtoMessage()

func (*ListPodResourcesResponse) Reset 

func (m *ListPodResourcesResponse) Reset()

func (*ListPodResourcesResponse) Size 

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

func (*ListPodResourcesResponse) String 

func (this *ListPodResourcesResponse) String() string

func (*ListPodResourcesResponse) Unmarshal 

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

func (*ListPodResourcesResponse) XXX_DiscardUnknown 

func (m *ListPodResourcesResponse) XXX_DiscardUnknown()

func (*ListPodResourcesResponse) XXX_Marshal 

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

func (*ListPodResourcesResponse) XXX_Merge 

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

func (*ListPodResourcesResponse) XXX_Size 

func (m *ListPodResourcesResponse) XXX_Size() int

func (*ListPodResourcesResponse) XXX_Unmarshal 

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

type NUMANode 

type NUMANode struct {
	ID                   int64    `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

NUMA representation of NUMA node

func (*NUMANode) Descriptor 

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

func (*NUMANode) GetID 

func (m *NUMANode) GetID() int64

func (*NUMANode) Marshal 

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

func (*NUMANode) MarshalTo 

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

func (*NUMANode) MarshalToSizedBuffer 

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

func (*NUMANode) ProtoMessage 

func (*NUMANode) ProtoMessage()

func (*NUMANode) Reset 

func (m *NUMANode) Reset()

func (*NUMANode) Size 

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

func (*NUMANode) String 

func (this *NUMANode) String() string

func (*NUMANode) Unmarshal 

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

func (*NUMANode) XXX_DiscardUnknown 

func (m *NUMANode) XXX_DiscardUnknown()

func (*NUMANode) XXX_Marshal 

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

func (*NUMANode) XXX_Merge 

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

func (*NUMANode) XXX_Size 

func (m *NUMANode) XXX_Size() int

func (*NUMANode) XXX_Unmarshal 

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

type PodResources 

type PodResources struct {
	Name                 string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string                `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Containers           []*ContainerResources `protobuf:"bytes,3,rep,name=containers,proto3" json:"containers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

PodResources contains information about the node resources assigned to a pod

func (*PodResources) Descriptor 

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

func (*PodResources) GetContainers 

func (m *PodResources) GetContainers() []*ContainerResources

func (*PodResources) GetName 

func (m *PodResources) GetName() string

func (*PodResources) GetNamespace 

func (m *PodResources) GetNamespace() string

func (*PodResources) Marshal 

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

func (*PodResources) MarshalTo 

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

func (*PodResources) MarshalToSizedBuffer 

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

func (*PodResources) ProtoMessage 

func (*PodResources) ProtoMessage()

func (*PodResources) Reset 

func (m *PodResources) Reset()

func (*PodResources) Size 

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

func (*PodResources) String 

func (this *PodResources) String() string

func (*PodResources) Unmarshal 

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

func (*PodResources) XXX_DiscardUnknown 

func (m *PodResources) XXX_DiscardUnknown()

func (*PodResources) XXX_Marshal 

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

func (*PodResources) XXX_Merge 

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

func (*PodResources) XXX_Size 

func (m *PodResources) XXX_Size() int

func (*PodResources) XXX_Unmarshal 

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

type PodResourcesListerClient 

type PodResourcesListerClient interface {
	List(ctx context.Context, in *ListPodResourcesRequest, opts ...grpc.CallOption) (*ListPodResourcesResponse, error)
	GetAllocatableResources(ctx context.Context, in *AllocatableResourcesRequest, opts ...grpc.CallOption) (*AllocatableResourcesResponse, error)
	Get(ctx context.Context, in *GetPodResourcesRequest, opts ...grpc.CallOption) (*GetPodResourcesResponse, error)
}

PodResourcesListerClient is the client API for PodResourcesLister service.

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

func NewPodResourcesListerClient 

func NewPodResourcesListerClient(cc *grpc.ClientConn) PodResourcesListerClient

type PodResourcesListerServer 

type PodResourcesListerServer interface {
	List(context.Context, *ListPodResourcesRequest) (*ListPodResourcesResponse, error)
	GetAllocatableResources(context.Context, *AllocatableResourcesRequest) (*AllocatableResourcesResponse, error)
	Get(context.Context, *GetPodResourcesRequest) (*GetPodResourcesResponse, error)
}

PodResourcesListerServer is the server API for PodResourcesLister service.

type TopologyInfo 

type TopologyInfo struct {
	Nodes                []*NUMANode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Topology describes hardware topology of the resource

func (*TopologyInfo) Descriptor 

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

func (*TopologyInfo) GetNodes 

func (m *TopologyInfo) GetNodes() []*NUMANode

func (*TopologyInfo) Marshal 

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

func (*TopologyInfo) MarshalTo 

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

func (*TopologyInfo) MarshalToSizedBuffer 

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

func (*TopologyInfo) ProtoMessage 

func (*TopologyInfo) ProtoMessage()

func (*TopologyInfo) Reset 

func (m *TopologyInfo) Reset()

func (*TopologyInfo) Size 

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

func (*TopologyInfo) String 

func (this *TopologyInfo) String() string

func (*TopologyInfo) Unmarshal 

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

func (*TopologyInfo) XXX_DiscardUnknown 

func (m *TopologyInfo) XXX_DiscardUnknown()

func (*TopologyInfo) XXX_Marshal 

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

func (*TopologyInfo) XXX_Merge 

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

func (*TopologyInfo) XXX_Size 

func (m *TopologyInfo) XXX_Size() int

func (*TopologyInfo) XXX_Unmarshal 

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

type UnimplementedPodResourcesListerServer 

type UnimplementedPodResourcesListerServer struct {
}

UnimplementedPodResourcesListerServer can be embedded to have forward compatible implementations.

func (*UnimplementedPodResourcesListerServer) Get added in v0.27.0 

func (*UnimplementedPodResourcesListerServer) Get(ctx context.Context, req *GetPodResourcesRequest) (*GetPodResourcesResponse, error)

func (*UnimplementedPodResourcesListerServer) GetAllocatableResources added in v0.21.0 

func (*UnimplementedPodResourcesListerServer) GetAllocatableResources(ctx context.Context, req *AllocatableResourcesRequest) (*AllocatableResourcesResponse, error)

func (*UnimplementedPodResourcesListerServer) List 

func (*UnimplementedPodResourcesListerServer) List(ctx context.Context, req *ListPodResourcesRequest) (*ListPodResourcesResponse, 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.