grpc_testing

package
v1.36.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 25, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_stress_grpc_testing_metrics_proto protoreflect.FileDescriptor
View Source
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)

Functions

func RegisterMetricsServiceServer

func RegisterMetricsServiceServer(s grpc.ServiceRegistrar, srv MetricsServiceServer)

Types

type EmptyMessage

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

func (*EmptyMessage) Descriptor deprecated

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

Deprecated: Use EmptyMessage.ProtoReflect.Descriptor instead.

func (*EmptyMessage) ProtoMessage

func (*EmptyMessage) ProtoMessage()

func (*EmptyMessage) ProtoReflect added in v1.36.0

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 deprecated

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

Deprecated: Use GaugeRequest.ProtoReflect.Descriptor instead.

func (*GaugeRequest) GetName added in v1.6.0

func (x *GaugeRequest) GetName() string

func (*GaugeRequest) ProtoMessage

func (*GaugeRequest) ProtoMessage()

func (*GaugeRequest) ProtoReflect added in v1.36.0

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 deprecated

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 added in v1.6.0

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 added in v1.36.0

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.

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 added in v1.36.0

type UnimplementedMetricsServiceServer struct {
}

UnimplementedMetricsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMetricsServiceServer) GetAllGauges added in v1.36.0

func (UnimplementedMetricsServiceServer) GetGauge added in v1.36.0

type UnsafeMetricsServiceServer added in v1.36.0

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL