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

package grpc_testing

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

Index

Functions

func RegisterMetricsServiceServer 

func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer)

Types

type EmptyMessage 

type EmptyMessage struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EmptyMessage) Descriptor 

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

func (*EmptyMessage) ProtoMessage 

func (*EmptyMessage) ProtoMessage()

func (*EmptyMessage) Reset 

func (m *EmptyMessage) Reset()

func (*EmptyMessage) String 

func (m *EmptyMessage) String() string

func (*EmptyMessage) XXX_DiscardUnknown 

func (m *EmptyMessage) XXX_DiscardUnknown()

func (*EmptyMessage) XXX_Marshal 

func (m *EmptyMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmptyMessage) XXX_Merge 

func (m *EmptyMessage) XXX_Merge(src proto.Message)

func (*EmptyMessage) XXX_Size 

func (m *EmptyMessage) XXX_Size() int

func (*EmptyMessage) XXX_Unmarshal 

func (m *EmptyMessage) XXX_Unmarshal(b []byte) error

type GaugeRequest 

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 

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

func (*GaugeRequest) GetName 

func (m *GaugeRequest) GetName() string

func (*GaugeRequest) ProtoMessage 

func (*GaugeRequest) ProtoMessage()

func (*GaugeRequest) Reset 

func (m *GaugeRequest) Reset()

func (*GaugeRequest) String 

func (m *GaugeRequest) String() string

func (*GaugeRequest) XXX_DiscardUnknown 

func (m *GaugeRequest) XXX_DiscardUnknown()

func (*GaugeRequest) XXX_Marshal 

func (m *GaugeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GaugeRequest) XXX_Merge 

func (m *GaugeRequest) XXX_Merge(src proto.Message)

func (*GaugeRequest) XXX_Size 

func (m *GaugeRequest) XXX_Size() int

func (*GaugeRequest) XXX_Unmarshal 

func (m *GaugeRequest) XXX_Unmarshal(b []byte) error

type GaugeResponse 

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 

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

func (*GaugeResponse) GetDoubleValue 

func (m *GaugeResponse) GetDoubleValue() float64

func (*GaugeResponse) GetLongValue 

func (m *GaugeResponse) GetLongValue() int64

func (*GaugeResponse) GetName 

func (m *GaugeResponse) GetName() string

func (*GaugeResponse) GetStringValue 

func (m *GaugeResponse) GetStringValue() string

func (*GaugeResponse) GetValue 

func (m *GaugeResponse) GetValue() isGaugeResponse_Value

func (*GaugeResponse) ProtoMessage 

func (*GaugeResponse) ProtoMessage()

func (*GaugeResponse) Reset 

func (m *GaugeResponse) Reset()

func (*GaugeResponse) String 

func (m *GaugeResponse) String() string

func (*GaugeResponse) XXX_DiscardUnknown 

func (m *GaugeResponse) XXX_DiscardUnknown()

func (*GaugeResponse) XXX_Marshal 

func (m *GaugeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GaugeResponse) XXX_Merge 

func (m *GaugeResponse) XXX_Merge(src proto.Message)

func (*GaugeResponse) XXX_OneofWrappers 

func (*GaugeResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GaugeResponse) XXX_Size 

func (m *GaugeResponse) XXX_Size() int

func (*GaugeResponse) XXX_Unmarshal 

func (m *GaugeResponse) XXX_Unmarshal(b []byte) error

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.33.0
Published
Oct 8, 2020
Platform
js/wasm
Imports
7 packages
Last checked
38 minutes ago –

Tools for package owners.