Versions in this module Expand all Collapse all v1 v1.0.3 Nov 5, 2024 Changes in this version + var ErrIntOverflow = fmt.Errorf("proto: integer overflow") + var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") + var File_remote_proto protoreflect.FileDescriptor + var Remote_ServiceDesc = grpc.ServiceDesc + func DRPCRegisterRemote(mux drpc.Mux, impl DRPCRemoteServer) error + func RegisterRemoteServer(s grpc.ServiceRegistrar, srv RemoteServer) + func RegisterType(v VTUnmarshaler) + type Config struct + TLSConfig *tls.Config + func NewConfig() Config + func (c Config) WithTLS(tlsconf *tls.Config) Config + type DRPCRemoteClient interface + DRPCConn func() drpc.Conn + Receive func(ctx context.Context) (DRPCRemote_ReceiveClient, error) + func NewDRPCRemoteClient(cc drpc.Conn) DRPCRemoteClient + type DRPCRemoteDescription struct + func (DRPCRemoteDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool) + func (DRPCRemoteDescription) NumMethods() int + type DRPCRemoteServer interface + Receive func(DRPCRemote_ReceiveStream) error + type DRPCRemoteUnimplementedServer struct + func (s *DRPCRemoteUnimplementedServer) Receive(DRPCRemote_ReceiveStream) error + type DRPCRemote_ReceiveClient interface + Recv func() (*Envelope, error) + Send func(*Envelope) error + type DRPCRemote_ReceiveStream interface + Recv func() (*Envelope, error) + Send func(*Envelope) error + type Deserializer interface + Deserialize func([]byte, string) (any, error) + type Envelope struct + Messages []*Message + Senders []*actor.PID + Targets []*actor.PID + TypeNames []string + func (*Envelope) Descriptor() ([]byte, []int) + func (*Envelope) ProtoMessage() + func (m *Envelope) CloneMessageVT() proto.Message + func (m *Envelope) CloneVT() *Envelope + func (m *Envelope) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Envelope) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) + func (m *Envelope) MarshalToVT(dAtA []byte) (int, error) + func (m *Envelope) MarshalToVTStrict(dAtA []byte) (int, error) + func (m *Envelope) MarshalVT() (dAtA []byte, err error) + func (m *Envelope) MarshalVTStrict() (dAtA []byte, err error) + func (m *Envelope) SizeVT() (n int) + func (m *Envelope) UnmarshalVT(dAtA []byte) error + func (this *Envelope) EqualMessageVT(thatMsg proto.Message) bool + func (this *Envelope) EqualVT(that *Envelope) bool + func (x *Envelope) GetMessages() []*Message + func (x *Envelope) GetSenders() []*actor.PID + func (x *Envelope) GetTargets() []*actor.PID + func (x *Envelope) GetTypeNames() []string + func (x *Envelope) ProtoReflect() protoreflect.Message + func (x *Envelope) Reset() + func (x *Envelope) String() string + type Message struct + Data []byte + SenderIndex int32 + TargetIndex int32 + TypeNameIndex int32 + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (m *Message) CloneMessageVT() proto.Message + func (m *Message) CloneVT() *Message + func (m *Message) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Message) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) + func (m *Message) MarshalToVT(dAtA []byte) (int, error) + func (m *Message) MarshalToVTStrict(dAtA []byte) (int, error) + func (m *Message) MarshalVT() (dAtA []byte, err error) + func (m *Message) MarshalVTStrict() (dAtA []byte, err error) + func (m *Message) SizeVT() (n int) + func (m *Message) UnmarshalVT(dAtA []byte) error + func (this *Message) EqualMessageVT(thatMsg proto.Message) bool + func (this *Message) EqualVT(that *Message) bool + func (x *Message) GetData() []byte + func (x *Message) GetSenderIndex() int32 + func (x *Message) GetTargetIndex() int32 + func (x *Message) GetTypeNameIndex() int32 + func (x *Message) ProtoReflect() protoreflect.Message + func (x *Message) Reset() + func (x *Message) String() string + type ProtoSerializer struct + func (ProtoSerializer) Deserialize(data []byte, tname string) (any, error) + func (ProtoSerializer) Serialize(msg any) ([]byte, error) + func (ProtoSerializer) TypeName(msg any) string + type Remote struct + func New(addr string, config Config) *Remote + func (r *Remote) Address() string + func (r *Remote) Send(pid *actor.PID, msg any, sender *actor.PID) + func (r *Remote) Start(e *actor.Engine) error + func (r *Remote) Stop() *sync.WaitGroup + type RemoteClient interface + Receive func(ctx context.Context, opts ...grpc.CallOption) (Remote_ReceiveClient, error) + func NewRemoteClient(cc grpc.ClientConnInterface) RemoteClient + type RemoteServer interface + Receive func(Remote_ReceiveServer) error + type Remote_ReceiveClient interface + Recv func() (*Envelope, error) + Send func(*Envelope) error + type Remote_ReceiveServer interface + Recv func() (*Envelope, error) + Send func(*Envelope) error + type Serializer interface + Serialize func(msg any) ([]byte, error) + TypeName func(any) string + type TestMessage struct + Data []byte + func (*TestMessage) Descriptor() ([]byte, []int) + func (*TestMessage) ProtoMessage() + func (m *TestMessage) CloneMessageVT() proto.Message + func (m *TestMessage) CloneVT() *TestMessage + func (m *TestMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *TestMessage) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error) + func (m *TestMessage) MarshalToVT(dAtA []byte) (int, error) + func (m *TestMessage) MarshalToVTStrict(dAtA []byte) (int, error) + func (m *TestMessage) MarshalVT() (dAtA []byte, err error) + func (m *TestMessage) MarshalVTStrict() (dAtA []byte, err error) + func (m *TestMessage) SizeVT() (n int) + func (m *TestMessage) UnmarshalVT(dAtA []byte) error + func (this *TestMessage) EqualMessageVT(thatMsg proto.Message) bool + func (this *TestMessage) EqualVT(that *TestMessage) bool + func (x *TestMessage) GetData() []byte + func (x *TestMessage) ProtoReflect() protoreflect.Message + func (x *TestMessage) Reset() + func (x *TestMessage) String() string + type UnimplementedRemoteServer struct + func (UnimplementedRemoteServer) Receive(Remote_ReceiveServer) error + type UnsafeRemoteServer interface + type VTMarshaler interface + MarshalVT func() ([]byte, error) + type VTProtoSerializer struct + func (VTProtoSerializer) Deserialize(data []byte, mtype string) (any, error) + func (VTProtoSerializer) Serialize(msg any) ([]byte, error) + func (VTProtoSerializer) TypeName(msg any) string + type VTUnmarshaler interface + UnmarshalVT func([]byte) error