v1

package
v0.21.15-rc.0 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2022 License: Apache-2.0 Imports: 12 Imported by: 57

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

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

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