Documentation
¶
Index ¶
- Variables
- type Event
- type TestListener
- type TestListenerAsync
- type TestListenerClient
- type TestListenerClientAsync
- type TestListenerServer
- type TestService
- type TestService2
- type TestService2Async
- type TestService2Client
- type TestService2ClientAsync
- type TestService2Server
- type TestServiceAsync
- type TestServiceClient
- type TestServiceClientAsync
- type TestServiceServer
- type Void
Constants ¶
This section is empty.
Variables ¶
View Source
var File_service_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Event ¶
type Event struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*Event) Descriptor
deprecated
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type TestListenerAsync ¶
type TestListenerClient ¶
type TestListenerClient struct {
// contains filtered or unexported fields
}
func NewRSocketTestListenerClient ¶
func NewRSocketTestListenerClient(selector uint64, rs rsocketgo.RSocket) *TestListenerClient
func NewTestListenerClient ¶
func NewTestListenerClient(selector uint64, handler runtime.ClientRequestResponseHandler) *TestListenerClient
type TestListenerClientAsync ¶
type TestListenerClientAsync struct {
// contains filtered or unexported fields
}
func NewRSocketTestListenerClientAsync ¶
func NewRSocketTestListenerClientAsync(selector uint64, rs rsocketgo.RSocket) *TestListenerClientAsync
func NewTestListenerClientAsync ¶
func NewTestListenerClientAsync(selector uint64, handler runtime.ClientRequestResponseHandlerAsync) *TestListenerClientAsync
type TestListenerServer ¶
type TestListenerServer struct {
// contains filtered or unexported fields
}
func NewTestListenerServer ¶
func NewTestListenerServer(selector uint64, service TestListener) *TestListenerServer
func (*TestListenerServer) HandleRequestResponse ¶
func (s *TestListenerServer) HandleRequestResponse(ctx context.Context, reqWrapper *runtime.RequestWrapper) (proto.Message, error)
func (*TestListenerServer) Selector ¶
func (s *TestListenerServer) Selector() uint64
type TestService ¶
type TestService interface {
Test(context.Context, *pb.TestRequest) (*pb1.TestResponse, error)
}
type TestService2 ¶
type TestService2 interface {
Test(context.Context, *pb.TestRequest) (*pb1.TestResponse, error)
}
type TestService2Async ¶
type TestService2Async interface {
Test(context.Context, *pb.TestRequest) *mo.Future[*pb1.TestResponse]
}
type TestService2Client ¶
type TestService2Client struct {
// contains filtered or unexported fields
}
func NewRSocketTestService2Client ¶
func NewRSocketTestService2Client(selector uint64, rs rsocketgo.RSocket) *TestService2Client
func NewTestService2Client ¶
func NewTestService2Client(selector uint64, handler runtime.ClientRequestResponseHandler) *TestService2Client
func (*TestService2Client) Test ¶
func (c *TestService2Client) Test(ctx context.Context, req *pb.TestRequest) (*pb1.TestResponse, error)
type TestService2ClientAsync ¶
type TestService2ClientAsync struct {
// contains filtered or unexported fields
}
func NewRSocketTestService2ClientAsync ¶
func NewRSocketTestService2ClientAsync(selector uint64, rs rsocketgo.RSocket) *TestService2ClientAsync
func NewTestService2ClientAsync ¶
func NewTestService2ClientAsync(selector uint64, handler runtime.ClientRequestResponseHandlerAsync) *TestService2ClientAsync
func (*TestService2ClientAsync) Test ¶
func (c *TestService2ClientAsync) Test(ctx context.Context, req *pb.TestRequest) *mo.Future[*pb1.TestResponse]
type TestService2Server ¶
type TestService2Server struct {
// contains filtered or unexported fields
}
func NewTestService2Server ¶
func NewTestService2Server(selector uint64, service TestService2) *TestService2Server
func (*TestService2Server) HandleRequestResponse ¶
func (s *TestService2Server) HandleRequestResponse(ctx context.Context, reqWrapper *runtime.RequestWrapper) (proto.Message, error)
func (*TestService2Server) Selector ¶
func (s *TestService2Server) Selector() uint64
type TestServiceAsync ¶
type TestServiceAsync interface {
Test(context.Context, *pb.TestRequest) *mo.Future[*pb1.TestResponse]
}
type TestServiceClient ¶
type TestServiceClient struct {
// contains filtered or unexported fields
}
func NewRSocketTestServiceClient ¶
func NewRSocketTestServiceClient(selector uint64, rs rsocketgo.RSocket) *TestServiceClient
func NewTestServiceClient ¶
func NewTestServiceClient(selector uint64, handler runtime.ClientRequestResponseHandler) *TestServiceClient
func (*TestServiceClient) Test ¶
func (c *TestServiceClient) Test(ctx context.Context, req *pb.TestRequest) (*pb1.TestResponse, error)
type TestServiceClientAsync ¶
type TestServiceClientAsync struct {
// contains filtered or unexported fields
}
func NewRSocketTestServiceClientAsync ¶
func NewRSocketTestServiceClientAsync(selector uint64, rs rsocketgo.RSocket) *TestServiceClientAsync
func NewTestServiceClientAsync ¶
func NewTestServiceClientAsync(selector uint64, handler runtime.ClientRequestResponseHandlerAsync) *TestServiceClientAsync
func (*TestServiceClientAsync) Test ¶
func (c *TestServiceClientAsync) Test(ctx context.Context, req *pb.TestRequest) *mo.Future[*pb1.TestResponse]
type TestServiceServer ¶
type TestServiceServer struct {
// contains filtered or unexported fields
}
func NewTestServiceServer ¶
func NewTestServiceServer(selector uint64, service TestService) *TestServiceServer
func (*TestServiceServer) HandleRequestResponse ¶
func (s *TestServiceServer) HandleRequestResponse(ctx context.Context, reqWrapper *runtime.RequestWrapper) (proto.Message, error)
func (*TestServiceServer) Selector ¶
func (s *TestServiceServer) Selector() uint64
type Void ¶
type Void struct {
// contains filtered or unexported fields
}
func (*Void) Descriptor
deprecated
func (*Void) ProtoMessage ¶
func (*Void) ProtoMessage()
func (*Void) ProtoReflect ¶
func (x *Void) ProtoReflect() protoreflect.Message
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.