grpc_testing

package
v1.51.0 Latest Latest
Warning

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

 Go to latest Published: Nov 18, 2022 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.33.2 

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.33.2 

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.33.2 

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

type UnimplementedMetricsServiceServer struct {
}

UnimplementedMetricsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMetricsServiceServer) GetAllGauges added in v1.24.0 

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

func (UnimplementedMetricsServiceServer) GetGauge added in v1.24.0 

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

type UnsafeMetricsServiceServer added in v1.33.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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.