Documentation
¶
Index ¶
- Constants
- func NewSRPCPrototypeServiceHandler(impl SRPCPrototypeServiceServer, serviceID string) srpc.Handler
- func SRPCRegisterPrototypeService(mux srpc.Mux, impl SRPCPrototypeServiceServer) error
- type PrototypeRequest
- func (m *PrototypeRequest) CloneMessageVT() protobuf_go_lite.CloneMessage
- func (m *PrototypeRequest) CloneVT() *PrototypeRequest
- func (this *PrototypeRequest) EqualMessageVT(thatMsg any) bool
- func (this *PrototypeRequest) EqualVT(that *PrototypeRequest) bool
- func (x *PrototypeRequest) GetBody() string
- func (x *PrototypeRequest) MarshalJSON() ([]byte, error)
- func (x *PrototypeRequest) MarshalProtoJSON(s *json.MarshalState)
- func (x *PrototypeRequest) MarshalProtoText() string
- func (m *PrototypeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PrototypeRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *PrototypeRequest) MarshalVT() (dAtA []byte, err error)
- func (*PrototypeRequest) ProtoMessage()
- func (x *PrototypeRequest) Reset()
- func (m *PrototypeRequest) SizeVT() (n int)
- func (x *PrototypeRequest) String() string
- func (x *PrototypeRequest) UnmarshalJSON(b []byte) error
- func (x *PrototypeRequest) UnmarshalProtoJSON(s *json.UnmarshalState)
- func (m *PrototypeRequest) UnmarshalVT(dAtA []byte) error
- type PrototypeResponse
- func (m *PrototypeResponse) CloneMessageVT() protobuf_go_lite.CloneMessage
- func (m *PrototypeResponse) CloneVT() *PrototypeResponse
- func (this *PrototypeResponse) EqualMessageVT(thatMsg any) bool
- func (this *PrototypeResponse) EqualVT(that *PrototypeResponse) bool
- func (x *PrototypeResponse) GetBody() string
- func (x *PrototypeResponse) GetSequenceNumber() int32
- func (x *PrototypeResponse) MarshalJSON() ([]byte, error)
- func (x *PrototypeResponse) MarshalProtoJSON(s *json.MarshalState)
- func (x *PrototypeResponse) MarshalProtoText() string
- func (m *PrototypeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PrototypeResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *PrototypeResponse) MarshalVT() (dAtA []byte, err error)
- func (*PrototypeResponse) ProtoMessage()
- func (x *PrototypeResponse) Reset()
- func (m *PrototypeResponse) SizeVT() (n int)
- func (x *PrototypeResponse) String() string
- func (x *PrototypeResponse) UnmarshalJSON(b []byte) error
- func (x *PrototypeResponse) UnmarshalProtoJSON(s *json.UnmarshalState)
- func (m *PrototypeResponse) UnmarshalVT(dAtA []byte) error
- type SRPCPrototypeServiceClient
- type SRPCPrototypeServiceHandler
- func (SRPCPrototypeServiceHandler) GetMethodIDs() []string
- func (d *SRPCPrototypeServiceHandler) GetServiceID() string
- func (d *SRPCPrototypeServiceHandler) InvokeMethod(serviceID, methodID string, strm srpc.Stream) (bool, error)
- func (SRPCPrototypeServiceHandler) InvokeMethod_Prototype(impl SRPCPrototypeServiceServer, strm srpc.Stream) error
- type SRPCPrototypeServiceServer
- type SRPCPrototypeService_PrototypeClient
- type SRPCPrototypeService_PrototypeStream
Constants ¶
const SRPCPrototypeServiceServiceID = "prototype.webworker_rpcstream.common.PrototypeService"
Variables ¶
This section is empty.
Functions ¶
func NewSRPCPrototypeServiceHandler ¶
func NewSRPCPrototypeServiceHandler(impl SRPCPrototypeServiceServer, serviceID string) srpc.Handler
NewSRPCPrototypeServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: prototype.webworker_rpcstream.common.PrototypeService
func SRPCRegisterPrototypeService ¶
func SRPCRegisterPrototypeService(mux srpc.Mux, impl SRPCPrototypeServiceServer) error
SRPCRegisterPrototypeService registers the implementation with the mux. Uses the default serviceID: prototype.webworker_rpcstream.common.PrototypeService
Types ¶
type PrototypeRequest ¶
type PrototypeRequest struct {
Body string `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
// contains filtered or unexported fields
}
PrototypeRequest is the request message for the Prototype RPC.
func (*PrototypeRequest) CloneMessageVT ¶
func (m *PrototypeRequest) CloneMessageVT() protobuf_go_lite.CloneMessage
func (*PrototypeRequest) CloneVT ¶
func (m *PrototypeRequest) CloneVT() *PrototypeRequest
func (*PrototypeRequest) EqualMessageVT ¶
func (this *PrototypeRequest) EqualMessageVT(thatMsg any) bool
func (*PrototypeRequest) EqualVT ¶
func (this *PrototypeRequest) EqualVT(that *PrototypeRequest) bool
func (*PrototypeRequest) GetBody ¶
func (x *PrototypeRequest) GetBody() string
func (*PrototypeRequest) MarshalJSON ¶
func (x *PrototypeRequest) MarshalJSON() ([]byte, error)
MarshalJSON marshals the PrototypeRequest to JSON.
func (*PrototypeRequest) MarshalProtoJSON ¶
func (x *PrototypeRequest) MarshalProtoJSON(s *json.MarshalState)
MarshalProtoJSON marshals the PrototypeRequest message to JSON.
func (*PrototypeRequest) MarshalProtoText ¶
func (x *PrototypeRequest) MarshalProtoText() string
func (*PrototypeRequest) MarshalToSizedBufferVT ¶
func (m *PrototypeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*PrototypeRequest) MarshalToVT ¶
func (m *PrototypeRequest) MarshalToVT(dAtA []byte) (int, error)
func (*PrototypeRequest) MarshalVT ¶
func (m *PrototypeRequest) MarshalVT() (dAtA []byte, err error)
func (*PrototypeRequest) ProtoMessage ¶
func (*PrototypeRequest) ProtoMessage()
func (*PrototypeRequest) Reset ¶
func (x *PrototypeRequest) Reset()
func (*PrototypeRequest) SizeVT ¶
func (m *PrototypeRequest) SizeVT() (n int)
func (*PrototypeRequest) String ¶
func (x *PrototypeRequest) String() string
func (*PrototypeRequest) UnmarshalJSON ¶
func (x *PrototypeRequest) UnmarshalJSON(b []byte) error
UnmarshalJSON unmarshals the PrototypeRequest from JSON.
func (*PrototypeRequest) UnmarshalProtoJSON ¶
func (x *PrototypeRequest) UnmarshalProtoJSON(s *json.UnmarshalState)
UnmarshalProtoJSON unmarshals the PrototypeRequest message from JSON.
func (*PrototypeRequest) UnmarshalVT ¶
func (m *PrototypeRequest) UnmarshalVT(dAtA []byte) error
type PrototypeResponse ¶
type PrototypeResponse struct {
Body string `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
SequenceNumber int32 `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequenceNumber,omitempty"`
// contains filtered or unexported fields
}
PrototypeResponse is the response message for the Prototype RPC.
func (*PrototypeResponse) CloneMessageVT ¶
func (m *PrototypeResponse) CloneMessageVT() protobuf_go_lite.CloneMessage
func (*PrototypeResponse) CloneVT ¶
func (m *PrototypeResponse) CloneVT() *PrototypeResponse
func (*PrototypeResponse) EqualMessageVT ¶
func (this *PrototypeResponse) EqualMessageVT(thatMsg any) bool
func (*PrototypeResponse) EqualVT ¶
func (this *PrototypeResponse) EqualVT(that *PrototypeResponse) bool
func (*PrototypeResponse) GetBody ¶
func (x *PrototypeResponse) GetBody() string
func (*PrototypeResponse) GetSequenceNumber ¶
func (x *PrototypeResponse) GetSequenceNumber() int32
func (*PrototypeResponse) MarshalJSON ¶
func (x *PrototypeResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshals the PrototypeResponse to JSON.
func (*PrototypeResponse) MarshalProtoJSON ¶
func (x *PrototypeResponse) MarshalProtoJSON(s *json.MarshalState)
MarshalProtoJSON marshals the PrototypeResponse message to JSON.
func (*PrototypeResponse) MarshalProtoText ¶
func (x *PrototypeResponse) MarshalProtoText() string
func (*PrototypeResponse) MarshalToSizedBufferVT ¶
func (m *PrototypeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*PrototypeResponse) MarshalToVT ¶
func (m *PrototypeResponse) MarshalToVT(dAtA []byte) (int, error)
func (*PrototypeResponse) MarshalVT ¶
func (m *PrototypeResponse) MarshalVT() (dAtA []byte, err error)
func (*PrototypeResponse) ProtoMessage ¶
func (*PrototypeResponse) ProtoMessage()
func (*PrototypeResponse) Reset ¶
func (x *PrototypeResponse) Reset()
func (*PrototypeResponse) SizeVT ¶
func (m *PrototypeResponse) SizeVT() (n int)
func (*PrototypeResponse) String ¶
func (x *PrototypeResponse) String() string
func (*PrototypeResponse) UnmarshalJSON ¶
func (x *PrototypeResponse) UnmarshalJSON(b []byte) error
UnmarshalJSON unmarshals the PrototypeResponse from JSON.
func (*PrototypeResponse) UnmarshalProtoJSON ¶
func (x *PrototypeResponse) UnmarshalProtoJSON(s *json.UnmarshalState)
UnmarshalProtoJSON unmarshals the PrototypeResponse message from JSON.
func (*PrototypeResponse) UnmarshalVT ¶
func (m *PrototypeResponse) UnmarshalVT(dAtA []byte) error
type SRPCPrototypeServiceClient ¶
type SRPCPrototypeServiceClient interface {
// SRPCClient returns the underlying SRPC client.
SRPCClient() srpc.Client
// Prototype is the prototype request.
Prototype(ctx context.Context, in *PrototypeRequest) (SRPCPrototypeService_PrototypeClient, error)
}
func NewSRPCPrototypeServiceClient ¶
func NewSRPCPrototypeServiceClient(cc srpc.Client) SRPCPrototypeServiceClient
func NewSRPCPrototypeServiceClientWithServiceID ¶
func NewSRPCPrototypeServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCPrototypeServiceClient
type SRPCPrototypeServiceHandler ¶
type SRPCPrototypeServiceHandler struct {
// contains filtered or unexported fields
}
func (SRPCPrototypeServiceHandler) GetMethodIDs ¶
func (SRPCPrototypeServiceHandler) GetMethodIDs() []string
func (*SRPCPrototypeServiceHandler) GetServiceID ¶
func (d *SRPCPrototypeServiceHandler) GetServiceID() string
func (*SRPCPrototypeServiceHandler) InvokeMethod ¶
func (SRPCPrototypeServiceHandler) InvokeMethod_Prototype ¶
func (SRPCPrototypeServiceHandler) InvokeMethod_Prototype(impl SRPCPrototypeServiceServer, strm srpc.Stream) error
type SRPCPrototypeServiceServer ¶
type SRPCPrototypeServiceServer interface {
// Prototype is the prototype request.
Prototype(*PrototypeRequest, SRPCPrototypeService_PrototypeStream) error
}
type SRPCPrototypeService_PrototypeClient ¶
type SRPCPrototypeService_PrototypeClient interface {
srpc.Stream
Recv() (*PrototypeResponse, error)
RecvTo(*PrototypeResponse) error
}
type SRPCPrototypeService_PrototypeStream ¶
type SRPCPrototypeService_PrototypeStream interface {
srpc.Stream
Send(*PrototypeResponse) error
SendAndClose(*PrototypeResponse) error
}