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

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

func (*AllocatableResourcesRequest) Descriptor

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

func (*AllocatableResourcesRequest) Marshal

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

func (*AllocatableResourcesRequest) MarshalTo

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

func (*AllocatableResourcesRequest) MarshalToSizedBuffer

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

func (*AllocatableResourcesRequest) ProtoMessage

func (*AllocatableResourcesRequest) ProtoMessage()

func (*AllocatableResourcesRequest) Reset

func (m *AllocatableResourcesRequest) Reset()

func (*AllocatableResourcesRequest) Size

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

func (*AllocatableResourcesRequest) String

func (this *AllocatableResourcesRequest) String() string

func (*AllocatableResourcesRequest) Unmarshal

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

func (*AllocatableResourcesRequest) XXX_DiscardUnknown

func (m *AllocatableResourcesRequest) XXX_DiscardUnknown()

func (*AllocatableResourcesRequest) XXX_Marshal

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

func (*AllocatableResourcesRequest) XXX_Merge

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

func (*AllocatableResourcesRequest) XXX_Size

func (m *AllocatableResourcesRequest) XXX_Size() int

func (*AllocatableResourcesRequest) XXX_Unmarshal

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

type AllocatableResourcesResponse

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

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

    func (*AllocatableResourcesResponse) GetCpuIds

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

    func (*AllocatableResourcesResponse) GetDevices

    func (*AllocatableResourcesResponse) Marshal

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

    func (*AllocatableResourcesResponse) MarshalTo

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

    func (*AllocatableResourcesResponse) MarshalToSizedBuffer

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

    func (*AllocatableResourcesResponse) ProtoMessage

    func (*AllocatableResourcesResponse) ProtoMessage()

    func (*AllocatableResourcesResponse) Reset

    func (m *AllocatableResourcesResponse) Reset()

    func (*AllocatableResourcesResponse) Size

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

    func (*AllocatableResourcesResponse) String

    func (this *AllocatableResourcesResponse) String() string

    func (*AllocatableResourcesResponse) Unmarshal

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

    func (*AllocatableResourcesResponse) XXX_DiscardUnknown

    func (m *AllocatableResourcesResponse) XXX_DiscardUnknown()

    func (*AllocatableResourcesResponse) XXX_Marshal

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

    func (*AllocatableResourcesResponse) XXX_Merge

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

    func (*AllocatableResourcesResponse) XXX_Size

    func (m *AllocatableResourcesResponse) XXX_Size() int

    func (*AllocatableResourcesResponse) XXX_Unmarshal

    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

                        func (*UnimplementedPodResourcesListerServer) List

                        Source Files