remote

package
v0.0.0-...-1c5f5a9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 18, 2023 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_remote_proto protoreflect.FileDescriptor
View Source 
var Remote_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "remote.Remote",
	HandlerType: (*RemoteServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Receive",
			Handler:       _Remote_Receive_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "remote.proto",
}

Remote_ServiceDesc is the grpc.ServiceDesc for Remote service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func DRPCRegisterRemote 

func DRPCRegisterRemote(mux drpc.Mux, impl DRPCRemoteServer) error

func RegisterRemoteServer 

func RegisterRemoteServer(s grpc.ServiceRegistrar, srv RemoteServer)

Types

type DRPCRemoteClient 

type DRPCRemoteClient interface {
	DRPCConn() drpc.Conn

	Receive(ctx context.Context) (DRPCRemote_ReceiveClient, error)
}

func NewDRPCRemoteClient 

func NewDRPCRemoteClient(cc drpc.Conn) DRPCRemoteClient

type DRPCRemoteDescription 

type DRPCRemoteDescription struct{}

func (DRPCRemoteDescription) Method 

func (DRPCRemoteDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCRemoteDescription) NumMethods 

func (DRPCRemoteDescription) NumMethods() int

type DRPCRemoteServer 

type DRPCRemoteServer interface {
	Receive(DRPCRemote_ReceiveStream) error
}

type DRPCRemoteUnimplementedServer 

type DRPCRemoteUnimplementedServer struct{}

func (*DRPCRemoteUnimplementedServer) Receive 

func (s *DRPCRemoteUnimplementedServer) Receive(DRPCRemote_ReceiveStream) error

type DRPCRemote_ReceiveClient 

type DRPCRemote_ReceiveClient interface {
	drpc.Stream
	Send(*Packet) error
	Recv() (*Packet, error)
}

type DRPCRemote_ReceiveStream 

type DRPCRemote_ReceiveStream interface {
	drpc.Stream
	Send(*Packet) error
	Recv() (*Packet, error)
}

type Deserializer 

type Deserializer interface {
	Deserialize([]byte, string) (any, error)
}

type Message 

type Message struct {
	Data          []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	TargetIndex   int32  `protobuf:"varint,2,opt,name=targetIndex,proto3" json:"targetIndex,omitempty"`
	SenderIndex   int32  `protobuf:"varint,3,opt,name=senderIndex,proto3" json:"senderIndex,omitempty"`
	TypeNameIndex int32  `protobuf:"varint,4,opt,name=typeNameIndex,proto3" json:"typeNameIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) CloneMessageVT 

func (m *Message) CloneMessageVT() proto.Message

func (*Message) CloneVT 

func (m *Message) CloneVT() *Message

func (*Message) Descriptor deprecated 

func (*Message) Descriptor() ([]byte, []int)

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) EqualMessageVT 

func (this *Message) EqualMessageVT(thatMsg proto.Message) bool

func (*Message) EqualVT 

func (this *Message) EqualVT(that *Message) bool

func (*Message) GetData 

func (x *Message) GetData() []byte

func (*Message) GetSenderIndex 

func (x *Message) GetSenderIndex() int32

func (*Message) GetTargetIndex 

func (x *Message) GetTargetIndex() int32

func (*Message) GetTypeNameIndex 

func (x *Message) GetTypeNameIndex() int32

func (*Message) MarshalToSizedBufferVT 

func (m *Message) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Message) MarshalToSizedBufferVTStrict 

func (m *Message) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Message) MarshalToVT 

func (m *Message) MarshalToVT(dAtA []byte) (int, error)

func (*Message) MarshalToVTStrict 

func (m *Message) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Message) MarshalVT 

func (m *Message) MarshalVT() (dAtA []byte, err error)

func (*Message) MarshalVTStrict 

func (m *Message) MarshalVTStrict() (dAtA []byte, err error)

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) SizeVT 

func (m *Message) SizeVT() (n int)

func (*Message) String 

func (x *Message) String() string

func (*Message) UnmarshalVT 

func (m *Message) UnmarshalVT(dAtA []byte) error

type Packet 

type Packet struct {
	TypeNames []string     `protobuf:"bytes,1,rep,name=typeNames,proto3" json:"typeNames,omitempty"`
	Targets   []*actor.PID `protobuf:"bytes,2,rep,name=targets,proto3" json:"targets,omitempty"`
	Senders   []*actor.PID `protobuf:"bytes,3,rep,name=senders,proto3" json:"senders,omitempty"`
	Messages  []*Message   `protobuf:"bytes,4,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*Packet) CloneMessageVT 

func (m *Packet) CloneMessageVT() proto.Message

func (*Packet) CloneVT 

func (m *Packet) CloneVT() *Packet

func (*Packet) Descriptor deprecated 

func (*Packet) Descriptor() ([]byte, []int)

Deprecated: Use Packet.ProtoReflect.Descriptor instead.

func (*Packet) EqualMessageVT 

func (this *Packet) EqualMessageVT(thatMsg proto.Message) bool

func (*Packet) EqualVT 

func (this *Packet) EqualVT(that *Packet) bool

func (*Packet) GetMessages 

func (x *Packet) GetMessages() []*Message

func (*Packet) GetSenders 

func (x *Packet) GetSenders() []*actor.PID

func (*Packet) GetTargets 

func (x *Packet) GetTargets() []*actor.PID

func (*Packet) GetTypeNames 

func (x *Packet) GetTypeNames() []string

func (*Packet) MarshalToSizedBufferVT 

func (m *Packet) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Packet) MarshalToSizedBufferVTStrict 

func (m *Packet) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Packet) MarshalToVT 

func (m *Packet) MarshalToVT(dAtA []byte) (int, error)

func (*Packet) MarshalToVTStrict 

func (m *Packet) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Packet) MarshalVT 

func (m *Packet) MarshalVT() (dAtA []byte, err error)

func (*Packet) MarshalVTStrict 

func (m *Packet) MarshalVTStrict() (dAtA []byte, err error)

func (*Packet) ProtoMessage 

func (*Packet) ProtoMessage()

func (*Packet) ProtoReflect 

func (x *Packet) ProtoReflect() protoreflect.Message

func (*Packet) Reset 

func (x *Packet) Reset()

func (*Packet) SizeVT 

func (m *Packet) SizeVT() (n int)

func (*Packet) String 

func (x *Packet) String() string

func (*Packet) UnmarshalVT 

func (m *Packet) UnmarshalVT(dAtA []byte) error

type ProtoDeserializer 

type ProtoDeserializer struct{}

func (ProtoDeserializer) Deserialize 

func (ProtoDeserializer) Deserialize(data []byte, name string) (any, error)

type ProtoSerializer 

type ProtoSerializer struct{}

func (ProtoSerializer) Serialize 

func (ProtoSerializer) Serialize(msg any) ([]byte, error)

func (ProtoSerializer) TypeName 

func (ProtoSerializer) TypeName(msg any) string

type RemoteClient 

type RemoteClient interface {
	Receive(ctx context.Context, opts ...grpc.CallOption) (Remote_ReceiveClient, error)
}

RemoteClient is the client API for Remote 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 NewRemoteClient 

func NewRemoteClient(cc grpc.ClientConnInterface) RemoteClient

type RemoteServer 

type RemoteServer interface {
	Receive(Remote_ReceiveServer) error
	// contains filtered or unexported methods
}

RemoteServer is the server API for Remote service. All implementations must embed UnimplementedRemoteServer for forward compatibility

type Remote_ReceiveClient 

type Remote_ReceiveClient interface {
	Send(*Packet) error
	Recv() (*Packet, error)
	grpc.ClientStream
}

type Remote_ReceiveServer 

type Remote_ReceiveServer interface {
	Send(*Packet) error
	Recv() (*Packet, error)
	grpc.ServerStream
}

type Remoter 

type Remoter struct {
	// contains filtered or unexported fields
}

func NewRemoter 

func NewRemoter(engine *actor.Engine, address string) *Remoter

func (*Remoter) Address 

func (slf *Remoter) Address() string

func (*Remoter) Send 

func (slf *Remoter) Send(target *actor.PID, msg any, sender *actor.PID)

func (*Remoter) Start 

func (slf *Remoter) Start()

type Serializer 

type Serializer interface {
	Serialize(msg any) ([]byte, error)
	TypeName(any) string
}

type UnimplementedRemoteServer 

type UnimplementedRemoteServer struct {
}

UnimplementedRemoteServer must be embedded to have forward compatible implementations.

func (UnimplementedRemoteServer) Receive 

func (UnimplementedRemoteServer) Receive(Remote_ReceiveServer) error

type UnsafeRemoteServer 

type UnsafeRemoteServer interface {
	// contains filtered or unexported methods
}

UnsafeRemoteServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RemoteServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.