advisorsvc

package
v0.3.1 Latest Latest
Warning

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

Go to latest
Published: Aug 10, 2023 License: Apache-2.0 Imports: 14 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthAdvisorSvc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAdvisorSvc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAdvisorSvc = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterAdvisorServiceServer

func RegisterAdvisorServiceServer(s *grpc.Server, srv AdvisorServiceServer)

Types

type AddContainerRequest

type AddContainerRequest struct {
	PodUid               string                 `protobuf:"bytes,1,opt,name=pod_uid,json=podUid,proto3" json:"pod_uid,omitempty"`
	PodNamespace         string                 `protobuf:"bytes,2,opt,name=pod_namespace,json=podNamespace,proto3" json:"pod_namespace,omitempty"`
	PodName              string                 `protobuf:"bytes,3,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	ContainerName        string                 `protobuf:"bytes,4,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	ContainerType        v1alpha1.ContainerType `` /* 144-byte string literal not displayed */
	ContainerIndex       uint64                 `protobuf:"varint,6,opt,name=container_index,json=containerIndex,proto3" json:"container_index,omitempty"`
	Labels               map[string]string      `` /* 153-byte string literal not displayed */
	Annotations          map[string]string      `` /* 163-byte string literal not displayed */
	QosLevel             string                 `protobuf:"bytes,9,opt,name=qos_level,json=qosLevel,proto3" json:"qos_level,omitempty"`
	RequestQuantity      uint64                 `protobuf:"varint,10,opt,name=requestQuantity,proto3" json:"requestQuantity,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

containing metadata of the container which won't be changed during container's lifecycle

func (*AddContainerRequest) Descriptor

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

func (*AddContainerRequest) GetAnnotations

func (m *AddContainerRequest) GetAnnotations() map[string]string

func (*AddContainerRequest) GetContainerIndex

func (m *AddContainerRequest) GetContainerIndex() uint64

func (*AddContainerRequest) GetContainerName

func (m *AddContainerRequest) GetContainerName() string

func (*AddContainerRequest) GetContainerType

func (m *AddContainerRequest) GetContainerType() v1alpha1.ContainerType

func (*AddContainerRequest) GetLabels

func (m *AddContainerRequest) GetLabels() map[string]string

func (*AddContainerRequest) GetPodName

func (m *AddContainerRequest) GetPodName() string

func (*AddContainerRequest) GetPodNamespace

func (m *AddContainerRequest) GetPodNamespace() string

func (*AddContainerRequest) GetPodUid

func (m *AddContainerRequest) GetPodUid() string

func (*AddContainerRequest) GetQosLevel

func (m *AddContainerRequest) GetQosLevel() string

func (*AddContainerRequest) GetRequestQuantity

func (m *AddContainerRequest) GetRequestQuantity() uint64

func (*AddContainerRequest) Marshal

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

func (*AddContainerRequest) MarshalTo

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

func (*AddContainerRequest) MarshalToSizedBuffer

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

func (*AddContainerRequest) ProtoMessage

func (*AddContainerRequest) ProtoMessage()

func (*AddContainerRequest) Reset

func (m *AddContainerRequest) Reset()

func (*AddContainerRequest) Size

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

func (*AddContainerRequest) String

func (this *AddContainerRequest) String() string

func (*AddContainerRequest) Unmarshal

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

func (*AddContainerRequest) XXX_DiscardUnknown

func (m *AddContainerRequest) XXX_DiscardUnknown()

func (*AddContainerRequest) XXX_Marshal

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

func (*AddContainerRequest) XXX_Merge

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

func (*AddContainerRequest) XXX_Size

func (m *AddContainerRequest) XXX_Size() int

func (*AddContainerRequest) XXX_Unmarshal

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

type AddContainerResponse

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

func (*AddContainerResponse) Descriptor

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

func (*AddContainerResponse) Marshal

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

func (*AddContainerResponse) MarshalTo

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

func (*AddContainerResponse) MarshalToSizedBuffer

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

func (*AddContainerResponse) ProtoMessage

func (*AddContainerResponse) ProtoMessage()

func (*AddContainerResponse) Reset

func (m *AddContainerResponse) Reset()

func (*AddContainerResponse) Size

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

func (*AddContainerResponse) String

func (this *AddContainerResponse) String() string

func (*AddContainerResponse) Unmarshal

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

func (*AddContainerResponse) XXX_DiscardUnknown

func (m *AddContainerResponse) XXX_DiscardUnknown()

func (*AddContainerResponse) XXX_Marshal

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

func (*AddContainerResponse) XXX_Merge

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

func (*AddContainerResponse) XXX_Size

func (m *AddContainerResponse) XXX_Size() int

func (*AddContainerResponse) XXX_Unmarshal

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

type AdvisorServiceClient

type AdvisorServiceClient interface {
	AddContainer(ctx context.Context, in *AddContainerRequest, opts ...grpc.CallOption) (*AddContainerResponse, error)
	RemovePod(ctx context.Context, in *RemovePodRequest, opts ...grpc.CallOption) (*RemovePodResponse, error)
	ListAndWatch(ctx context.Context, in *Empty, opts ...grpc.CallOption) (AdvisorService_ListAndWatchClient, error)
}

AdvisorServiceClient is the client API for AdvisorService service.

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

func NewAdvisorServiceClient

func NewAdvisorServiceClient(cc *grpc.ClientConn) AdvisorServiceClient

func NewStubAdvisorServiceClient added in v0.3.1

func NewStubAdvisorServiceClient() AdvisorServiceClient

type AdvisorServiceServer

type AdvisorServiceServer interface {
	AddContainer(context.Context, *AddContainerRequest) (*AddContainerResponse, error)
	RemovePod(context.Context, *RemovePodRequest) (*RemovePodResponse, error)
	ListAndWatch(*Empty, AdvisorService_ListAndWatchServer) error
}

AdvisorServiceServer is the server API for AdvisorService service.

type AdvisorService_ListAndWatchClient

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

type AdvisorService_ListAndWatchServer

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

type CalculationEntries

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

func (*CalculationEntries) Descriptor

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

func (*CalculationEntries) GetContainerEntries

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

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 {
	// eg. "/kubepods/besteffort";
	// empty for container; non-empty for high level cgroup path; since subsystem may be different for different control knob, so we use relative path here.
	CgroupPath           string             `protobuf:"bytes,1,opt,name=cgroup_path,json=cgroupPath,proto3" json:"cgroup_path,omitempty"`
	CalculationResult    *CalculationResult `protobuf:"bytes,2,opt,name=calculation_result,json=calculationResult,proto3" json:"calculation_result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*CalculationInfo) Descriptor

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

func (*CalculationInfo) GetCalculationResult

func (m *CalculationInfo) GetCalculationResult() *CalculationResult

func (*CalculationInfo) GetCgroupPath

func (m *CalculationInfo) GetCgroupPath() string

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 CalculationResult

type CalculationResult struct {
	Values               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CalculationResult) Descriptor

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

func (*CalculationResult) GetValues

func (m *CalculationResult) GetValues() map[string]string

func (*CalculationResult) Marshal

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

func (*CalculationResult) MarshalTo

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

func (*CalculationResult) MarshalToSizedBuffer

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

func (*CalculationResult) ProtoMessage

func (*CalculationResult) ProtoMessage()

func (*CalculationResult) Reset

func (m *CalculationResult) Reset()

func (*CalculationResult) Size

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

func (*CalculationResult) String

func (this *CalculationResult) String() string

func (*CalculationResult) Unmarshal

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

func (*CalculationResult) XXX_DiscardUnknown

func (m *CalculationResult) XXX_DiscardUnknown()

func (*CalculationResult) XXX_Marshal

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

func (*CalculationResult) XXX_Merge

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

func (*CalculationResult) XXX_Size

func (m *CalculationResult) XXX_Size() int

func (*CalculationResult) XXX_Unmarshal

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

type Empty

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

func (*Empty) Descriptor

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

func (*Empty) Marshal

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

func (*Empty) MarshalTo

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

func (*Empty) MarshalToSizedBuffer

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

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) Reset

func (m *Empty) Reset()

func (*Empty) Size

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

func (*Empty) String

func (this *Empty) String() string

func (*Empty) Unmarshal

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

func (*Empty) XXX_DiscardUnknown

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal

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

func (*Empty) XXX_Merge

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

func (*Empty) XXX_Size

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal

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

type ListAndWatchResponse

type ListAndWatchResponse struct {
	PodEntries           map[string]*CalculationEntries `` /* 179-byte string literal not displayed */
	ExtraEntries         []*CalculationInfo             `protobuf:"bytes,2,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) GetExtraEntries

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

func (*ListAndWatchResponse) GetPodEntries

func (m *ListAndWatchResponse) GetPodEntries() 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 RemovePodRequest

type RemovePodRequest struct {
	PodUid               string   `protobuf:"bytes,1,opt,name=pod_uid,json=podUid,proto3" json:"pod_uid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemovePodRequest) Descriptor

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

func (*RemovePodRequest) GetPodUid

func (m *RemovePodRequest) GetPodUid() string

func (*RemovePodRequest) Marshal

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

func (*RemovePodRequest) MarshalTo

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

func (*RemovePodRequest) MarshalToSizedBuffer

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

func (*RemovePodRequest) ProtoMessage

func (*RemovePodRequest) ProtoMessage()

func (*RemovePodRequest) Reset

func (m *RemovePodRequest) Reset()

func (*RemovePodRequest) Size

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

func (*RemovePodRequest) String

func (this *RemovePodRequest) String() string

func (*RemovePodRequest) Unmarshal

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

func (*RemovePodRequest) XXX_DiscardUnknown

func (m *RemovePodRequest) XXX_DiscardUnknown()

func (*RemovePodRequest) XXX_Marshal

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

func (*RemovePodRequest) XXX_Merge

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

func (*RemovePodRequest) XXX_Size

func (m *RemovePodRequest) XXX_Size() int

func (*RemovePodRequest) XXX_Unmarshal

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

type RemovePodResponse

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

func (*RemovePodResponse) Descriptor

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

func (*RemovePodResponse) Marshal

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

func (*RemovePodResponse) MarshalTo

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

func (*RemovePodResponse) MarshalToSizedBuffer

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

func (*RemovePodResponse) ProtoMessage

func (*RemovePodResponse) ProtoMessage()

func (*RemovePodResponse) Reset

func (m *RemovePodResponse) Reset()

func (*RemovePodResponse) Size

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

func (*RemovePodResponse) String

func (this *RemovePodResponse) String() string

func (*RemovePodResponse) Unmarshal

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

func (*RemovePodResponse) XXX_DiscardUnknown

func (m *RemovePodResponse) XXX_DiscardUnknown()

func (*RemovePodResponse) XXX_Marshal

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

func (*RemovePodResponse) XXX_Merge

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

func (*RemovePodResponse) XXX_Size

func (m *RemovePodResponse) XXX_Size() int

func (*RemovePodResponse) XXX_Unmarshal

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

type UnimplementedAdvisorServiceServer

type UnimplementedAdvisorServiceServer struct {
}

UnimplementedAdvisorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdvisorServiceServer) AddContainer

func (*UnimplementedAdvisorServiceServer) ListAndWatch

func (*UnimplementedAdvisorServiceServer) RemovePod

Jump to

Keyboard shortcuts

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