import "google.golang.org/grpc/stress/grpc_testing"
func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer)
type EmptyMessage struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}func (*EmptyMessage) Descriptor() ([]byte, []int)
func (*EmptyMessage) ProtoMessage()
func (m *EmptyMessage) Reset()
func (m *EmptyMessage) String() string
func (m *EmptyMessage) XXX_DiscardUnknown()
func (m *EmptyMessage) XXX_Merge(src proto.Message)
func (m *EmptyMessage) XXX_Size() int
func (m *EmptyMessage) XXX_Unmarshal(b []byte) error
type GaugeRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}Request message containing the gauge name
func (*GaugeRequest) Descriptor() ([]byte, []int)
func (m *GaugeRequest) GetName() string
func (*GaugeRequest) ProtoMessage()
func (m *GaugeRequest) Reset()
func (m *GaugeRequest) String() string
func (m *GaugeRequest) XXX_DiscardUnknown()
func (m *GaugeRequest) XXX_Merge(src proto.Message)
func (m *GaugeRequest) XXX_Size() int
func (m *GaugeRequest) XXX_Unmarshal(b []byte) error
type GaugeResponse struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Types that are valid to be assigned to Value:
// *GaugeResponse_LongValue
// *GaugeResponse_DoubleValue
// *GaugeResponse_StringValue
Value isGaugeResponse_Value `protobuf_oneof:"value"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}Response message containing the gauge name and value
func (*GaugeResponse) Descriptor() ([]byte, []int)
func (m *GaugeResponse) GetDoubleValue() float64
func (m *GaugeResponse) GetLongValue() int64
func (m *GaugeResponse) GetName() string
func (m *GaugeResponse) GetStringValue() string
func (m *GaugeResponse) GetValue() isGaugeResponse_Value
func (*GaugeResponse) ProtoMessage()
func (m *GaugeResponse) Reset()
func (m *GaugeResponse) String() string
func (m *GaugeResponse) XXX_DiscardUnknown()
func (m *GaugeResponse) XXX_Merge(src proto.Message)
func (*GaugeResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (m *GaugeResponse) XXX_Size() int
func (m *GaugeResponse) XXX_Unmarshal(b []byte) error
type GaugeResponse_DoubleValue struct {
DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"`
}type GaugeResponse_LongValue struct {
LongValue int64 `protobuf:"varint,2,opt,name=long_value,json=longValue,proto3,oneof"`
}type GaugeResponse_StringValue struct {
StringValue string `protobuf:"bytes,4,opt,name=string_value,json=stringValue,proto3,oneof"`
}type MetricsServiceClient interface {
// Returns the values of all the gauges that are currently being maintained by
// the service
GetAllGauges(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (MetricsService_GetAllGaugesClient, error)
// Returns the value of one gauge
GetGauge(ctx context.Context, in *GaugeRequest, opts ...grpc.CallOption) (*GaugeResponse, error)
}MetricsServiceClient is the client API for MetricsService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMetricsServiceClient(cc grpc.ClientConnInterface) MetricsServiceClient
type MetricsServiceServer interface {
// Returns the values of all the gauges that are currently being maintained by
// the service
GetAllGauges(*EmptyMessage, MetricsService_GetAllGaugesServer) error
// Returns the value of one gauge
GetGauge(context.Context, *GaugeRequest) (*GaugeResponse, error)
}MetricsServiceServer is the server API for MetricsService service.
type MetricsService_GetAllGaugesClient interface {
Recv() (*GaugeResponse, error)
grpc.ClientStream
}type MetricsService_GetAllGaugesServer interface {
Send(*GaugeResponse) error
grpc.ServerStream
}type UnimplementedMetricsServiceServer struct {
}UnimplementedMetricsServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedMetricsServiceServer) GetAllGauges(req *EmptyMessage, srv MetricsService_GetAllGaugesServer) error
func (*UnimplementedMetricsServiceServer) GetGauge(ctx context.Context, req *GaugeRequest) (*GaugeResponse, error)
Package grpc_testing imports 7 packages (graph) and is imported by 35 packages. Updated 2020-02-03. Refresh now. Tools for package owners.