grpc: google.golang.org/grpc/stress/grpc_testing Index | Files

package grpc_testing

import "google.golang.org/grpc/stress/grpc_testing"

Index

Package Files

metrics.pb.go metrics_grpc.pb.go

Variables

var File_stress_grpc_testing_metrics_proto protoreflect.FileDescriptor
var MetricsService_ServiceDesc = grpc.ServiceDesc{
    ServiceName: "grpc.testing.MetricsService",
    HandlerType: (*MetricsServiceServer)(nil),
    Methods: []grpc.MethodDesc{
        {
            MethodName: "GetGauge",
            Handler:    _MetricsService_GetGauge_Handler,
        },
    },
    Streams: []grpc.StreamDesc{
        {
            StreamName:    "GetAllGauges",
            Handler:       _MetricsService_GetAllGauges_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "stress/grpc_testing/metrics.proto",
}

MetricsService_ServiceDesc is the grpc.ServiceDesc for MetricsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

func RegisterMetricsServiceServer Uses

func RegisterMetricsServiceServer(s grpc.ServiceRegistrar, srv MetricsServiceServer)

type EmptyMessage Uses

type EmptyMessage struct {
    // contains filtered or unexported fields
}

func (*EmptyMessage) Descriptor Uses

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

Deprecated: Use EmptyMessage.ProtoReflect.Descriptor instead.

func (*EmptyMessage) ProtoMessage Uses

func (*EmptyMessage) ProtoMessage()

func (*EmptyMessage) ProtoReflect Uses

func (x *EmptyMessage) ProtoReflect() protoreflect.Message

func (*EmptyMessage) Reset Uses

func (x *EmptyMessage) Reset()

func (*EmptyMessage) String Uses

func (x *EmptyMessage) String() string

type GaugeRequest Uses

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 Uses

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

Deprecated: Use GaugeRequest.ProtoReflect.Descriptor instead.

func (*GaugeRequest) GetName Uses

func (x *GaugeRequest) GetName() string

func (*GaugeRequest) ProtoMessage Uses

func (*GaugeRequest) ProtoMessage()

func (*GaugeRequest) ProtoReflect Uses

func (x *GaugeRequest) ProtoReflect() protoreflect.Message

func (*GaugeRequest) Reset Uses

func (x *GaugeRequest) Reset()

func (*GaugeRequest) String Uses

func (x *GaugeRequest) String() string

type GaugeResponse Uses

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 Uses

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

Deprecated: Use GaugeResponse.ProtoReflect.Descriptor instead.

func (*GaugeResponse) GetDoubleValue Uses

func (x *GaugeResponse) GetDoubleValue() float64

func (*GaugeResponse) GetLongValue Uses

func (x *GaugeResponse) GetLongValue() int64

func (*GaugeResponse) GetName Uses

func (x *GaugeResponse) GetName() string

func (*GaugeResponse) GetStringValue Uses

func (x *GaugeResponse) GetStringValue() string

func (*GaugeResponse) GetValue Uses

func (m *GaugeResponse) GetValue() isGaugeResponse_Value

func (*GaugeResponse) ProtoMessage Uses

func (*GaugeResponse) ProtoMessage()

func (*GaugeResponse) ProtoReflect Uses

func (x *GaugeResponse) ProtoReflect() protoreflect.Message

func (*GaugeResponse) Reset Uses

func (x *GaugeResponse) Reset()

func (*GaugeResponse) String Uses

func (x *GaugeResponse) String() string

type GaugeResponse_DoubleValue Uses

type GaugeResponse_DoubleValue struct {
    DoubleValue float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type GaugeResponse_LongValue Uses

type GaugeResponse_LongValue struct {
    LongValue int64 `protobuf:"varint,2,opt,name=long_value,json=longValue,proto3,oneof"`
}

type GaugeResponse_StringValue Uses

type GaugeResponse_StringValue struct {
    StringValue string `protobuf:"bytes,4,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type MetricsServiceClient Uses

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 Uses

func NewMetricsServiceClient(cc grpc.ClientConnInterface) MetricsServiceClient

type MetricsServiceServer Uses

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 Uses

type MetricsService_GetAllGaugesClient interface {
    Recv() (*GaugeResponse, error)
    grpc.ClientStream
}

type MetricsService_GetAllGaugesServer Uses

type MetricsService_GetAllGaugesServer interface {
    Send(*GaugeResponse) error
    grpc.ServerStream
}

type UnimplementedMetricsServiceServer Uses

type UnimplementedMetricsServiceServer struct {
}

UnimplementedMetricsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMetricsServiceServer) GetAllGauges Uses

func (UnimplementedMetricsServiceServer) GetAllGauges(*EmptyMessage, MetricsService_GetAllGaugesServer) error

func (UnimplementedMetricsServiceServer) GetGauge Uses

func (UnimplementedMetricsServiceServer) GetGauge(context.Context, *GaugeRequest) (*GaugeResponse, error)

type UnsafeMetricsServiceServer Uses

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.

Package grpc_testing imports 9 packages (graph) and is imported by 41 packages. Updated 2021-01-16. Refresh now. Tools for package owners.