package grpc_testing
import "google.golang.org/grpc/stress/grpc_testing"
Index ¶
- Variables
- func RegisterMetricsServiceServer(s grpc.ServiceRegistrar, srv MetricsServiceServer)
- type EmptyMessage
- func (*EmptyMessage) Descriptor() ([]byte, []int)
- func (*EmptyMessage) ProtoMessage()
- func (x *EmptyMessage) ProtoReflect() protoreflect.Message
- func (x *EmptyMessage) Reset()
- func (x *EmptyMessage) String() string
- type GaugeRequest
- func (*GaugeRequest) Descriptor() ([]byte, []int)
- func (x *GaugeRequest) GetName() string
- func (*GaugeRequest) ProtoMessage()
- func (x *GaugeRequest) ProtoReflect() protoreflect.Message
- func (x *GaugeRequest) Reset()
- func (x *GaugeRequest) String() string
- type GaugeResponse
- func (*GaugeResponse) Descriptor() ([]byte, []int)
- func (x *GaugeResponse) GetDoubleValue() float64
- func (x *GaugeResponse) GetLongValue() int64
- func (x *GaugeResponse) GetName() string
- func (x *GaugeResponse) GetStringValue() string
- func (m *GaugeResponse) GetValue() isGaugeResponse_Value
- func (*GaugeResponse) ProtoMessage()
- func (x *GaugeResponse) ProtoReflect() protoreflect.Message
- func (x *GaugeResponse) Reset()
- func (x *GaugeResponse) String() string
- type GaugeResponse_DoubleValue
- type GaugeResponse_LongValue
- type GaugeResponse_StringValue
- type MetricsServiceClient
- type MetricsServiceServer
- type MetricsService_GetAllGaugesClient
- type MetricsService_GetAllGaugesServer
- type UnimplementedMetricsServiceServer
- func (UnimplementedMetricsServiceServer) GetAllGauges(*EmptyMessage, MetricsService_GetAllGaugesServer) error
- func (UnimplementedMetricsServiceServer) GetGauge(context.Context, *GaugeRequest) (*GaugeResponse, error)
- type UnsafeMetricsServiceServer
Variables ¶
var File_stress_grpc_testing_metrics_proto protoreflect.FileDescriptor
Functions ¶
func RegisterMetricsServiceServer ¶
func RegisterMetricsServiceServer(s grpc.ServiceRegistrar, srv MetricsServiceServer)
Types ¶
type EmptyMessage ¶
type EmptyMessage struct {
// contains filtered or unexported fields
}
func (*EmptyMessage) Descriptor ¶
func (*EmptyMessage) Descriptor() ([]byte, []int)
Deprecated: Use EmptyMessage.ProtoReflect.Descriptor instead.
func (*EmptyMessage) ProtoMessage ¶
func (*EmptyMessage) ProtoMessage()
func (*EmptyMessage) ProtoReflect ¶
func (x *EmptyMessage) ProtoReflect() protoreflect.Message
func (*EmptyMessage) Reset ¶
func (x *EmptyMessage) Reset()
func (*EmptyMessage) String ¶
func (x *EmptyMessage) String() string
type GaugeRequest ¶
type GaugeRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request message containing the gauge name
func (*GaugeRequest) Descriptor ¶
func (*GaugeRequest) Descriptor() ([]byte, []int)
Deprecated: Use GaugeRequest.ProtoReflect.Descriptor instead.
func (*GaugeRequest) GetName ¶
func (x *GaugeRequest) GetName() string
func (*GaugeRequest) ProtoMessage ¶
func (*GaugeRequest) ProtoMessage()
func (*GaugeRequest) ProtoReflect ¶
func (x *GaugeRequest) ProtoReflect() protoreflect.Message
func (*GaugeRequest) Reset ¶
func (x *GaugeRequest) Reset()
func (*GaugeRequest) String ¶
func (x *GaugeRequest) String() string
type GaugeResponse ¶
type GaugeResponse struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Types that are assignable to Value: // *GaugeResponse_LongValue // *GaugeResponse_DoubleValue // *GaugeResponse_StringValue Value isGaugeResponse_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
Response message containing the gauge name and value
func (*GaugeResponse) Descriptor ¶
func (*GaugeResponse) Descriptor() ([]byte, []int)
Deprecated: Use GaugeResponse.ProtoReflect.Descriptor instead.
func (*GaugeResponse) GetDoubleValue ¶
func (x *GaugeResponse) GetDoubleValue() float64
func (*GaugeResponse) GetLongValue ¶
func (x *GaugeResponse) GetLongValue() int64
func (*GaugeResponse) GetName ¶
func (x *GaugeResponse) GetName() string
func (*GaugeResponse) GetStringValue ¶
func (x *GaugeResponse) GetStringValue() string
func (*GaugeResponse) GetValue ¶
func (m *GaugeResponse) GetValue() isGaugeResponse_Value
func (*GaugeResponse) ProtoMessage ¶
func (*GaugeResponse) ProtoMessage()
func (*GaugeResponse) ProtoReflect ¶
func (x *GaugeResponse) ProtoReflect() protoreflect.Message
func (*GaugeResponse) Reset ¶
func (x *GaugeResponse) Reset()
func (*GaugeResponse) String ¶
func (x *GaugeResponse) String() string
type GaugeResponse_DoubleValue ¶
type GaugeResponse_DoubleValue struct { DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"` }
type GaugeResponse_LongValue ¶
type GaugeResponse_LongValue struct { LongValue int64 `protobuf:"varint,2,opt,name=long_value,json=longValue,proto3,oneof"` }
type GaugeResponse_StringValue ¶
type GaugeResponse_StringValue struct { StringValue string `protobuf:"bytes,4,opt,name=string_value,json=stringValue,proto3,oneof"` }
type MetricsServiceClient ¶
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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewMetricsServiceClient ¶
func NewMetricsServiceClient(cc grpc.ClientConnInterface) MetricsServiceClient
type MetricsServiceServer ¶
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) // contains filtered or unexported methods }
MetricsServiceServer is the server API for MetricsService service. All implementations must embed UnimplementedMetricsServiceServer for forward compatibility
type MetricsService_GetAllGaugesClient ¶
type MetricsService_GetAllGaugesClient interface { Recv() (*GaugeResponse, error) grpc.ClientStream }
type MetricsService_GetAllGaugesServer ¶
type MetricsService_GetAllGaugesServer interface { Send(*GaugeResponse) error grpc.ServerStream }
type UnimplementedMetricsServiceServer ¶
type UnimplementedMetricsServiceServer struct { }
UnimplementedMetricsServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedMetricsServiceServer) GetAllGauges ¶
func (UnimplementedMetricsServiceServer) GetAllGauges(*EmptyMessage, MetricsService_GetAllGaugesServer) error
func (UnimplementedMetricsServiceServer) GetGauge ¶
func (UnimplementedMetricsServiceServer) GetGauge(context.Context, *GaugeRequest) (*GaugeResponse, error)
type UnsafeMetricsServiceServer ¶
type UnsafeMetricsServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMetricsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetricsServiceServer will result in compilation errors.
Source Files ¶
metrics.pb.go metrics_grpc.pb.go
- Version
- v1.34.1
- Published
- Jan 11, 2021
- Platform
- linux/amd64
- Imports
- 9 packages
- Last checked
- 3 minutes ago –
Tools for package owners.