Documentation ¶
Overview ¶
Package remote provides access to actors across a network or other I/O connection.
Index ¶
- Variables
- func Deserialize(message []byte, typeName string, serializerID int32) (interface{}, error)
- func NewEndpointLazy(em *endpointManager, address string) *endpointLazy
- func RegisterRemotingServer(s *grpc.Server, srv RemotingServer)
- func RegisterSerializer(serializer Serializer)
- func RegisterSerializerAsDefault(serializer Serializer)
- func Serialize(message interface{}, serializerID int32) ([]byte, string, error)
- func SetLogLevel(level log.Level)
- type ActivatorError
- type ActorPidRequest
- func (*ActorPidRequest) Descriptor() ([]byte, []int)
- func (this *ActorPidRequest) Equal(that interface{}) bool
- func (m *ActorPidRequest) GetKind() string
- func (m *ActorPidRequest) GetName() string
- func (m *ActorPidRequest) Marshal() (dAtA []byte, err error)
- func (m *ActorPidRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ActorPidRequest) ProtoMessage()
- func (m *ActorPidRequest) Reset()
- func (m *ActorPidRequest) Size() (n int)
- func (this *ActorPidRequest) String() string
- func (m *ActorPidRequest) Unmarshal(dAtA []byte) error
- func (m *ActorPidRequest) XXX_DiscardUnknown()
- func (m *ActorPidRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActorPidRequest) XXX_Merge(src proto.Message)
- func (m *ActorPidRequest) XXX_Size() int
- func (m *ActorPidRequest) XXX_Unmarshal(b []byte) error
- type ActorPidResponse
- func (*ActorPidResponse) Descriptor() ([]byte, []int)
- func (this *ActorPidResponse) Equal(that interface{}) bool
- func (m *ActorPidResponse) GetPid() *actor.PID
- func (m *ActorPidResponse) GetStatusCode() int32
- func (m *ActorPidResponse) Marshal() (dAtA []byte, err error)
- func (m *ActorPidResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ActorPidResponse) ProtoMessage()
- func (m *ActorPidResponse) Reset()
- func (m *ActorPidResponse) Size() (n int)
- func (this *ActorPidResponse) String() string
- func (m *ActorPidResponse) Unmarshal(dAtA []byte) error
- func (m *ActorPidResponse) XXX_DiscardUnknown()
- func (m *ActorPidResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActorPidResponse) XXX_Merge(src proto.Message)
- func (m *ActorPidResponse) XXX_Size() int
- func (m *ActorPidResponse) XXX_Unmarshal(b []byte) error
- type Config
- func (rc Config) Address() string
- func (rc Config) WithAdvertisedHost(address string) Config
- func (rc Config) WithCallOptions(options ...grpc.CallOption) Config
- func (rc Config) WithDialOptions(options ...grpc.DialOption) Config
- func (rc Config) WithEndpointManagerBatchSize(batchSize int) Config
- func (rc Config) WithEndpointManagerQueueSize(queueSize int) Config
- func (rc Config) WithEndpointWriterBatchSize(batchSize int) Config
- func (rc Config) WithEndpointWriterQueueSize(queueSize int) Config
- func (rc Config) WithServerOptions(options ...grpc.ServerOption) Config
- type ConnectRequest
- func (*ConnectRequest) Descriptor() ([]byte, []int)
- func (this *ConnectRequest) Equal(that interface{}) bool
- func (m *ConnectRequest) Marshal() (dAtA []byte, err error)
- func (m *ConnectRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ConnectRequest) ProtoMessage()
- func (m *ConnectRequest) Reset()
- func (m *ConnectRequest) Size() (n int)
- func (this *ConnectRequest) String() string
- func (m *ConnectRequest) Unmarshal(dAtA []byte) error
- func (m *ConnectRequest) XXX_DiscardUnknown()
- func (m *ConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectRequest) XXX_Merge(src proto.Message)
- func (m *ConnectRequest) XXX_Size() int
- func (m *ConnectRequest) XXX_Unmarshal(b []byte) error
- type ConnectResponse
- func (*ConnectResponse) Descriptor() ([]byte, []int)
- func (this *ConnectResponse) Equal(that interface{}) bool
- func (m *ConnectResponse) GetDefaultSerializerId() int32
- func (m *ConnectResponse) Marshal() (dAtA []byte, err error)
- func (m *ConnectResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ConnectResponse) ProtoMessage()
- func (m *ConnectResponse) Reset()
- func (m *ConnectResponse) Size() (n int)
- func (this *ConnectResponse) String() string
- func (m *ConnectResponse) Unmarshal(dAtA []byte) error
- func (m *ConnectResponse) XXX_DiscardUnknown()
- func (m *ConnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectResponse) XXX_Merge(src proto.Message)
- func (m *ConnectResponse) XXX_Size() int
- func (m *ConnectResponse) XXX_Unmarshal(b []byte) error
- type EndpointConnectedEvent
- type EndpointTerminatedEvent
- type JsonMessage
- type Kind
- type MessageBatch
- func (*MessageBatch) Descriptor() ([]byte, []int)
- func (this *MessageBatch) Equal(that interface{}) bool
- func (m *MessageBatch) GetEnvelopes() []*MessageEnvelope
- func (m *MessageBatch) GetTargetNames() []string
- func (m *MessageBatch) GetTypeNames() []string
- func (m *MessageBatch) Marshal() (dAtA []byte, err error)
- func (m *MessageBatch) MarshalTo(dAtA []byte) (int, error)
- func (*MessageBatch) ProtoMessage()
- func (m *MessageBatch) Reset()
- func (m *MessageBatch) Size() (n int)
- func (this *MessageBatch) String() string
- func (m *MessageBatch) Unmarshal(dAtA []byte) error
- func (m *MessageBatch) XXX_DiscardUnknown()
- func (m *MessageBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessageBatch) XXX_Merge(src proto.Message)
- func (m *MessageBatch) XXX_Size() int
- func (m *MessageBatch) XXX_Unmarshal(b []byte) error
- type MessageEnvelope
- func (*MessageEnvelope) Descriptor() ([]byte, []int)
- func (this *MessageEnvelope) Equal(that interface{}) bool
- func (m *MessageEnvelope) GetMessageData() []byte
- func (m *MessageEnvelope) GetMessageHeader() *MessageHeader
- func (m *MessageEnvelope) GetSender() *actor.PID
- func (m *MessageEnvelope) GetSerializerId() int32
- func (m *MessageEnvelope) GetTarget() int32
- func (m *MessageEnvelope) GetTypeId() int32
- func (m *MessageEnvelope) Marshal() (dAtA []byte, err error)
- func (m *MessageEnvelope) MarshalTo(dAtA []byte) (int, error)
- func (*MessageEnvelope) ProtoMessage()
- func (m *MessageEnvelope) Reset()
- func (m *MessageEnvelope) Size() (n int)
- func (this *MessageEnvelope) String() string
- func (m *MessageEnvelope) Unmarshal(dAtA []byte) error
- func (m *MessageEnvelope) XXX_DiscardUnknown()
- func (m *MessageEnvelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessageEnvelope) XXX_Merge(src proto.Message)
- func (m *MessageEnvelope) XXX_Size() int
- func (m *MessageEnvelope) XXX_Unmarshal(b []byte) error
- type MessageHeader
- func (*MessageHeader) Descriptor() ([]byte, []int)
- func (this *MessageHeader) Equal(that interface{}) bool
- func (m *MessageHeader) GetHeaderData() map[string]string
- func (m *MessageHeader) Marshal() (dAtA []byte, err error)
- func (m *MessageHeader) MarshalTo(dAtA []byte) (int, error)
- func (*MessageHeader) ProtoMessage()
- func (m *MessageHeader) Reset()
- func (m *MessageHeader) Size() (n int)
- func (this *MessageHeader) String() string
- func (m *MessageHeader) Unmarshal(dAtA []byte) error
- func (m *MessageHeader) XXX_DiscardUnknown()
- func (m *MessageHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MessageHeader) XXX_Merge(src proto.Message)
- func (m *MessageHeader) XXX_Size() int
- func (m *MessageHeader) XXX_Unmarshal(b []byte) error
- type Ping
- type Pong
- type Remote
- func (r *Remote) ActivatorForAddress(address string) *actor.PID
- func (r *Remote) GetKnownKinds() []string
- func (r *Remote) Id() extensions.ExtensionId
- func (r *Remote) Register(kind string, props *actor.Props)
- func (r *Remote) SendMessage(pid *actor.PID, header actor.ReadonlyMessageHeader, message interface{}, ...)
- func (r *Remote) Shutdown(graceful bool)
- func (r *Remote) Spawn(address, kind string, timeout time.Duration) (*ActorPidResponse, error)
- func (r *Remote) SpawnFuture(address, name, kind string, timeout time.Duration) *actor.Future
- func (r *Remote) SpawnNamed(address, name, kind string, timeout time.Duration) (*ActorPidResponse, error)
- func (r *Remote) Start()
- type RemotingClient
- type RemotingServer
- type Remoting_ReceiveClient
- type Remoting_ReceiveServer
- type ResponseError
- type ResponseStatusCode
- type Serializer
- type Unit
- func (*Unit) Descriptor() ([]byte, []int)
- func (this *Unit) Equal(that interface{}) bool
- func (m *Unit) Marshal() (dAtA []byte, err error)
- func (m *Unit) MarshalTo(dAtA []byte) (int, error)
- func (*Unit) ProtoMessage()
- func (m *Unit) Reset()
- func (m *Unit) Size() (n int)
- func (this *Unit) String() string
- func (m *Unit) Unmarshal(dAtA []byte) error
- func (m *Unit) XXX_DiscardUnknown()
- func (m *Unit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Unit) XXX_Merge(src proto.Message)
- func (m *Unit) XXX_Size() int
- func (m *Unit) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrUnAvailable = &ResponseError{ResponseStatusCodeUNAVAILABLE} ErrTimeout = &ResponseError{ResponseStatusCodeTIMEOUT} ErrProcessNameAlreadyExist = &ResponseError{ResponseStatusCodePROCESSNAMEALREADYEXIST} ErrDeadLetter = &ResponseError{ResponseStatusCodeDeadLetter} ErrUnknownError = &ResponseError{ResponseStatusCodeERROR} )
var ( ActorPidRespErr interface{} = &ActorPidResponse{StatusCode: ResponseStatusCodeERROR.ToInt32()} ActorPidRespTimeout interface{} = &ActorPidResponse{StatusCode: ResponseStatusCodeTIMEOUT.ToInt32()} )
var ( ErrInvalidLengthProtos = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowProtos = fmt.Errorf("proto: integer overflow") )
var DefaultSerializerID int32
ErrActivatorUnavailable : this error will not panic the Activator. It simply tells Partition this Activator is not available Partition will then find next available Activator to spawn
Functions ¶
func Deserialize ¶
func NewEndpointLazy ¶
func NewEndpointLazy(em *endpointManager, address string) *endpointLazy
func RegisterRemotingServer ¶
func RegisterRemotingServer(s *grpc.Server, srv RemotingServer)
func RegisterSerializer ¶
func RegisterSerializer(serializer Serializer)
func RegisterSerializerAsDefault ¶
func RegisterSerializerAsDefault(serializer Serializer)
func SetLogLevel ¶
SetLogLevel sets the log level for the logger.
SetLogLevel is safe to call concurrently
Types ¶
type ActivatorError ¶
func (*ActivatorError) Error ¶
func (e *ActivatorError) Error() string
type ActorPidRequest ¶
type ActorPidRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"` }
func (*ActorPidRequest) Descriptor ¶
func (*ActorPidRequest) Descriptor() ([]byte, []int)
func (*ActorPidRequest) Equal ¶
func (this *ActorPidRequest) Equal(that interface{}) bool
func (*ActorPidRequest) GetKind ¶
func (m *ActorPidRequest) GetKind() string
func (*ActorPidRequest) GetName ¶
func (m *ActorPidRequest) GetName() string
func (*ActorPidRequest) Marshal ¶
func (m *ActorPidRequest) Marshal() (dAtA []byte, err error)
func (*ActorPidRequest) ProtoMessage ¶
func (*ActorPidRequest) ProtoMessage()
func (*ActorPidRequest) Reset ¶
func (m *ActorPidRequest) Reset()
func (*ActorPidRequest) Size ¶
func (m *ActorPidRequest) Size() (n int)
func (*ActorPidRequest) String ¶
func (this *ActorPidRequest) String() string
func (*ActorPidRequest) Unmarshal ¶
func (m *ActorPidRequest) Unmarshal(dAtA []byte) error
func (*ActorPidRequest) XXX_DiscardUnknown ¶
func (m *ActorPidRequest) XXX_DiscardUnknown()
func (*ActorPidRequest) XXX_Marshal ¶
func (m *ActorPidRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActorPidRequest) XXX_Merge ¶
func (m *ActorPidRequest) XXX_Merge(src proto.Message)
func (*ActorPidRequest) XXX_Size ¶
func (m *ActorPidRequest) XXX_Size() int
func (*ActorPidRequest) XXX_Unmarshal ¶
func (m *ActorPidRequest) XXX_Unmarshal(b []byte) error
type ActorPidResponse ¶
type ActorPidResponse struct { Pid *actor.PID `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"` StatusCode int32 `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"` }
func (*ActorPidResponse) Descriptor ¶
func (*ActorPidResponse) Descriptor() ([]byte, []int)
func (*ActorPidResponse) Equal ¶
func (this *ActorPidResponse) Equal(that interface{}) bool
func (*ActorPidResponse) GetPid ¶
func (m *ActorPidResponse) GetPid() *actor.PID
func (*ActorPidResponse) GetStatusCode ¶
func (m *ActorPidResponse) GetStatusCode() int32
func (*ActorPidResponse) Marshal ¶
func (m *ActorPidResponse) Marshal() (dAtA []byte, err error)
func (*ActorPidResponse) ProtoMessage ¶
func (*ActorPidResponse) ProtoMessage()
func (*ActorPidResponse) Reset ¶
func (m *ActorPidResponse) Reset()
func (*ActorPidResponse) Size ¶
func (m *ActorPidResponse) Size() (n int)
func (*ActorPidResponse) String ¶
func (this *ActorPidResponse) String() string
func (*ActorPidResponse) Unmarshal ¶
func (m *ActorPidResponse) Unmarshal(dAtA []byte) error
func (*ActorPidResponse) XXX_DiscardUnknown ¶
func (m *ActorPidResponse) XXX_DiscardUnknown()
func (*ActorPidResponse) XXX_Marshal ¶
func (m *ActorPidResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActorPidResponse) XXX_Merge ¶
func (m *ActorPidResponse) XXX_Merge(src proto.Message)
func (*ActorPidResponse) XXX_Size ¶
func (m *ActorPidResponse) XXX_Size() int
func (*ActorPidResponse) XXX_Unmarshal ¶
func (m *ActorPidResponse) XXX_Unmarshal(b []byte) error
type Config ¶
type Config struct { Host string Port int AdvertisedHost string ServerOptions []grpc.ServerOption CallOptions []grpc.CallOption DialOptions []grpc.DialOption EndpointWriterBatchSize int EndpointWriterQueueSize int EndpointManagerBatchSize int EndpointManagerQueueSize int Kinds map[string]*actor.Props }
func (Config) WithAdvertisedHost ¶
func (Config) WithCallOptions ¶
func (rc Config) WithCallOptions(options ...grpc.CallOption) Config
func (Config) WithDialOptions ¶
func (rc Config) WithDialOptions(options ...grpc.DialOption) Config
func (Config) WithEndpointManagerBatchSize ¶
func (Config) WithEndpointManagerQueueSize ¶
func (Config) WithEndpointWriterBatchSize ¶
func (Config) WithEndpointWriterQueueSize ¶
func (Config) WithServerOptions ¶
func (rc Config) WithServerOptions(options ...grpc.ServerOption) Config
type ConnectRequest ¶
type ConnectRequest struct { }
func (*ConnectRequest) Descriptor ¶
func (*ConnectRequest) Descriptor() ([]byte, []int)
func (*ConnectRequest) Equal ¶
func (this *ConnectRequest) Equal(that interface{}) bool
func (*ConnectRequest) Marshal ¶
func (m *ConnectRequest) Marshal() (dAtA []byte, err error)
func (*ConnectRequest) ProtoMessage ¶
func (*ConnectRequest) ProtoMessage()
func (*ConnectRequest) Reset ¶
func (m *ConnectRequest) Reset()
func (*ConnectRequest) Size ¶
func (m *ConnectRequest) Size() (n int)
func (*ConnectRequest) String ¶
func (this *ConnectRequest) String() string
func (*ConnectRequest) Unmarshal ¶
func (m *ConnectRequest) Unmarshal(dAtA []byte) error
func (*ConnectRequest) XXX_DiscardUnknown ¶
func (m *ConnectRequest) XXX_DiscardUnknown()
func (*ConnectRequest) XXX_Marshal ¶
func (m *ConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectRequest) XXX_Merge ¶
func (m *ConnectRequest) XXX_Merge(src proto.Message)
func (*ConnectRequest) XXX_Size ¶
func (m *ConnectRequest) XXX_Size() int
func (*ConnectRequest) XXX_Unmarshal ¶
func (m *ConnectRequest) XXX_Unmarshal(b []byte) error
type ConnectResponse ¶
type ConnectResponse struct {
DefaultSerializerId int32 `protobuf:"varint,1,opt,name=default_serializer_id,json=defaultSerializerId,proto3" json:"default_serializer_id,omitempty"`
}
func (*ConnectResponse) Descriptor ¶
func (*ConnectResponse) Descriptor() ([]byte, []int)
func (*ConnectResponse) Equal ¶
func (this *ConnectResponse) Equal(that interface{}) bool
func (*ConnectResponse) GetDefaultSerializerId ¶
func (m *ConnectResponse) GetDefaultSerializerId() int32
func (*ConnectResponse) Marshal ¶
func (m *ConnectResponse) Marshal() (dAtA []byte, err error)
func (*ConnectResponse) ProtoMessage ¶
func (*ConnectResponse) ProtoMessage()
func (*ConnectResponse) Reset ¶
func (m *ConnectResponse) Reset()
func (*ConnectResponse) Size ¶
func (m *ConnectResponse) Size() (n int)
func (*ConnectResponse) String ¶
func (this *ConnectResponse) String() string
func (*ConnectResponse) Unmarshal ¶
func (m *ConnectResponse) Unmarshal(dAtA []byte) error
func (*ConnectResponse) XXX_DiscardUnknown ¶
func (m *ConnectResponse) XXX_DiscardUnknown()
func (*ConnectResponse) XXX_Marshal ¶
func (m *ConnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectResponse) XXX_Merge ¶
func (m *ConnectResponse) XXX_Merge(src proto.Message)
func (*ConnectResponse) XXX_Size ¶
func (m *ConnectResponse) XXX_Size() int
func (*ConnectResponse) XXX_Unmarshal ¶
func (m *ConnectResponse) XXX_Unmarshal(b []byte) error
type EndpointConnectedEvent ¶
type EndpointConnectedEvent struct {
Address string
}
type EndpointTerminatedEvent ¶
type EndpointTerminatedEvent struct {
Address string
}
type JsonMessage ¶
type MessageBatch ¶
type MessageBatch struct { TypeNames []string `protobuf:"bytes,1,rep,name=type_names,json=typeNames,proto3" json:"type_names,omitempty"` TargetNames []string `protobuf:"bytes,2,rep,name=target_names,json=targetNames,proto3" json:"target_names,omitempty"` Envelopes []*MessageEnvelope `protobuf:"bytes,3,rep,name=envelopes,proto3" json:"envelopes,omitempty"` }
func (*MessageBatch) Descriptor ¶
func (*MessageBatch) Descriptor() ([]byte, []int)
func (*MessageBatch) Equal ¶
func (this *MessageBatch) Equal(that interface{}) bool
func (*MessageBatch) GetEnvelopes ¶
func (m *MessageBatch) GetEnvelopes() []*MessageEnvelope
func (*MessageBatch) GetTargetNames ¶
func (m *MessageBatch) GetTargetNames() []string
func (*MessageBatch) GetTypeNames ¶
func (m *MessageBatch) GetTypeNames() []string
func (*MessageBatch) Marshal ¶
func (m *MessageBatch) Marshal() (dAtA []byte, err error)
func (*MessageBatch) ProtoMessage ¶
func (*MessageBatch) ProtoMessage()
func (*MessageBatch) Reset ¶
func (m *MessageBatch) Reset()
func (*MessageBatch) Size ¶
func (m *MessageBatch) Size() (n int)
func (*MessageBatch) String ¶
func (this *MessageBatch) String() string
func (*MessageBatch) Unmarshal ¶
func (m *MessageBatch) Unmarshal(dAtA []byte) error
func (*MessageBatch) XXX_DiscardUnknown ¶
func (m *MessageBatch) XXX_DiscardUnknown()
func (*MessageBatch) XXX_Marshal ¶
func (m *MessageBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageBatch) XXX_Merge ¶
func (m *MessageBatch) XXX_Merge(src proto.Message)
func (*MessageBatch) XXX_Size ¶
func (m *MessageBatch) XXX_Size() int
func (*MessageBatch) XXX_Unmarshal ¶
func (m *MessageBatch) XXX_Unmarshal(b []byte) error
type MessageEnvelope ¶
type MessageEnvelope struct { TypeId int32 `protobuf:"varint,1,opt,name=type_id,json=typeId,proto3" json:"type_id,omitempty"` MessageData []byte `protobuf:"bytes,2,opt,name=message_data,json=messageData,proto3" json:"message_data,omitempty"` Target int32 `protobuf:"varint,3,opt,name=target,proto3" json:"target,omitempty"` Sender *actor.PID `protobuf:"bytes,4,opt,name=sender,proto3" json:"sender,omitempty"` SerializerId int32 `protobuf:"varint,5,opt,name=serializer_id,json=serializerId,proto3" json:"serializer_id,omitempty"` MessageHeader *MessageHeader `protobuf:"bytes,6,opt,name=message_header,json=messageHeader,proto3" json:"message_header,omitempty"` }
func (*MessageEnvelope) Descriptor ¶
func (*MessageEnvelope) Descriptor() ([]byte, []int)
func (*MessageEnvelope) Equal ¶
func (this *MessageEnvelope) Equal(that interface{}) bool
func (*MessageEnvelope) GetMessageData ¶
func (m *MessageEnvelope) GetMessageData() []byte
func (*MessageEnvelope) GetMessageHeader ¶
func (m *MessageEnvelope) GetMessageHeader() *MessageHeader
func (*MessageEnvelope) GetSender ¶
func (m *MessageEnvelope) GetSender() *actor.PID
func (*MessageEnvelope) GetSerializerId ¶
func (m *MessageEnvelope) GetSerializerId() int32
func (*MessageEnvelope) GetTarget ¶
func (m *MessageEnvelope) GetTarget() int32
func (*MessageEnvelope) GetTypeId ¶
func (m *MessageEnvelope) GetTypeId() int32
func (*MessageEnvelope) Marshal ¶
func (m *MessageEnvelope) Marshal() (dAtA []byte, err error)
func (*MessageEnvelope) ProtoMessage ¶
func (*MessageEnvelope) ProtoMessage()
func (*MessageEnvelope) Reset ¶
func (m *MessageEnvelope) Reset()
func (*MessageEnvelope) Size ¶
func (m *MessageEnvelope) Size() (n int)
func (*MessageEnvelope) String ¶
func (this *MessageEnvelope) String() string
func (*MessageEnvelope) Unmarshal ¶
func (m *MessageEnvelope) Unmarshal(dAtA []byte) error
func (*MessageEnvelope) XXX_DiscardUnknown ¶
func (m *MessageEnvelope) XXX_DiscardUnknown()
func (*MessageEnvelope) XXX_Marshal ¶
func (m *MessageEnvelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageEnvelope) XXX_Merge ¶
func (m *MessageEnvelope) XXX_Merge(src proto.Message)
func (*MessageEnvelope) XXX_Size ¶
func (m *MessageEnvelope) XXX_Size() int
func (*MessageEnvelope) XXX_Unmarshal ¶
func (m *MessageEnvelope) XXX_Unmarshal(b []byte) error
type MessageHeader ¶
type MessageHeader struct {
HeaderData map[string]string `` /* 179-byte string literal not displayed */
}
func (*MessageHeader) Descriptor ¶
func (*MessageHeader) Descriptor() ([]byte, []int)
func (*MessageHeader) Equal ¶
func (this *MessageHeader) Equal(that interface{}) bool
func (*MessageHeader) GetHeaderData ¶
func (m *MessageHeader) GetHeaderData() map[string]string
func (*MessageHeader) Marshal ¶
func (m *MessageHeader) Marshal() (dAtA []byte, err error)
func (*MessageHeader) ProtoMessage ¶
func (*MessageHeader) ProtoMessage()
func (*MessageHeader) Reset ¶
func (m *MessageHeader) Reset()
func (*MessageHeader) Size ¶
func (m *MessageHeader) Size() (n int)
func (*MessageHeader) String ¶
func (this *MessageHeader) String() string
func (*MessageHeader) Unmarshal ¶
func (m *MessageHeader) Unmarshal(dAtA []byte) error
func (*MessageHeader) XXX_DiscardUnknown ¶
func (m *MessageHeader) XXX_DiscardUnknown()
func (*MessageHeader) XXX_Marshal ¶
func (m *MessageHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageHeader) XXX_Merge ¶
func (m *MessageHeader) XXX_Merge(src proto.Message)
func (*MessageHeader) XXX_Size ¶
func (m *MessageHeader) XXX_Size() int
func (*MessageHeader) XXX_Unmarshal ¶
func (m *MessageHeader) XXX_Unmarshal(b []byte) error
type Ping ¶
type Ping struct{}
Ping is message sent by the actor system to probe an actor is started.
type Remote ¶
type Remote struct {
// contains filtered or unexported fields
}
func GetRemote ¶
func GetRemote(actorSystem *actor.ActorSystem) *Remote
func (*Remote) ActivatorForAddress ¶
ActivatorForAddress returns a PID for the activator at the given address
func (*Remote) GetKnownKinds ¶
GetKnownKinds returns a slice of known actor "Kinds"
func (*Remote) Id ¶
func (r *Remote) Id() extensions.ExtensionId
func (*Remote) SendMessage ¶
func (*Remote) SpawnFuture ¶
SpawnFuture spawns a remote actor and returns a Future that completes once the actor is started
func (*Remote) SpawnNamed ¶
func (r *Remote) SpawnNamed(address, name, kind string, timeout time.Duration) (*ActorPidResponse, error)
SpawnNamed spawns a named remote actor of a given type at a given address
type RemotingClient ¶
type RemotingClient interface { Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error) Receive(ctx context.Context, opts ...grpc.CallOption) (Remoting_ReceiveClient, error) }
RemotingClient is the client API for Remoting service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRemotingClient ¶
func NewRemotingClient(cc *grpc.ClientConn) RemotingClient
type RemotingServer ¶
type RemotingServer interface { Connect(context.Context, *ConnectRequest) (*ConnectResponse, error) Receive(Remoting_ReceiveServer) error }
RemotingServer is the server API for Remoting service.
type Remoting_ReceiveClient ¶
type Remoting_ReceiveClient interface { Send(*MessageBatch) error Recv() (*Unit, error) grpc.ClientStream }
type Remoting_ReceiveServer ¶
type Remoting_ReceiveServer interface { Send(*Unit) error Recv() (*MessageBatch, error) grpc.ServerStream }
type ResponseError ¶
type ResponseError struct {
Code ResponseStatusCode
}
ResponseError is an error type. e.g.:
var err = &ResponseError{1}
func (*ResponseError) Error ¶
func (r *ResponseError) Error() string
type ResponseStatusCode ¶
type ResponseStatusCode int32
const ( ResponseStatusCodeOK ResponseStatusCode = iota ResponseStatusCodeUNAVAILABLE ResponseStatusCodeTIMEOUT ResponseStatusCodePROCESSNAMEALREADYEXIST ResponseStatusCodeERROR ResponseStatusCodeDeadLetter ResponseStatusCodeMAX // just a boundary. )
func (ResponseStatusCode) AsError ¶
func (c ResponseStatusCode) AsError() *ResponseError
func (ResponseStatusCode) String ¶
func (c ResponseStatusCode) String() string
func (ResponseStatusCode) ToInt32 ¶
func (c ResponseStatusCode) ToInt32() int32
type Serializer ¶
type Unit ¶
type Unit struct { }
func (*Unit) Descriptor ¶
func (*Unit) ProtoMessage ¶
func (*Unit) ProtoMessage()
func (*Unit) XXX_DiscardUnknown ¶
func (m *Unit) XXX_DiscardUnknown()
func (*Unit) XXX_Unmarshal ¶
Source Files ¶
- activator_actor.go
- config.go
- doc.go
- endpoint_manager.go
- endpoint_reader.go
- endpoint_watcher.go
- endpoint_writer.go
- endpoint_writer_mailbox.go
- errors.go
- json_serializer.go
- log.go
- messages.go
- proto_serializer.go
- protos.pb.go
- remote_handler.go
- remote_process.go
- response_status_code.go
- serializer.go
- server.go