cpuadvisor

package
v0.5.21 Latest Latest
Warning

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

 Go to latest Published: Mar 18, 2025 License: Apache-2.0 Imports: 20 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCpu        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCpu          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCpu = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var OverlapType_name = map[int32]string{
	0: "OverlapWithPod",
	1: "OverlapWithPool",
}
View Source 
var OverlapType_value = map[string]int32{
	"OverlapWithPod":  0,
	"OverlapWithPool": 1,
}

Functions

func IsBlockOfRelcaim added in v0.5.4 

func IsBlockOfRelcaim(blockEntryNames [][]string) bool

func RegisterCPUAdvisorServer 

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

func RegisterCPUPluginServer 

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

Types

type AllocationEntries 

type AllocationEntries struct {
	Entries              map[string]*AllocationInfo `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*AllocationEntries) Descriptor 

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

func (*AllocationEntries) GetEntries 

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

func (*AllocationEntries) Marshal 

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

func (*AllocationEntries) MarshalTo 

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

func (*AllocationEntries) MarshalToSizedBuffer 

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

func (*AllocationEntries) ProtoMessage 

func (*AllocationEntries) ProtoMessage()

func (*AllocationEntries) Reset 

func (m *AllocationEntries) Reset()

func (*AllocationEntries) Size 

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

func (*AllocationEntries) String 

func (this *AllocationEntries) String() string

func (*AllocationEntries) Unmarshal 

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

func (*AllocationEntries) XXX_DiscardUnknown 

func (m *AllocationEntries) XXX_DiscardUnknown()

func (*AllocationEntries) XXX_Marshal 

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

func (*AllocationEntries) XXX_Merge 

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

func (*AllocationEntries) XXX_Size 

func (m *AllocationEntries) XXX_Size() int

func (*AllocationEntries) XXX_Unmarshal 

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

type AllocationInfo 

type AllocationInfo struct {
	RampUp bool `protobuf:"varint,1,opt,name=ramp_up,json=rampUp,proto3" json:"ramp_up,omitempty"`
	// owner_pool_name indicates the real pool this entry belongs to, it may equal to
	// 1. real pool name shows up explicitly in GetCheckpointResponse, including:
	//    - common pools (eg. share, reclaim, flink, batch, bmq)
	//    - pools generated by qos aware server containing isolated shared_cores containers (eg. isolation0, isolation1, ...)
	// 2. "dedicated" (dedicated_cores container with or without numa_biding)
	// 3. "fallback" (dedicated_cores without numa_binding will be put to this fake pool when it can't allocate isolated cpuset for them), there is no AllocationInfo for this fake pool
	// 4. empty (the entry is ramping up)
	OwnerPoolName                    string            `protobuf:"bytes,2,opt,name=owner_pool_name,json=ownerPoolName,proto3" json:"owner_pool_name,omitempty"`
	TopologyAwareAssignments         map[uint64]string `` /* 224-byte string literal not displayed */
	OriginalTopologyAwareAssignments map[uint64]string `` /* 250-byte string literal not displayed */
	XXX_NoUnkeyedLiteral             struct{}          `json:"-"`
	XXX_sizecache                    int32             `json:"-"`
}

func (*AllocationInfo) Descriptor 

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

func (*AllocationInfo) GetOriginalTopologyAwareAssignments 

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

func (*AllocationInfo) GetOwnerPoolName 

func (m *AllocationInfo) GetOwnerPoolName() string

func (*AllocationInfo) GetRampUp 

func (m *AllocationInfo) GetRampUp() bool

func (*AllocationInfo) GetTopologyAwareAssignments 

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

func (*AllocationInfo) Marshal 

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

func (*AllocationInfo) MarshalTo 

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

func (*AllocationInfo) MarshalToSizedBuffer 

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

func (*AllocationInfo) ProtoMessage 

func (*AllocationInfo) ProtoMessage()

func (*AllocationInfo) Reset 

func (m *AllocationInfo) Reset()

func (*AllocationInfo) Size 

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

func (*AllocationInfo) String 

func (this *AllocationInfo) String() string

func (*AllocationInfo) Unmarshal 

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

func (*AllocationInfo) XXX_DiscardUnknown 

func (m *AllocationInfo) XXX_DiscardUnknown()

func (*AllocationInfo) XXX_Marshal 

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

func (*AllocationInfo) XXX_Merge 

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

func (*AllocationInfo) XXX_Size 

func (m *AllocationInfo) XXX_Size() int

func (*AllocationInfo) XXX_Unmarshal 

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

type Block 

type Block struct {
	Result               uint64           `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	OverlapTargets       []*OverlapTarget `protobuf:"bytes,2,rep,name=overlap_targets,json=overlapTargets,proto3" json:"overlap_targets,omitempty"`
	BlockId              string           `protobuf:"bytes,3,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Block) Descriptor 

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

func (*Block) GetBlockId 

func (m *Block) GetBlockId() string

func (*Block) GetOverlapTargets 

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

func (*Block) GetResult 

func (m *Block) GetResult() uint64

func (*Block) Marshal 

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

func (*Block) MarshalTo 

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

func (*Block) MarshalToSizedBuffer 

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

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) Reset 

func (m *Block) Reset()

func (*Block) Size 

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

func (*Block) String 

func (this *Block) String() string

func (*Block) Unmarshal 

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

func (*Block) XXX_DiscardUnknown 

func (m *Block) XXX_DiscardUnknown()

func (*Block) XXX_Marshal 

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

func (*Block) XXX_Merge 

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

func (*Block) XXX_Size 

func (m *Block) XXX_Size() int

func (*Block) XXX_Unmarshal 

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

type BlockCPUSet added in v0.2.0 

type BlockCPUSet map[string]machine.CPUSet

func NewBlockCPUSet added in v0.2.0 

func NewBlockCPUSet() BlockCPUSet

type CPUAdvisorClient 

type CPUAdvisorClient interface {
	AddContainer(ctx context.Context, in *advisorsvc.ContainerMetadata, opts ...grpc.CallOption) (*advisorsvc.AddContainerResponse, error)
	RemovePod(ctx context.Context, in *advisorsvc.RemovePodRequest, opts ...grpc.CallOption) (*advisorsvc.RemovePodResponse, error)
	ListAndWatch(ctx context.Context, in *advisorsvc.Empty, opts ...grpc.CallOption) (CPUAdvisor_ListAndWatchClient, error)
	GetAdvice(ctx context.Context, in *GetAdviceRequest, opts ...grpc.CallOption) (*GetAdviceResponse, error)
}

CPUAdvisorClient is the client API for CPUAdvisor service.

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

func NewCPUAdvisorClient 

func NewCPUAdvisorClient(cc *grpc.ClientConn) CPUAdvisorClient

func NewCPUAdvisorClientStub 

func NewCPUAdvisorClientStub() CPUAdvisorClient

type CPUAdvisorServer 

type CPUAdvisorServer interface {
	AddContainer(context.Context, *advisorsvc.ContainerMetadata) (*advisorsvc.AddContainerResponse, error)
	RemovePod(context.Context, *advisorsvc.RemovePodRequest) (*advisorsvc.RemovePodResponse, error)
	ListAndWatch(*advisorsvc.Empty, CPUAdvisor_ListAndWatchServer) error
	GetAdvice(context.Context, *GetAdviceRequest) (*GetAdviceResponse, error)
}

CPUAdvisorServer is the server API for CPUAdvisor service.

type CPUAdvisor_ListAndWatchClient 

type CPUAdvisor_ListAndWatchClient interface {
	Recv() (*ListAndWatchResponse, error)
	grpc.ClientStream
}

type CPUAdvisor_ListAndWatchServer 

type CPUAdvisor_ListAndWatchServer interface {
	Send(*ListAndWatchResponse) error
	grpc.ServerStream
}

type CPUControlKnobName added in v0.5.16 

type CPUControlKnobName string
const (
	ControlKnobKeyCPUNUMAHeadroom CPUControlKnobName = "cpu_numa_headroom"
)

type CPUNUMAHeadroom added in v0.5.16 

type CPUNUMAHeadroom map[int]float64

type CPUPluginClient 

type CPUPluginClient interface {
	GetCheckpoint(ctx context.Context, in *GetCheckpointRequest, opts ...grpc.CallOption) (*GetCheckpointResponse, error)
}

CPUPluginClient is the client API for CPUPlugin service.

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

func NewCPUPluginClient 

func NewCPUPluginClient(cc *grpc.ClientConn) CPUPluginClient

type CPUPluginServer 

type CPUPluginServer interface {
	GetCheckpoint(context.Context, *GetCheckpointRequest) (*GetCheckpointResponse, error)
}

CPUPluginServer is the server API for CPUPlugin service.

type CalculationEntries 

type CalculationEntries struct {
	Entries              map[string]*CalculationInfo `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*CalculationEntries) Descriptor 

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

func (*CalculationEntries) GetEntries 

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

func (*CalculationEntries) GetNUMACalculationResult added in v0.2.0 

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

GetNUMACalculationResult returns numa-level calculation results

func (*CalculationEntries) IsPoolEntry added in v0.5.4 

func (ce *CalculationEntries) IsPoolEntry() bool

func (*CalculationEntries) IsSharedNUMABindingPoolEntry added in v0.5.4 

func (ce *CalculationEntries) IsSharedNUMABindingPoolEntry() bool

func (*CalculationEntries) Marshal 

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

func (*CalculationEntries) MarshalTo 

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

func (*CalculationEntries) MarshalToSizedBuffer 

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

func (*CalculationEntries) ProtoMessage 

func (*CalculationEntries) ProtoMessage()

func (*CalculationEntries) Reset 

func (m *CalculationEntries) Reset()

func (*CalculationEntries) Size 

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

func (*CalculationEntries) String 

func (this *CalculationEntries) String() string

func (*CalculationEntries) Unmarshal 

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

func (*CalculationEntries) XXX_DiscardUnknown 

func (m *CalculationEntries) XXX_DiscardUnknown()

func (*CalculationEntries) XXX_Marshal 

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

func (*CalculationEntries) XXX_Merge 

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

func (*CalculationEntries) XXX_Size 

func (m *CalculationEntries) XXX_Size() int

func (*CalculationEntries) XXX_Unmarshal 

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

type CalculationInfo 

type CalculationInfo struct {
	// valid values:
	// 1. "dedicated" (dedicated_cores container with or without numa_biding)
	// 2. real pool name (shared_cores container entries and pool entries)，, including:
	//    - common pools (eg. share, reclaim, flink, batch, bmq)
	//    - pools generated by qos aware server containing isolated shared_cores containers (eg. isolation0, isolation1, ...)
	OwnerPoolName             string                           `protobuf:"bytes,1,opt,name=owner_pool_name,json=ownerPoolName,proto3" json:"owner_pool_name,omitempty"`
	CalculationResultsByNumas map[int64]*NumaCalculationResult `` /* 229-byte string literal not displayed */
	XXX_NoUnkeyedLiteral      struct{}                         `json:"-"`
	XXX_sizecache             int32                            `json:"-"`
}

func (*CalculationInfo) Descriptor 

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

func (*CalculationInfo) GetCPUSet added in v0.2.0 

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

GetCPUSet returns cpuset for this container by union all blocks for it

func (*CalculationInfo) GetCalculationResultsByNumas 

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

func (*CalculationInfo) GetNUMAQuantities added in v0.2.0 

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

GetNUMAQuantities returns quantity in each numa for in this CalculationInfo

func (*CalculationInfo) GetOwnerPoolName 

func (m *CalculationInfo) GetOwnerPoolName() string

func (*CalculationInfo) GetTotalQuantity added in v0.2.0 

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

GetTotalQuantity returns total quantity for in this CalculationInfo

func (*CalculationInfo) IsSharedNUMABindingPool added in v0.5.4 

func (ci *CalculationInfo) IsSharedNUMABindingPool() bool

func (*CalculationInfo) Marshal 

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

func (*CalculationInfo) MarshalTo 

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

func (*CalculationInfo) MarshalToSizedBuffer 

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

func (*CalculationInfo) ProtoMessage 

func (*CalculationInfo) ProtoMessage()

func (*CalculationInfo) Reset 

func (m *CalculationInfo) Reset()

func (*CalculationInfo) Size 

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

func (*CalculationInfo) String 

func (this *CalculationInfo) String() string

func (*CalculationInfo) Unmarshal 

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

func (*CalculationInfo) XXX_DiscardUnknown 

func (m *CalculationInfo) XXX_DiscardUnknown()

func (*CalculationInfo) XXX_Marshal 

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

func (*CalculationInfo) XXX_Merge 

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

func (*CalculationInfo) XXX_Size 

func (m *CalculationInfo) XXX_Size() int

func (*CalculationInfo) XXX_Unmarshal 

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

type ContainerAllocationInfo added in v0.5.17 

type ContainerAllocationInfo struct {
	Metadata             *advisorsvc.ContainerMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	AllocationInfo       *AllocationInfo               `protobuf:"bytes,2,opt,name=allocation_info,json=allocationInfo,proto3" json:"allocation_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

Combination of container metadata and allocation info

func (*ContainerAllocationInfo) Descriptor added in v0.5.17 

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

func (*ContainerAllocationInfo) GetAllocationInfo added in v0.5.17 

func (m *ContainerAllocationInfo) GetAllocationInfo() *AllocationInfo

func (*ContainerAllocationInfo) GetMetadata added in v0.5.17 

func (m *ContainerAllocationInfo) GetMetadata() *advisorsvc.ContainerMetadata

func (*ContainerAllocationInfo) Marshal added in v0.5.17 

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

func (*ContainerAllocationInfo) MarshalTo added in v0.5.17 

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

func (*ContainerAllocationInfo) MarshalToSizedBuffer added in v0.5.17 

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

func (*ContainerAllocationInfo) ProtoMessage added in v0.5.17 

func (*ContainerAllocationInfo) ProtoMessage()

func (*ContainerAllocationInfo) Reset added in v0.5.17 

func (m *ContainerAllocationInfo) Reset()

func (*ContainerAllocationInfo) Size added in v0.5.17 

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

func (*ContainerAllocationInfo) String added in v0.5.17 

func (this *ContainerAllocationInfo) String() string

func (*ContainerAllocationInfo) Unmarshal added in v0.5.17 

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

func (*ContainerAllocationInfo) XXX_DiscardUnknown added in v0.5.17 

func (m *ContainerAllocationInfo) XXX_DiscardUnknown()

func (*ContainerAllocationInfo) XXX_Marshal added in v0.5.17 

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

func (*ContainerAllocationInfo) XXX_Merge added in v0.5.17 

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

func (*ContainerAllocationInfo) XXX_Size added in v0.5.17 

func (m *ContainerAllocationInfo) XXX_Size() int

func (*ContainerAllocationInfo) XXX_Unmarshal added in v0.5.17 

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

type ContainerAllocationInfoEntries added in v0.5.17 

type ContainerAllocationInfoEntries struct {
	Entries              map[string]*ContainerAllocationInfo `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*ContainerAllocationInfoEntries) Descriptor added in v0.5.17 

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

func (*ContainerAllocationInfoEntries) GetEntries added in v0.5.17 

func (m *ContainerAllocationInfoEntries) GetEntries() map[string]*ContainerAllocationInfo

func (*ContainerAllocationInfoEntries) Marshal added in v0.5.17 

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

func (*ContainerAllocationInfoEntries) MarshalTo added in v0.5.17 

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

func (*ContainerAllocationInfoEntries) MarshalToSizedBuffer added in v0.5.17 

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

func (*ContainerAllocationInfoEntries) ProtoMessage added in v0.5.17 

func (*ContainerAllocationInfoEntries) ProtoMessage()

func (*ContainerAllocationInfoEntries) Reset added in v0.5.17 

func (m *ContainerAllocationInfoEntries) Reset()

func (*ContainerAllocationInfoEntries) Size added in v0.5.17 

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

func (*ContainerAllocationInfoEntries) String added in v0.5.17 

func (this *ContainerAllocationInfoEntries) String() string

func (*ContainerAllocationInfoEntries) Unmarshal added in v0.5.17 

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

func (*ContainerAllocationInfoEntries) XXX_DiscardUnknown added in v0.5.17 

func (m *ContainerAllocationInfoEntries) XXX_DiscardUnknown()

func (*ContainerAllocationInfoEntries) XXX_Marshal added in v0.5.17 

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

func (*ContainerAllocationInfoEntries) XXX_Merge added in v0.5.17 

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

func (*ContainerAllocationInfoEntries) XXX_Size added in v0.5.17 

func (m *ContainerAllocationInfoEntries) XXX_Size() int

func (*ContainerAllocationInfoEntries) XXX_Unmarshal added in v0.5.17 

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

type GetAdviceRequest added in v0.5.17 

type GetAdviceRequest struct {
	Entries              map[string]*ContainerAllocationInfoEntries `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                   `json:"-"`
	XXX_sizecache        int32                                      `json:"-"`
}

func (*GetAdviceRequest) Descriptor added in v0.5.17 

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

func (*GetAdviceRequest) GetEntries added in v0.5.17 

func (m *GetAdviceRequest) GetEntries() map[string]*ContainerAllocationInfoEntries

func (*GetAdviceRequest) Marshal added in v0.5.17 

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

func (*GetAdviceRequest) MarshalTo added in v0.5.17 

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

func (*GetAdviceRequest) MarshalToSizedBuffer added in v0.5.17 

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

func (*GetAdviceRequest) ProtoMessage added in v0.5.17 

func (*GetAdviceRequest) ProtoMessage()

func (*GetAdviceRequest) Reset added in v0.5.17 

func (m *GetAdviceRequest) Reset()

func (*GetAdviceRequest) Size added in v0.5.17 

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

func (*GetAdviceRequest) String added in v0.5.17 

func (this *GetAdviceRequest) String() string

func (*GetAdviceRequest) Unmarshal added in v0.5.17 

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

func (*GetAdviceRequest) XXX_DiscardUnknown added in v0.5.17 

func (m *GetAdviceRequest) XXX_DiscardUnknown()

func (*GetAdviceRequest) XXX_Marshal added in v0.5.17 

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

func (*GetAdviceRequest) XXX_Merge added in v0.5.17 

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

func (*GetAdviceRequest) XXX_Size added in v0.5.17 

func (m *GetAdviceRequest) XXX_Size() int

func (*GetAdviceRequest) XXX_Unmarshal added in v0.5.17 

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

type GetAdviceResponse added in v0.5.17 

type GetAdviceResponse struct {
	Entries                               map[string]*CalculationEntries `` /* 155-byte string literal not displayed */
	AllowSharedCoresOverlapReclaimedCores bool                           `` /* 181-byte string literal not displayed */
	ExtraEntries                          []*advisorsvc.CalculationInfo  `protobuf:"bytes,3,rep,name=extra_entries,json=extraEntries,proto3" json:"extra_entries,omitempty"`
	XXX_NoUnkeyedLiteral                  struct{}                       `json:"-"`
	XXX_sizecache                         int32                          `json:"-"`
}

func (*GetAdviceResponse) Descriptor added in v0.5.17 

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

func (*GetAdviceResponse) GetAllowSharedCoresOverlapReclaimedCores added in v0.5.17 

func (m *GetAdviceResponse) GetAllowSharedCoresOverlapReclaimedCores() bool

func (*GetAdviceResponse) GetEntries added in v0.5.17 

func (m *GetAdviceResponse) GetEntries() map[string]*CalculationEntries

func (*GetAdviceResponse) GetExtraEntries added in v0.5.17 

func (m *GetAdviceResponse) GetExtraEntries() []*advisorsvc.CalculationInfo

func (*GetAdviceResponse) Marshal added in v0.5.17 

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

func (*GetAdviceResponse) MarshalTo added in v0.5.17 

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

func (*GetAdviceResponse) MarshalToSizedBuffer added in v0.5.17 

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

func (*GetAdviceResponse) ProtoMessage added in v0.5.17 

func (*GetAdviceResponse) ProtoMessage()

func (*GetAdviceResponse) Reset added in v0.5.17 

func (m *GetAdviceResponse) Reset()

func (*GetAdviceResponse) Size added in v0.5.17 

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

func (*GetAdviceResponse) String added in v0.5.17 

func (this *GetAdviceResponse) String() string

func (*GetAdviceResponse) Unmarshal added in v0.5.17 

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

func (*GetAdviceResponse) XXX_DiscardUnknown added in v0.5.17 

func (m *GetAdviceResponse) XXX_DiscardUnknown()

func (*GetAdviceResponse) XXX_Marshal added in v0.5.17 

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

func (*GetAdviceResponse) XXX_Merge added in v0.5.17 

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

func (*GetAdviceResponse) XXX_Size added in v0.5.17 

func (m *GetAdviceResponse) XXX_Size() int

func (*GetAdviceResponse) XXX_Unmarshal added in v0.5.17 

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

type GetCheckpointRequest 

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

func (*GetCheckpointRequest) Descriptor 

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

func (*GetCheckpointRequest) Marshal 

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

func (*GetCheckpointRequest) MarshalTo 

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

func (*GetCheckpointRequest) MarshalToSizedBuffer 

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

func (*GetCheckpointRequest) ProtoMessage 

func (*GetCheckpointRequest) ProtoMessage()

func (*GetCheckpointRequest) Reset 

func (m *GetCheckpointRequest) Reset()

func (*GetCheckpointRequest) Size 

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

func (*GetCheckpointRequest) String 

func (this *GetCheckpointRequest) String() string

func (*GetCheckpointRequest) Unmarshal 

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

func (*GetCheckpointRequest) XXX_DiscardUnknown 

func (m *GetCheckpointRequest) XXX_DiscardUnknown()

func (*GetCheckpointRequest) XXX_Marshal 

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

func (*GetCheckpointRequest) XXX_Merge 

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

func (*GetCheckpointRequest) XXX_Size 

func (m *GetCheckpointRequest) XXX_Size() int

func (*GetCheckpointRequest) XXX_Unmarshal 

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

type GetCheckpointResponse 

type GetCheckpointResponse struct {
	Entries              map[string]*AllocationEntries `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*GetCheckpointResponse) Descriptor 

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

func (*GetCheckpointResponse) GetEntries 

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

func (*GetCheckpointResponse) Marshal 

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

func (*GetCheckpointResponse) MarshalTo 

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

func (*GetCheckpointResponse) MarshalToSizedBuffer 

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

func (*GetCheckpointResponse) ProtoMessage 

func (*GetCheckpointResponse) ProtoMessage()

func (*GetCheckpointResponse) Reset 

func (m *GetCheckpointResponse) Reset()

func (*GetCheckpointResponse) Size 

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

func (*GetCheckpointResponse) String 

func (this *GetCheckpointResponse) String() string

func (*GetCheckpointResponse) Unmarshal 

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

func (*GetCheckpointResponse) XXX_DiscardUnknown 

func (m *GetCheckpointResponse) XXX_DiscardUnknown()

func (*GetCheckpointResponse) XXX_Marshal 

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

func (*GetCheckpointResponse) XXX_Merge 

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

func (*GetCheckpointResponse) XXX_Size 

func (m *GetCheckpointResponse) XXX_Size() int

func (*GetCheckpointResponse) XXX_Unmarshal 

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

type ListAndWatchResponse 

type ListAndWatchResponse struct {
	Entries                               map[string]*CalculationEntries `` /* 155-byte string literal not displayed */
	AllowSharedCoresOverlapReclaimedCores bool                           `` /* 181-byte string literal not displayed */
	ExtraEntries                          []*advisorsvc.CalculationInfo  `protobuf:"bytes,3,rep,name=extra_entries,json=extraEntries,proto3" json:"extra_entries,omitempty"`
	XXX_NoUnkeyedLiteral                  struct{}                       `json:"-"`
	XXX_sizecache                         int32                          `json:"-"`
}

func (*ListAndWatchResponse) Descriptor 

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

func (*ListAndWatchResponse) FilterCalculationInfo added in v0.2.0 

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

FilterCalculationInfo filter out CalculationInfo only for dedicated pod, and the returned map and formatted as pod -> container -> CalculationInfo

func (*ListAndWatchResponse) GeEntryNUMABlocks added in v0.2.0 

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

GeEntryNUMABlocks returns Block lists according to the given [entry, subEntry] pair

func (*ListAndWatchResponse) GetAllowSharedCoresOverlapReclaimedCores added in v0.5.1 

func (m *ListAndWatchResponse) GetAllowSharedCoresOverlapReclaimedCores() bool

func (*ListAndWatchResponse) GetBlocks added in v0.2.0 

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

GetBlocks parses ListAndWatchResponse and returns map[int][]*Block, the map is keyed as numa id -> blocks slice (which has been sorted and deduped)

func (*ListAndWatchResponse) GetCalculationInfo added in v0.2.0 

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

GetCalculationInfo returns CalculationInfo according to the given [entry, subEntry]

func (*ListAndWatchResponse) GetEntries 

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

func (*ListAndWatchResponse) GetExtraEntries added in v0.5.16 

func (m *ListAndWatchResponse) GetExtraEntries() []*advisorsvc.CalculationInfo

func (*ListAndWatchResponse) GetSharedBindingNUMAs added in v0.5.4 

func (lwr *ListAndWatchResponse) GetSharedBindingNUMAs() (sets.Int, error)

func (*ListAndWatchResponse) Marshal 

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

func (*ListAndWatchResponse) MarshalTo 

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

func (*ListAndWatchResponse) MarshalToSizedBuffer 

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

func (*ListAndWatchResponse) ProtoMessage 

func (*ListAndWatchResponse) ProtoMessage()

func (*ListAndWatchResponse) Reset 

func (m *ListAndWatchResponse) Reset()

func (*ListAndWatchResponse) Size 

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

func (*ListAndWatchResponse) String 

func (this *ListAndWatchResponse) String() string

func (*ListAndWatchResponse) Unmarshal 

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

func (*ListAndWatchResponse) XXX_DiscardUnknown 

func (m *ListAndWatchResponse) XXX_DiscardUnknown()

func (*ListAndWatchResponse) XXX_Marshal 

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

func (*ListAndWatchResponse) XXX_Merge 

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

func (*ListAndWatchResponse) XXX_Size 

func (m *ListAndWatchResponse) XXX_Size() int

func (*ListAndWatchResponse) XXX_Unmarshal 

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

type NumaCalculationResult 

type NumaCalculationResult struct {
	// every block doesn't overlap with other blocks in same NumaCalculationResult
	Blocks               []*Block `protobuf:"bytes,2,rep,name=blocks,proto3" json:"blocks,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NumaCalculationResult) Descriptor 

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

func (*NumaCalculationResult) GetBlocks 

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

func (*NumaCalculationResult) Marshal 

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

func (*NumaCalculationResult) MarshalTo 

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

func (*NumaCalculationResult) MarshalToSizedBuffer 

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

func (*NumaCalculationResult) ProtoMessage 

func (*NumaCalculationResult) ProtoMessage()

func (*NumaCalculationResult) Reset 

func (m *NumaCalculationResult) Reset()

func (*NumaCalculationResult) Size 

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

func (*NumaCalculationResult) String 

func (this *NumaCalculationResult) String() string

func (*NumaCalculationResult) Unmarshal 

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

func (*NumaCalculationResult) XXX_DiscardUnknown 

func (m *NumaCalculationResult) XXX_DiscardUnknown()

func (*NumaCalculationResult) XXX_Marshal 

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

func (*NumaCalculationResult) XXX_Merge 

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

func (*NumaCalculationResult) XXX_Size 

func (m *NumaCalculationResult) XXX_Size() int

func (*NumaCalculationResult) XXX_Unmarshal 

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

type OverlapTarget 

type OverlapTarget struct {
	OverlapTargetPoolName      string      `` /* 128-byte string literal not displayed */
	OverlapTargetPodUid        string      `protobuf:"bytes,2,opt,name=overlap_target_pod_uid,json=overlapTargetPodUid,proto3" json:"overlap_target_pod_uid,omitempty"`
	OverlapTargetContainerName string      `` /* 143-byte string literal not displayed */
	OverlapType                OverlapType `protobuf:"varint,4,opt,name=overlap_type,json=overlapType,proto3,enum=cpuadvisor.OverlapType" json:"overlap_type,omitempty"`
	XXX_NoUnkeyedLiteral       struct{}    `json:"-"`
	XXX_sizecache              int32       `json:"-"`
}

func (*OverlapTarget) Descriptor 

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

func (*OverlapTarget) GetOverlapTargetContainerName 

func (m *OverlapTarget) GetOverlapTargetContainerName() string

func (*OverlapTarget) GetOverlapTargetPodUid 

func (m *OverlapTarget) GetOverlapTargetPodUid() string

func (*OverlapTarget) GetOverlapTargetPoolName 

func (m *OverlapTarget) GetOverlapTargetPoolName() string

func (*OverlapTarget) GetOverlapType 

func (m *OverlapTarget) GetOverlapType() OverlapType

func (*OverlapTarget) Marshal 

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

func (*OverlapTarget) MarshalTo 

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

func (*OverlapTarget) MarshalToSizedBuffer 

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

func (*OverlapTarget) ProtoMessage 

func (*OverlapTarget) ProtoMessage()

func (*OverlapTarget) Reset 

func (m *OverlapTarget) Reset()

func (*OverlapTarget) Size 

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

func (*OverlapTarget) String 

func (this *OverlapTarget) String() string

func (*OverlapTarget) Unmarshal 

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

func (*OverlapTarget) XXX_DiscardUnknown 

func (m *OverlapTarget) XXX_DiscardUnknown()

func (*OverlapTarget) XXX_Marshal 

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

func (*OverlapTarget) XXX_Merge 

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

func (*OverlapTarget) XXX_Size 

func (m *OverlapTarget) XXX_Size() int

func (*OverlapTarget) XXX_Unmarshal 

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

type OverlapType 

type OverlapType int32
const (
	OverlapType_OverlapWithPod  OverlapType = 0
	OverlapType_OverlapWithPool OverlapType = 1
)

func (OverlapType) EnumDescriptor 

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

func (OverlapType) String 

func (x OverlapType) String() string

type UnimplementedCPUAdvisorServer 

type UnimplementedCPUAdvisorServer struct {
}

UnimplementedCPUAdvisorServer can be embedded to have forward compatible implementations.

func (*UnimplementedCPUAdvisorServer) AddContainer 

func (*UnimplementedCPUAdvisorServer) AddContainer(ctx context.Context, req *advisorsvc.ContainerMetadata) (*advisorsvc.AddContainerResponse, error)

func (*UnimplementedCPUAdvisorServer) GetAdvice added in v0.5.17 

func (*UnimplementedCPUAdvisorServer) GetAdvice(ctx context.Context, req *GetAdviceRequest) (*GetAdviceResponse, error)

func (*UnimplementedCPUAdvisorServer) ListAndWatch 

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

func (*UnimplementedCPUAdvisorServer) RemovePod 

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

type UnimplementedCPUPluginServer 

type UnimplementedCPUPluginServer struct {
}

UnimplementedCPUPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedCPUPluginServer) GetCheckpoint 

func (*UnimplementedCPUPluginServer) GetCheckpoint(ctx context.Context, req *GetCheckpointRequest) (*GetCheckpointResponse, 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.