Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)
- func TestTestServiceServerImpl(t *testing.T, client TestServiceClient)
- type PingRequest
- type PingResponse
- func (*PingResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PingResponse) GetCounter() int32
- func (x *PingResponse) GetValue() string
- func (*PingResponse) ProtoMessage()
- func (x *PingResponse) ProtoReflect() protoreflect.Message
- func (x *PingResponse) Reset()
- func (x *PingResponse) String() string
- type TestServiceClient
- type TestServiceServer
- type TestService_PingListClient
- type TestService_PingListServer
- type TestService_PingStreamClient
- type TestService_PingStreamServer
- type UnimplementedTestServiceServer
- func (UnimplementedTestServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
- func (UnimplementedTestServiceServer) PingEmpty(context.Context, *emptypb.Empty) (*PingResponse, error)
- func (UnimplementedTestServiceServer) PingError(context.Context, *PingRequest) (*emptypb.Empty, error)
- func (UnimplementedTestServiceServer) PingList(*PingRequest, TestService_PingListServer) error
- func (UnimplementedTestServiceServer) PingStream(TestService_PingStreamServer) error
- type UnsafeTestServiceServer
Constants ¶
const ( PingHeader = "ping-header" PingHeaderCts = "Arbitrary header text" PingTrailer = "ping-trailer" PingTrailerCts = "Arbitrary trailer text" PingEchoHeader = "ping-echo-header" PingEchoTrailer = "ping-echo-trailer" )
Variables ¶
var DefaultTestServiceServer = defaultPingServer{}
var File_test_proto protoreflect.FileDescriptor
var TestService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "mwitkow.testproto.TestService", HandlerType: (*TestServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "PingEmpty", Handler: _TestService_PingEmpty_Handler, }, { MethodName: "Ping", Handler: _TestService_Ping_Handler, }, { MethodName: "PingError", Handler: _TestService_PingError_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "PingList", Handler: _TestService_PingList_Handler, ServerStreams: true, }, { StreamName: "PingStream", Handler: _TestService_PingStream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "test.proto", }
TestService_ServiceDesc is the grpc.ServiceDesc for TestService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterTestServiceServer ¶
func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)
func TestTestServiceServerImpl ¶
func TestTestServiceServerImpl(t *testing.T, client TestServiceClient)
TestTestServiceServerImpl can be called to test the underlying TestServiceServer.
Types ¶
type PingRequest ¶
type PingRequest struct {
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*PingRequest) Descriptor
deprecated
func (*PingRequest) Descriptor() ([]byte, []int)
Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.
func (*PingRequest) GetValue ¶
func (x *PingRequest) GetValue() string
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) ProtoReflect ¶
func (x *PingRequest) ProtoReflect() protoreflect.Message
func (*PingRequest) Reset ¶
func (x *PingRequest) Reset()
func (*PingRequest) String ¶
func (x *PingRequest) String() string
type PingResponse ¶
type PingResponse struct {
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
Counter int32 `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
// contains filtered or unexported fields
}
func (*PingResponse) Descriptor
deprecated
func (*PingResponse) Descriptor() ([]byte, []int)
Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.
func (*PingResponse) GetCounter ¶
func (x *PingResponse) GetCounter() int32
func (*PingResponse) GetValue ¶
func (x *PingResponse) GetValue() string
func (*PingResponse) ProtoMessage ¶
func (*PingResponse) ProtoMessage()
func (*PingResponse) ProtoReflect ¶
func (x *PingResponse) ProtoReflect() protoreflect.Message
func (*PingResponse) Reset ¶
func (x *PingResponse) Reset()
func (*PingResponse) String ¶
func (x *PingResponse) String() string
type TestServiceClient ¶
type TestServiceClient interface {
PingEmpty(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PingResponse, error)
Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
PingError(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
PingList(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (TestService_PingListClient, error)
PingStream(ctx context.Context, opts ...grpc.CallOption) (TestService_PingStreamClient, error)
}
TestServiceClient is the client API for TestService 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 NewTestServiceClient ¶
func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient
type TestServiceServer ¶
type TestServiceServer interface {
PingEmpty(context.Context, *emptypb.Empty) (*PingResponse, error)
Ping(context.Context, *PingRequest) (*PingResponse, error)
PingError(context.Context, *PingRequest) (*emptypb.Empty, error)
PingList(*PingRequest, TestService_PingListServer) error
PingStream(TestService_PingStreamServer) error
// contains filtered or unexported methods
}
TestServiceServer is the server API for TestService service. All implementations must embed UnimplementedTestServiceServer for forward compatibility
type TestService_PingListClient ¶
type TestService_PingListClient interface {
Recv() (*PingResponse, error)
grpc.ClientStream
}
type TestService_PingListServer ¶
type TestService_PingListServer interface {
Send(*PingResponse) error
grpc.ServerStream
}
type TestService_PingStreamClient ¶
type TestService_PingStreamClient interface {
Send(*PingRequest) error
Recv() (*PingResponse, error)
grpc.ClientStream
}
type TestService_PingStreamServer ¶
type TestService_PingStreamServer interface {
Send(*PingResponse) error
Recv() (*PingRequest, error)
grpc.ServerStream
}
type UnimplementedTestServiceServer ¶
type UnimplementedTestServiceServer struct {
}
UnimplementedTestServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedTestServiceServer) Ping ¶
func (UnimplementedTestServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
func (UnimplementedTestServiceServer) PingEmpty ¶
func (UnimplementedTestServiceServer) PingEmpty(context.Context, *emptypb.Empty) (*PingResponse, error)
func (UnimplementedTestServiceServer) PingError ¶
func (UnimplementedTestServiceServer) PingError(context.Context, *PingRequest) (*emptypb.Empty, error)
func (UnimplementedTestServiceServer) PingList ¶
func (UnimplementedTestServiceServer) PingList(*PingRequest, TestService_PingListServer) error
func (UnimplementedTestServiceServer) PingStream ¶
func (UnimplementedTestServiceServer) PingStream(TestService_PingStreamServer) error
type UnsafeTestServiceServer ¶
type UnsafeTestServiceServer interface {
// contains filtered or unexported methods
}
UnsafeTestServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TestServiceServer will result in compilation errors.