package orca_v1
import "google.golang.org/grpc/internal/balancerload/orca/orca_v1"
Index ¶
- func RegisterOpenRCAServiceServer(s *grpc.Server, srv OpenRCAServiceServer)
- type LoadReport
- func (*LoadReport) Descriptor() ([]byte, []int)
- func (m *LoadReport) GetCpuUtilization() float64
- func (m *LoadReport) GetMemUtilization() float64
- func (m *LoadReport) GetNicInUtilization() float64
- func (m *LoadReport) GetNicOutUtilization() float64
- func (m *LoadReport) GetRequestCostOrUtilization() map[string]float64
- func (*LoadReport) ProtoMessage()
- func (m *LoadReport) Reset()
- func (m *LoadReport) String() string
- func (m *LoadReport) XXX_DiscardUnknown()
- func (m *LoadReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *LoadReport) XXX_Merge(src proto.Message)
- func (m *LoadReport) XXX_Size() int
- func (m *LoadReport) XXX_Unmarshal(b []byte) error
- type LoadReportRequest
- func (*LoadReportRequest) Descriptor() ([]byte, []int)
- func (m *LoadReportRequest) GetReportInterval() *duration.Duration
- func (m *LoadReportRequest) GetRequestCostNames() []string
- func (*LoadReportRequest) ProtoMessage()
- func (m *LoadReportRequest) Reset()
- func (m *LoadReportRequest) String() string
- func (m *LoadReportRequest) XXX_DiscardUnknown()
- func (m *LoadReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *LoadReportRequest) XXX_Merge(src proto.Message)
- func (m *LoadReportRequest) XXX_Size() int
- func (m *LoadReportRequest) XXX_Unmarshal(b []byte) error
- type OpenRCAServiceClient
- type OpenRCAServiceServer
- type OpenRCAService_StreamCoreMetricsClient
- type OpenRCAService_StreamCoreMetricsServer
Functions ¶
func RegisterOpenRCAServiceServer ¶
func RegisterOpenRCAServiceServer(s *grpc.Server, srv OpenRCAServiceServer)
Types ¶
type LoadReport ¶
type LoadReport struct { // CPU utilization expressed as a fraction of available CPU resources. This // should be derived from a sample or measurement taken during the request. CpuUtilization float64 `protobuf:"fixed64,1,opt,name=cpu_utilization,json=cpuUtilization,proto3" json:"cpu_utilization,omitempty"` // Memory utilization expressed as a fraction of available memory // resources. This should be derived from a sample or measurement taken // during the request. MemUtilization float64 `protobuf:"fixed64,2,opt,name=mem_utilization,json=memUtilization,proto3" json:"mem_utilization,omitempty"` // NIC inbound/outbound utilization expressed as a fraction of available NIC // bandwidth. The request in/out bytes can be inferred by Envoy, but not the // NIC availability at the endpoint, hence reporting NicInUtilization float64 `protobuf:"fixed64,3,opt,name=nic_in_utilization,json=nicInUtilization,proto3" json:"nic_in_utilization,omitempty"` NicOutUtilization float64 `protobuf:"fixed64,4,opt,name=nic_out_utilization,json=nicOutUtilization,proto3" json:"nic_out_utilization,omitempty"` // Application specific requests costs. Values may be absolute costs (e.g. // 3487 bytes of storage) associated with the cost or utilization, // expressed as a fraction of total resources available. Utilization // metrics should be derived from a sample or measurement taken // during the request. RequestCostOrUtilization map[string]float64 `protobuf:"bytes,5,rep,name=request_cost_or_utilization,json=requestCostOrUtilization,proto3" json:"request_cost_or_utilization,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"fixed64,2,opt,name=value,proto3"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LoadReport) Descriptor ¶
func (*LoadReport) Descriptor() ([]byte, []int)
func (*LoadReport) GetCpuUtilization ¶
func (m *LoadReport) GetCpuUtilization() float64
func (*LoadReport) GetMemUtilization ¶
func (m *LoadReport) GetMemUtilization() float64
func (*LoadReport) GetNicInUtilization ¶
func (m *LoadReport) GetNicInUtilization() float64
func (*LoadReport) GetNicOutUtilization ¶
func (m *LoadReport) GetNicOutUtilization() float64
func (*LoadReport) GetRequestCostOrUtilization ¶
func (m *LoadReport) GetRequestCostOrUtilization() map[string]float64
func (*LoadReport) ProtoMessage ¶
func (*LoadReport) ProtoMessage()
func (*LoadReport) Reset ¶
func (m *LoadReport) Reset()
func (*LoadReport) String ¶
func (m *LoadReport) String() string
func (*LoadReport) XXX_DiscardUnknown ¶
func (m *LoadReport) XXX_DiscardUnknown()
func (*LoadReport) XXX_Marshal ¶
func (m *LoadReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadReport) XXX_Merge ¶
func (dst *LoadReport) XXX_Merge(src proto.Message)
func (*LoadReport) XXX_Size ¶
func (m *LoadReport) XXX_Size() int
func (*LoadReport) XXX_Unmarshal ¶
func (m *LoadReport) XXX_Unmarshal(b []byte) error
type LoadReportRequest ¶
type LoadReportRequest struct { // Interval for generating Open RCA core metric responses. ReportInterval *duration.Duration `protobuf:"bytes,1,opt,name=report_interval,json=reportInterval,proto3" json:"report_interval,omitempty"` // Request costs to collect. If this is empty, all known requests costs tracked by // the load reporting agent will be returned. This provides an opportunity for // the client to selectively obtain a subset of tracked costs. RequestCostNames []string `protobuf:"bytes,2,rep,name=request_cost_names,json=requestCostNames,proto3" json:"request_cost_names,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LoadReportRequest) Descriptor ¶
func (*LoadReportRequest) Descriptor() ([]byte, []int)
func (*LoadReportRequest) GetReportInterval ¶
func (m *LoadReportRequest) GetReportInterval() *duration.Duration
func (*LoadReportRequest) GetRequestCostNames ¶
func (m *LoadReportRequest) GetRequestCostNames() []string
func (*LoadReportRequest) ProtoMessage ¶
func (*LoadReportRequest) ProtoMessage()
func (*LoadReportRequest) Reset ¶
func (m *LoadReportRequest) Reset()
func (*LoadReportRequest) String ¶
func (m *LoadReportRequest) String() string
func (*LoadReportRequest) XXX_DiscardUnknown ¶
func (m *LoadReportRequest) XXX_DiscardUnknown()
func (*LoadReportRequest) XXX_Marshal ¶
func (m *LoadReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadReportRequest) XXX_Merge ¶
func (dst *LoadReportRequest) XXX_Merge(src proto.Message)
func (*LoadReportRequest) XXX_Size ¶
func (m *LoadReportRequest) XXX_Size() int
func (*LoadReportRequest) XXX_Unmarshal ¶
func (m *LoadReportRequest) XXX_Unmarshal(b []byte) error
type OpenRCAServiceClient ¶
type OpenRCAServiceClient interface { StreamCoreMetrics(ctx context.Context, in *LoadReportRequest, opts ...grpc.CallOption) (OpenRCAService_StreamCoreMetricsClient, error) }
OpenRCAServiceClient is the client API for OpenRCAService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewOpenRCAServiceClient ¶
func NewOpenRCAServiceClient(cc *grpc.ClientConn) OpenRCAServiceClient
type OpenRCAServiceServer ¶
type OpenRCAServiceServer interface { StreamCoreMetrics(*LoadReportRequest, OpenRCAService_StreamCoreMetricsServer) error }
OpenRCAServiceServer is the server API for OpenRCAService service.
type OpenRCAService_StreamCoreMetricsClient ¶
type OpenRCAService_StreamCoreMetricsClient interface { Recv() (*LoadReport, error) grpc.ClientStream }
type OpenRCAService_StreamCoreMetricsServer ¶
type OpenRCAService_StreamCoreMetricsServer interface { Send(*LoadReport) error grpc.ServerStream }
Source Files ¶
orca.pb.go
- Version
- v1.20.1
- Published
- Apr 18, 2019
- Platform
- linux/amd64
- Imports
- 6 packages
- Last checked
- 3 minutes ago –
Tools for package owners.