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

func RegisterMetricsServiceService Uses

func RegisterMetricsServiceService(s grpc.ServiceRegistrar, srv *MetricsServiceService)

RegisterMetricsServiceService registers a service implementation with a gRPC server.

type EmptyMessage Uses

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

func (*EmptyMessage) Descriptor Uses

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

func (*EmptyMessage) ProtoMessage Uses

func (*EmptyMessage) ProtoMessage()

func (*EmptyMessage) Reset Uses

func (m *EmptyMessage) Reset()

func (*EmptyMessage) String Uses

func (m *EmptyMessage) String() string

func (*EmptyMessage) XXX_DiscardUnknown Uses

func (m *EmptyMessage) XXX_DiscardUnknown()

func (*EmptyMessage) XXX_Marshal Uses

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

func (*EmptyMessage) XXX_Merge Uses

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

func (*EmptyMessage) XXX_Size Uses

func (m *EmptyMessage) XXX_Size() int

func (*EmptyMessage) XXX_Unmarshal Uses

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

type GaugeRequest Uses

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 Uses

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

func (*GaugeRequest) GetName Uses

func (m *GaugeRequest) GetName() string

func (*GaugeRequest) ProtoMessage Uses

func (*GaugeRequest) ProtoMessage()

func (*GaugeRequest) Reset Uses

func (m *GaugeRequest) Reset()

func (*GaugeRequest) String Uses

func (m *GaugeRequest) String() string

func (*GaugeRequest) XXX_DiscardUnknown Uses

func (m *GaugeRequest) XXX_DiscardUnknown()

func (*GaugeRequest) XXX_Marshal Uses

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

func (*GaugeRequest) XXX_Merge Uses

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

func (*GaugeRequest) XXX_Size Uses

func (m *GaugeRequest) XXX_Size() int

func (*GaugeRequest) XXX_Unmarshal Uses

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

type GaugeResponse Uses

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 Uses

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

func (*GaugeResponse) GetDoubleValue Uses

func (m *GaugeResponse) GetDoubleValue() float64

func (*GaugeResponse) GetLongValue Uses

func (m *GaugeResponse) GetLongValue() int64

func (*GaugeResponse) GetName Uses

func (m *GaugeResponse) GetName() string

func (*GaugeResponse) GetStringValue Uses

func (m *GaugeResponse) GetStringValue() string

func (*GaugeResponse) GetValue Uses

func (m *GaugeResponse) GetValue() isGaugeResponse_Value

func (*GaugeResponse) ProtoMessage Uses

func (*GaugeResponse) ProtoMessage()

func (*GaugeResponse) Reset Uses

func (m *GaugeResponse) Reset()

func (*GaugeResponse) String Uses

func (m *GaugeResponse) String() string

func (*GaugeResponse) XXX_DiscardUnknown Uses

func (m *GaugeResponse) XXX_DiscardUnknown()

func (*GaugeResponse) XXX_Marshal Uses

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

func (*GaugeResponse) XXX_Merge Uses

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

func (*GaugeResponse) XXX_OneofWrappers Uses

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*GaugeResponse) XXX_Size Uses

func (m *GaugeResponse) XXX_Size() int

func (*GaugeResponse) XXX_Unmarshal Uses

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

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 MetricsServiceService Uses

type MetricsServiceService struct {
    // Returns the values of all the gauges that are currently being maintained by
    // the service
    GetAllGauges func(*EmptyMessage, MetricsService_GetAllGaugesServer) error
    // Returns the value of one gauge
    GetGauge func(context.Context, *GaugeRequest) (*GaugeResponse, error)
}

MetricsServiceService is the service API for MetricsService service. Fields should be assigned to their respective handler implementations only before RegisterMetricsServiceService is called. Any unassigned fields will result in the handler for that method returning an Unimplemented error.

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
}

Package grpc_testing imports 7 packages (graph) and is imported by 39 packages. Updated 2020-09-17. Refresh now. Tools for package owners.