Documentation ¶
Overview ¶
Package test is a generated protocol buffer package.
It is generated from these files:
test.proto
It has these top-level messages:
TestRequest TestResponse
Index ¶
- Variables
- func RegisterTestSvcServer(s *grpc.Server, srv TestSvcServer)
- func StartInProcServer(socketPath string, tracer opentracing.Tracer, waitChan chan<- *grpc.Server)
- type TestRequest
- func (*TestRequest) Descriptor() ([]byte, []int)
- func (m *TestRequest) GetRequest() string
- func (m *TestRequest) Marshal() (dAtA []byte, err error)
- func (m *TestRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TestRequest) ProtoMessage()
- func (m *TestRequest) Reset()
- func (m *TestRequest) Size() (n int)
- func (m *TestRequest) String() string
- func (m *TestRequest) Unmarshal(dAtA []byte) error
- type TestResponse
- func (*TestResponse) Descriptor() ([]byte, []int)
- func (m *TestResponse) GetResponse() string
- func (m *TestResponse) Marshal() (dAtA []byte, err error)
- func (m *TestResponse) MarshalTo(dAtA []byte) (int, error)
- func (*TestResponse) ProtoMessage()
- func (m *TestResponse) Reset()
- func (m *TestResponse) Size() (n int)
- func (m *TestResponse) String() string
- func (m *TestResponse) Unmarshal(dAtA []byte) error
- type TestServer
- func (ts *TestServer) BidiStreamRPC(stream TestSvc_BidiStreamRPCServer) error
- func (ts *TestServer) ClientStreamRPC(stream TestSvc_ClientStreamRPCServer) error
- func (ts *TestServer) ServerStreamRPC(req *TestRequest, stream TestSvc_ServerStreamRPCServer) error
- func (ts *TestServer) UnaryRPC(ctx context.Context, req *TestRequest) (*TestResponse, error)
- type TestSvcClient
- type TestSvcServer
- type TestSvc_BidiStreamRPCClient
- type TestSvc_BidiStreamRPCServer
- type TestSvc_ClientStreamRPCClient
- type TestSvc_ClientStreamRPCServer
- type TestSvc_ServerStreamRPCClient
- type TestSvc_ServerStreamRPCServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthTest = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTest = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterTestSvcServer ¶
func RegisterTestSvcServer(s *grpc.Server, srv TestSvcServer)
func StartInProcServer ¶
Types ¶
type TestRequest ¶
type TestRequest struct {
Request string `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
}
func (*TestRequest) Descriptor ¶
func (*TestRequest) Descriptor() ([]byte, []int)
func (*TestRequest) GetRequest ¶
func (m *TestRequest) GetRequest() string
func (*TestRequest) Marshal ¶
func (m *TestRequest) Marshal() (dAtA []byte, err error)
func (*TestRequest) ProtoMessage ¶
func (*TestRequest) ProtoMessage()
func (*TestRequest) Reset ¶
func (m *TestRequest) Reset()
func (*TestRequest) Size ¶
func (m *TestRequest) Size() (n int)
func (*TestRequest) String ¶
func (m *TestRequest) String() string
func (*TestRequest) Unmarshal ¶
func (m *TestRequest) Unmarshal(dAtA []byte) error
type TestResponse ¶
type TestResponse struct {
Response string `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
}
func (*TestResponse) Descriptor ¶
func (*TestResponse) Descriptor() ([]byte, []int)
func (*TestResponse) GetResponse ¶
func (m *TestResponse) GetResponse() string
func (*TestResponse) Marshal ¶
func (m *TestResponse) Marshal() (dAtA []byte, err error)
func (*TestResponse) ProtoMessage ¶
func (*TestResponse) ProtoMessage()
func (*TestResponse) Reset ¶
func (m *TestResponse) Reset()
func (*TestResponse) Size ¶
func (m *TestResponse) Size() (n int)
func (*TestResponse) String ¶
func (m *TestResponse) String() string
func (*TestResponse) Unmarshal ¶
func (m *TestResponse) Unmarshal(dAtA []byte) error
type TestServer ¶
type TestServer struct{}
func (*TestServer) BidiStreamRPC ¶
func (ts *TestServer) BidiStreamRPC(stream TestSvc_BidiStreamRPCServer) error
func (*TestServer) ClientStreamRPC ¶
func (ts *TestServer) ClientStreamRPC(stream TestSvc_ClientStreamRPCServer) error
func (*TestServer) ServerStreamRPC ¶
func (ts *TestServer) ServerStreamRPC(req *TestRequest, stream TestSvc_ServerStreamRPCServer) error
func (*TestServer) UnaryRPC ¶
func (ts *TestServer) UnaryRPC(ctx context.Context, req *TestRequest) (*TestResponse, error)
type TestSvcClient ¶
type TestSvcClient interface { UnaryRPC(ctx context.Context, in *TestRequest, opts ...grpc.CallOption) (*TestResponse, error) ClientStreamRPC(ctx context.Context, opts ...grpc.CallOption) (TestSvc_ClientStreamRPCClient, error) ServerStreamRPC(ctx context.Context, in *TestRequest, opts ...grpc.CallOption) (TestSvc_ServerStreamRPCClient, error) BidiStreamRPC(ctx context.Context, opts ...grpc.CallOption) (TestSvc_BidiStreamRPCClient, error) }
func GetInProcClient ¶
func GetInProcClient(socketPath string, tracer opentracing.Tracer) TestSvcClient
func NewTestSvcClient ¶
func NewTestSvcClient(cc *grpc.ClientConn) TestSvcClient
type TestSvcServer ¶
type TestSvcServer interface { UnaryRPC(context.Context, *TestRequest) (*TestResponse, error) ClientStreamRPC(TestSvc_ClientStreamRPCServer) error ServerStreamRPC(*TestRequest, TestSvc_ServerStreamRPCServer) error BidiStreamRPC(TestSvc_BidiStreamRPCServer) error }
type TestSvc_BidiStreamRPCClient ¶
type TestSvc_BidiStreamRPCClient interface { Send(*TestRequest) error Recv() (*TestResponse, error) grpc.ClientStream }
type TestSvc_BidiStreamRPCServer ¶
type TestSvc_BidiStreamRPCServer interface { Send(*TestResponse) error Recv() (*TestRequest, error) grpc.ServerStream }
type TestSvc_ClientStreamRPCClient ¶
type TestSvc_ClientStreamRPCClient interface { Send(*TestRequest) error CloseAndRecv() (*TestResponse, error) grpc.ClientStream }
type TestSvc_ClientStreamRPCServer ¶
type TestSvc_ClientStreamRPCServer interface { SendAndClose(*TestResponse) error Recv() (*TestRequest, error) grpc.ServerStream }
type TestSvc_ServerStreamRPCClient ¶
type TestSvc_ServerStreamRPCClient interface { Recv() (*TestResponse, error) grpc.ClientStream }
type TestSvc_ServerStreamRPCServer ¶
type TestSvc_ServerStreamRPCServer interface { Send(*TestResponse) error grpc.ServerStream }
Click to show internal directories.
Click to hide internal directories.