Documentation ¶
Index ¶
- Variables
- type RemoteAskRequest
- func (*RemoteAskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoteAskRequest) GetRemoteMessage() *RemoteMessage
- func (x *RemoteAskRequest) GetSendTime() *timestamppb.Timestamp
- func (*RemoteAskRequest) ProtoMessage()
- func (x *RemoteAskRequest) ProtoReflect() protoreflect.Message
- func (x *RemoteAskRequest) Reset()
- func (x *RemoteAskRequest) String() string
- type RemoteAskResponse
- func (*RemoteAskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RemoteAskResponse) GetMessage() *anypb.Any
- func (*RemoteAskResponse) ProtoMessage()
- func (x *RemoteAskResponse) ProtoReflect() protoreflect.Message
- func (x *RemoteAskResponse) Reset()
- func (x *RemoteAskResponse) String() string
- type RemoteLookupRequest
- func (*RemoteLookupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoteLookupRequest) GetHost() string
- func (x *RemoteLookupRequest) GetName() string
- func (x *RemoteLookupRequest) GetPort() int32
- func (*RemoteLookupRequest) ProtoMessage()
- func (x *RemoteLookupRequest) ProtoReflect() protoreflect.Message
- func (x *RemoteLookupRequest) Reset()
- func (x *RemoteLookupRequest) String() string
- type RemoteLookupResponse
- func (*RemoteLookupResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RemoteLookupResponse) GetAddress() *v1.Address
- func (*RemoteLookupResponse) ProtoMessage()
- func (x *RemoteLookupResponse) ProtoReflect() protoreflect.Message
- func (x *RemoteLookupResponse) Reset()
- func (x *RemoteLookupResponse) String() string
- type RemoteMessage
- func (*RemoteMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RemoteMessage) GetMessage() *anypb.Any
- func (x *RemoteMessage) GetReceiver() *v1.Address
- func (x *RemoteMessage) GetSender() *v1.Address
- func (*RemoteMessage) ProtoMessage()
- func (x *RemoteMessage) ProtoReflect() protoreflect.Message
- func (x *RemoteMessage) Reset()
- func (x *RemoteMessage) String() string
- type RemoteTellRequest
- func (*RemoteTellRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoteTellRequest) GetRemoteMessage() *RemoteMessage
- func (x *RemoteTellRequest) GetSendTime() *timestamppb.Timestamp
- func (*RemoteTellRequest) ProtoMessage()
- func (x *RemoteTellRequest) ProtoReflect() protoreflect.Message
- func (x *RemoteTellRequest) Reset()
- func (x *RemoteTellRequest) String() string
- type RemoteTellResponse
- type WireActor
- func (*WireActor) Descriptor() ([]byte, []int)deprecated
- func (x *WireActor) GetActorAddress() *v1.Address
- func (x *WireActor) GetActorName() string
- func (x *WireActor) GetActorPath() string
- func (*WireActor) ProtoMessage()
- func (x *WireActor) ProtoReflect() protoreflect.Message
- func (x *WireActor) Reset()
- func (x *WireActor) String() string
Constants ¶
This section is empty.
Variables ¶
var File_internal_v1_remoting_proto protoreflect.FileDescriptor
var File_internal_v1_wireactor_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type RemoteAskRequest ¶
type RemoteAskRequest struct { // Specifies the remote message to send RemoteMessage *RemoteMessage `protobuf:"bytes,1,opt,name=remote_message,json=remoteMessage,proto3" json:"remote_message,omitempty"` // Specifies the send time SendTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=send_time,json=sendTime,proto3" json:"send_time,omitempty"` // contains filtered or unexported fields }
RemoteAsk is used to send a message to an actor remotely and expect a response immediately. With this type of message the receiver cannot communicate back to Sender except reply the message with a response. This one-way communication
func (*RemoteAskRequest) Descriptor
deprecated
func (*RemoteAskRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoteAskRequest.ProtoReflect.Descriptor instead.
func (*RemoteAskRequest) GetRemoteMessage ¶
func (x *RemoteAskRequest) GetRemoteMessage() *RemoteMessage
func (*RemoteAskRequest) GetSendTime ¶ added in v0.8.1
func (x *RemoteAskRequest) GetSendTime() *timestamppb.Timestamp
func (*RemoteAskRequest) ProtoMessage ¶
func (*RemoteAskRequest) ProtoMessage()
func (*RemoteAskRequest) ProtoReflect ¶
func (x *RemoteAskRequest) ProtoReflect() protoreflect.Message
func (*RemoteAskRequest) Reset ¶
func (x *RemoteAskRequest) Reset()
func (*RemoteAskRequest) String ¶
func (x *RemoteAskRequest) String() string
type RemoteAskResponse ¶
type RemoteAskResponse struct { // Specifies the message to send to the actor // Any proto message is allowed to be sent Message *anypb.Any `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*RemoteAskResponse) Descriptor
deprecated
func (*RemoteAskResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoteAskResponse.ProtoReflect.Descriptor instead.
func (*RemoteAskResponse) GetMessage ¶
func (x *RemoteAskResponse) GetMessage() *anypb.Any
func (*RemoteAskResponse) ProtoMessage ¶
func (*RemoteAskResponse) ProtoMessage()
func (*RemoteAskResponse) ProtoReflect ¶
func (x *RemoteAskResponse) ProtoReflect() protoreflect.Message
func (*RemoteAskResponse) Reset ¶
func (x *RemoteAskResponse) Reset()
func (*RemoteAskResponse) String ¶
func (x *RemoteAskResponse) String() string
type RemoteLookupRequest ¶
type RemoteLookupRequest struct { // Specifies the remote host address Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // Specifies the remote port Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // Specifies the actor name Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
RemoteLookupRequest checks whether a given actor exists on a remote host
func (*RemoteLookupRequest) Descriptor
deprecated
func (*RemoteLookupRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoteLookupRequest.ProtoReflect.Descriptor instead.
func (*RemoteLookupRequest) GetHost ¶
func (x *RemoteLookupRequest) GetHost() string
func (*RemoteLookupRequest) GetName ¶
func (x *RemoteLookupRequest) GetName() string
func (*RemoteLookupRequest) GetPort ¶
func (x *RemoteLookupRequest) GetPort() int32
func (*RemoteLookupRequest) ProtoMessage ¶
func (*RemoteLookupRequest) ProtoMessage()
func (*RemoteLookupRequest) ProtoReflect ¶
func (x *RemoteLookupRequest) ProtoReflect() protoreflect.Message
func (*RemoteLookupRequest) Reset ¶
func (x *RemoteLookupRequest) Reset()
func (*RemoteLookupRequest) String ¶
func (x *RemoteLookupRequest) String() string
type RemoteLookupResponse ¶
type RemoteLookupResponse struct { // Specifies the actor address Address *v1.Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
func (*RemoteLookupResponse) Descriptor
deprecated
func (*RemoteLookupResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoteLookupResponse.ProtoReflect.Descriptor instead.
func (*RemoteLookupResponse) GetAddress ¶
func (x *RemoteLookupResponse) GetAddress() *v1.Address
func (*RemoteLookupResponse) ProtoMessage ¶
func (*RemoteLookupResponse) ProtoMessage()
func (*RemoteLookupResponse) ProtoReflect ¶
func (x *RemoteLookupResponse) ProtoReflect() protoreflect.Message
func (*RemoteLookupResponse) Reset ¶
func (x *RemoteLookupResponse) Reset()
func (*RemoteLookupResponse) String ¶
func (x *RemoteLookupResponse) String() string
type RemoteMessage ¶
type RemoteMessage struct { // Specifies the sender' address Sender *v1.Address `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` // Specifies the actor address Receiver *v1.Address `protobuf:"bytes,2,opt,name=receiver,proto3" json:"receiver,omitempty"` // Specifies the message to send to the actor // Any proto message is allowed to be sent Message *anypb.Any `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
RemoteMessage will be used by Actors to communicate remotely
func (*RemoteMessage) Descriptor
deprecated
func (*RemoteMessage) Descriptor() ([]byte, []int)
Deprecated: Use RemoteMessage.ProtoReflect.Descriptor instead.
func (*RemoteMessage) GetMessage ¶
func (x *RemoteMessage) GetMessage() *anypb.Any
func (*RemoteMessage) GetReceiver ¶
func (x *RemoteMessage) GetReceiver() *v1.Address
func (*RemoteMessage) GetSender ¶
func (x *RemoteMessage) GetSender() *v1.Address
func (*RemoteMessage) ProtoMessage ¶
func (*RemoteMessage) ProtoMessage()
func (*RemoteMessage) ProtoReflect ¶
func (x *RemoteMessage) ProtoReflect() protoreflect.Message
func (*RemoteMessage) Reset ¶
func (x *RemoteMessage) Reset()
func (*RemoteMessage) String ¶
func (x *RemoteMessage) String() string
type RemoteTellRequest ¶
type RemoteTellRequest struct { // Specifies the remote message to send RemoteMessage *RemoteMessage `protobuf:"bytes,1,opt,name=remote_message,json=remoteMessage,proto3" json:"remote_message,omitempty"` // Specifies the send time SendTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=send_time,json=sendTime,proto3" json:"send_time,omitempty"` // contains filtered or unexported fields }
RemoteTell is used to send a message to an actor remotely by another actor This is the only way remote actors can interact with each other. The actor on the other line can reply to the sender by using the Sender in the message
func (*RemoteTellRequest) Descriptor
deprecated
func (*RemoteTellRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoteTellRequest.ProtoReflect.Descriptor instead.
func (*RemoteTellRequest) GetRemoteMessage ¶
func (x *RemoteTellRequest) GetRemoteMessage() *RemoteMessage
func (*RemoteTellRequest) GetSendTime ¶ added in v0.8.1
func (x *RemoteTellRequest) GetSendTime() *timestamppb.Timestamp
func (*RemoteTellRequest) ProtoMessage ¶
func (*RemoteTellRequest) ProtoMessage()
func (*RemoteTellRequest) ProtoReflect ¶
func (x *RemoteTellRequest) ProtoReflect() protoreflect.Message
func (*RemoteTellRequest) Reset ¶
func (x *RemoteTellRequest) Reset()
func (*RemoteTellRequest) String ¶
func (x *RemoteTellRequest) String() string
type RemoteTellResponse ¶
type RemoteTellResponse struct {
// contains filtered or unexported fields
}
func (*RemoteTellResponse) Descriptor
deprecated
func (*RemoteTellResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoteTellResponse.ProtoReflect.Descriptor instead.
func (*RemoteTellResponse) ProtoMessage ¶
func (*RemoteTellResponse) ProtoMessage()
func (*RemoteTellResponse) ProtoReflect ¶
func (x *RemoteTellResponse) ProtoReflect() protoreflect.Message
func (*RemoteTellResponse) Reset ¶
func (x *RemoteTellResponse) Reset()
func (*RemoteTellResponse) String ¶
func (x *RemoteTellResponse) String() string
type WireActor ¶
type WireActor struct { // Specifies the actor name. // The actor name can be either the actor FQN or an alias ActorName string `protobuf:"bytes,1,opt,name=actor_name,json=actorName,proto3" json:"actor_name,omitempty"` // Specifies the actor address ActorAddress *v1.Address `protobuf:"bytes,2,opt,name=actor_address,json=actorAddress,proto3" json:"actor_address,omitempty"` // Specifies the actor full path ActorPath string `protobuf:"bytes,3,opt,name=actor_path,json=actorPath,proto3" json:"actor_path,omitempty"` // contains filtered or unexported fields }
WireActor represents the actor information on the wire.
func (*WireActor) Descriptor
deprecated
func (*WireActor) GetActorAddress ¶
func (*WireActor) GetActorName ¶
func (*WireActor) GetActorPath ¶
func (*WireActor) ProtoMessage ¶
func (*WireActor) ProtoMessage()
func (*WireActor) ProtoReflect ¶
func (x *WireActor) ProtoReflect() protoreflect.Message