cpuadvisor

package
v0.5.1 Latest Latest
Warning

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

Go to latest
Published: May 10, 2024 License: Apache-2.0 Imports: 17 Imported by: 7

Documentation

Index

Constants

View Source
const (
	EmptyOwnerPoolName = ""
	FakedContainerName = ""
	FakedNUMAID        = -1
	NameSeparator      = "#"
)

FakedContainerName represents a placeholder since pool entry has no container-level FakedNUMAID represents a placeholder since pools like shared/reclaimed will not contain a specific numa

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

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

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 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) 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) 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 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 */
	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) 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) ListAndWatch

func (*UnimplementedCPUAdvisorServer) RemovePod

type UnimplementedCPUPluginServer

type UnimplementedCPUPluginServer struct {
}

UnimplementedCPUPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedCPUPluginServer) GetCheckpoint

Jump to

Keyboard shortcuts

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