advisorsvc

package
v0.4.2 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2024 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)

func RegisterQRMServiceServer added in v0.4.0 

func RegisterQRMServiceServer(s *grpc.Server, srv QRMServiceServer)

Types

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 *ContainerMetadata, 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, *ContainerMetadata) (*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 ContainerMetadata added in v0.4.0 

type ContainerMetadata 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 (*ContainerMetadata) Descriptor added in v0.4.0 

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

func (*ContainerMetadata) GetAnnotations added in v0.4.0 

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

func (*ContainerMetadata) GetContainerIndex added in v0.4.0 

func (m *ContainerMetadata) GetContainerIndex() uint64

func (*ContainerMetadata) GetContainerName added in v0.4.0 

func (m *ContainerMetadata) GetContainerName() string

func (*ContainerMetadata) GetContainerType added in v0.4.0 

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

func (*ContainerMetadata) GetLabels added in v0.4.0 

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

func (*ContainerMetadata) GetPodName added in v0.4.0 

func (m *ContainerMetadata) GetPodName() string

func (*ContainerMetadata) GetPodNamespace added in v0.4.0 

func (m *ContainerMetadata) GetPodNamespace() string

func (*ContainerMetadata) GetPodUid added in v0.4.0 

func (m *ContainerMetadata) GetPodUid() string

func (*ContainerMetadata) GetQosLevel added in v0.4.0 

func (m *ContainerMetadata) GetQosLevel() string

func (*ContainerMetadata) GetRequestQuantity added in v0.4.0 

func (m *ContainerMetadata) GetRequestQuantity() uint64

func (*ContainerMetadata) Marshal added in v0.4.0 

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

func (*ContainerMetadata) MarshalTo added in v0.4.0 

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

func (*ContainerMetadata) MarshalToSizedBuffer added in v0.4.0 

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

func (*ContainerMetadata) ProtoMessage added in v0.4.0 

func (*ContainerMetadata) ProtoMessage()

func (*ContainerMetadata) Reset added in v0.4.0 

func (m *ContainerMetadata) Reset()

func (*ContainerMetadata) Size added in v0.4.0 

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

func (*ContainerMetadata) String added in v0.4.0 

func (this *ContainerMetadata) String() string

func (*ContainerMetadata) Unmarshal added in v0.4.0 

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

func (*ContainerMetadata) XXX_DiscardUnknown added in v0.4.0 

func (m *ContainerMetadata) XXX_DiscardUnknown()

func (*ContainerMetadata) XXX_Marshal added in v0.4.0 

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

func (*ContainerMetadata) XXX_Merge added in v0.4.0 

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

func (*ContainerMetadata) XXX_Size added in v0.4.0 

func (m *ContainerMetadata) XXX_Size() int

func (*ContainerMetadata) XXX_Unmarshal added in v0.4.0 

func (m *ContainerMetadata) 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 ListContainersResponse added in v0.4.0 

type ListContainersResponse struct {
	Containers           []*ContainerMetadata `protobuf:"bytes,1,rep,name=containers,proto3" json:"containers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ListContainersResponse) Descriptor added in v0.4.0 

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

func (*ListContainersResponse) GetContainers added in v0.4.0 

func (m *ListContainersResponse) GetContainers() []*ContainerMetadata

func (*ListContainersResponse) Marshal added in v0.4.0 

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

func (*ListContainersResponse) MarshalTo added in v0.4.0 

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

func (*ListContainersResponse) MarshalToSizedBuffer added in v0.4.0 

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

func (*ListContainersResponse) ProtoMessage added in v0.4.0 

func (*ListContainersResponse) ProtoMessage()

func (*ListContainersResponse) Reset added in v0.4.0 

func (m *ListContainersResponse) Reset()

func (*ListContainersResponse) Size added in v0.4.0 

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

func (*ListContainersResponse) String added in v0.4.0 

func (this *ListContainersResponse) String() string

func (*ListContainersResponse) Unmarshal added in v0.4.0 

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

func (*ListContainersResponse) XXX_DiscardUnknown added in v0.4.0 

func (m *ListContainersResponse) XXX_DiscardUnknown()

func (*ListContainersResponse) XXX_Marshal added in v0.4.0 

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

func (*ListContainersResponse) XXX_Merge added in v0.4.0 

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

func (*ListContainersResponse) XXX_Size added in v0.4.0 

func (m *ListContainersResponse) XXX_Size() int

func (*ListContainersResponse) XXX_Unmarshal added in v0.4.0 

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

type QRMServiceClient added in v0.4.0 

type QRMServiceClient interface {
	ListContainers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListContainersResponse, error)
}

QRMServiceClient is the client API for QRMService service.

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

func NewQRMServiceClient added in v0.4.0 

func NewQRMServiceClient(cc *grpc.ClientConn) QRMServiceClient

type QRMServiceServer added in v0.4.0 

type QRMServiceServer interface {
	ListContainers(context.Context, *Empty) (*ListContainersResponse, error)
}

QRMServiceServer is the server API for QRMService service.

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) AddContainer(ctx context.Context, req *ContainerMetadata) (*AddContainerResponse, error)

func (*UnimplementedAdvisorServiceServer) ListAndWatch 

func (*UnimplementedAdvisorServiceServer) ListAndWatch(req *Empty, srv AdvisorService_ListAndWatchServer) error

func (*UnimplementedAdvisorServiceServer) RemovePod 

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

type UnimplementedQRMServiceServer added in v0.4.0 

type UnimplementedQRMServiceServer struct {
}

UnimplementedQRMServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQRMServiceServer) ListContainers added in v0.4.0 

func (*UnimplementedQRMServiceServer) ListContainers(ctx context.Context, req *Empty) (*ListContainersResponse, 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.