Documentation
¶
Index ¶
- func RegisterOpenRcaServiceServer(s *grpc.Server, srv OpenRcaServiceServer)
- type OpenRcaServiceClient
- type OpenRcaServiceServer
- type OpenRcaService_StreamCoreMetricsClient
- type OpenRcaService_StreamCoreMetricsServer
- type OrcaLoadReportRequest
- func (*OrcaLoadReportRequest) Descriptor() ([]byte, []int)
- func (m *OrcaLoadReportRequest) GetReportInterval() *duration.Duration
- func (m *OrcaLoadReportRequest) GetRequestCostNames() []string
- func (*OrcaLoadReportRequest) ProtoMessage()
- func (m *OrcaLoadReportRequest) Reset()
- func (m *OrcaLoadReportRequest) String() string
- func (m *OrcaLoadReportRequest) XXX_DiscardUnknown()
- func (m *OrcaLoadReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OrcaLoadReportRequest) XXX_Merge(src proto.Message)
- func (m *OrcaLoadReportRequest) XXX_Size() int
- func (m *OrcaLoadReportRequest) XXX_Unmarshal(b []byte) error
- type UnimplementedOpenRcaServiceServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterOpenRcaServiceServer ¶
func RegisterOpenRcaServiceServer(s *grpc.Server, srv OpenRcaServiceServer)
Types ¶
type OpenRcaServiceClient ¶
type OpenRcaServiceClient interface {
StreamCoreMetrics(ctx context.Context, in *OrcaLoadReportRequest, 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/code.aliyun.com/yjkj.ink/grpc#ClientConn.NewStream.
func NewOpenRcaServiceClient ¶
func NewOpenRcaServiceClient(cc grpc.ClientConnInterface) OpenRcaServiceClient
type OpenRcaServiceServer ¶
type OpenRcaServiceServer interface {
StreamCoreMetrics(*OrcaLoadReportRequest, OpenRcaService_StreamCoreMetricsServer) error
}
OpenRcaServiceServer is the server API for OpenRcaService service.
type OpenRcaService_StreamCoreMetricsClient ¶
type OpenRcaService_StreamCoreMetricsClient interface {
Recv() (*v1.OrcaLoadReport, error)
grpc.ClientStream
}
type OpenRcaService_StreamCoreMetricsServer ¶
type OpenRcaService_StreamCoreMetricsServer interface {
Send(*v1.OrcaLoadReport) error
grpc.ServerStream
}
type OrcaLoadReportRequest ¶
type OrcaLoadReportRequest 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 (*OrcaLoadReportRequest) Descriptor ¶
func (*OrcaLoadReportRequest) Descriptor() ([]byte, []int)
func (*OrcaLoadReportRequest) GetReportInterval ¶
func (m *OrcaLoadReportRequest) GetReportInterval() *duration.Duration
func (*OrcaLoadReportRequest) GetRequestCostNames ¶
func (m *OrcaLoadReportRequest) GetRequestCostNames() []string
func (*OrcaLoadReportRequest) ProtoMessage ¶
func (*OrcaLoadReportRequest) ProtoMessage()
func (*OrcaLoadReportRequest) Reset ¶
func (m *OrcaLoadReportRequest) Reset()
func (*OrcaLoadReportRequest) String ¶
func (m *OrcaLoadReportRequest) String() string
func (*OrcaLoadReportRequest) XXX_DiscardUnknown ¶
func (m *OrcaLoadReportRequest) XXX_DiscardUnknown()
func (*OrcaLoadReportRequest) XXX_Marshal ¶
func (m *OrcaLoadReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OrcaLoadReportRequest) XXX_Merge ¶
func (m *OrcaLoadReportRequest) XXX_Merge(src proto.Message)
func (*OrcaLoadReportRequest) XXX_Size ¶
func (m *OrcaLoadReportRequest) XXX_Size() int
func (*OrcaLoadReportRequest) XXX_Unmarshal ¶
func (m *OrcaLoadReportRequest) XXX_Unmarshal(b []byte) error
type UnimplementedOpenRcaServiceServer ¶
type UnimplementedOpenRcaServiceServer struct {
}
UnimplementedOpenRcaServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedOpenRcaServiceServer) StreamCoreMetrics ¶
func (*UnimplementedOpenRcaServiceServer) StreamCoreMetrics(req *OrcaLoadReportRequest, srv OpenRcaService_StreamCoreMetricsServer) error
Source Files
¶
- orca.pb.go
Click to show internal directories.
Click to hide internal directories.