Versions in this module Expand all Collapse all v1 v1.0.2 Aug 21, 2020 Changes in this version + var ActorPidRespErr interface{} = &ActorPidResponse + var ActorPidRespTimeout interface{} = &ActorPidResponse + var ActorPidRespUnavailable interface{} = &ActorPidResponse + var DefaultSerializerID int32 = 0 + var ErrActivatorUnavailable = &ActivatorError + var ErrIntOverflowProtos = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthProtos = fmt.Errorf("proto: negative length found during unmarshaling") + func ActivatorForAddress(address string) *actor.PID + func Deserialize(message []byte, typeName string, serializerID int32) (interface{}, error) + func GetKnownKinds() []string + func Register(kind string, props *actor.Props) + func RegisterRemotingServer(s *grpc.Server, srv RemotingServer) + func RegisterSerializer(serializer Serializer) + func RegisterSerializerAsDefault(serializer Serializer) + func SendMessage(pid *actor.PID, header actor.ReadonlyMessageHeader, message interface{}, ...) + func Serialize(message interface{}, serializerID int32) ([]byte, string, error) + func Shutdown(graceful bool) + func SpawnFuture(address, name, kind string, timeout time.Duration) *actor.Future + func Start(address string, options ...RemotingOption) + type ActivatorError struct + Code int32 + DoNotPanic bool + func (e *ActivatorError) Error() string + type ActorPidRequest struct + Kind string + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*ActorPidRequest) Descriptor() ([]byte, []int) + func (*ActorPidRequest) ProtoMessage() + func (dst *ActorPidRequest) XXX_Merge(src proto.Message) + 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 (m *ActorPidRequest) Reset() + func (m *ActorPidRequest) Size() (n int) + 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_Size() int + func (m *ActorPidRequest) XXX_Unmarshal(b []byte) error + func (this *ActorPidRequest) Equal(that interface{}) bool + func (this *ActorPidRequest) String() string + type ActorPidResponse struct + Pid *actor.PID + StatusCode int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func Spawn(address, kind string, timeout time.Duration) (*ActorPidResponse, error) + func SpawnNamed(address, name, kind string, timeout time.Duration) (*ActorPidResponse, error) + func (*ActorPidResponse) Descriptor() ([]byte, []int) + func (*ActorPidResponse) ProtoMessage() + func (dst *ActorPidResponse) XXX_Merge(src proto.Message) + 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 (m *ActorPidResponse) Reset() + func (m *ActorPidResponse) Size() (n int) + 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_Size() int + func (m *ActorPidResponse) XXX_Unmarshal(b []byte) error + func (this *ActorPidResponse) Equal(that interface{}) bool + func (this *ActorPidResponse) String() string + type ConnectRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*ConnectRequest) Descriptor() ([]byte, []int) + func (*ConnectRequest) ProtoMessage() + func (dst *ConnectRequest) XXX_Merge(src proto.Message) + func (m *ConnectRequest) Marshal() (dAtA []byte, err error) + func (m *ConnectRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ConnectRequest) Reset() + func (m *ConnectRequest) Size() (n int) + 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_Size() int + func (m *ConnectRequest) XXX_Unmarshal(b []byte) error + func (this *ConnectRequest) Equal(that interface{}) bool + func (this *ConnectRequest) String() string + type ConnectResponse struct + DefaultSerializerId int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*ConnectResponse) Descriptor() ([]byte, []int) + func (*ConnectResponse) ProtoMessage() + func (dst *ConnectResponse) XXX_Merge(src proto.Message) + func (m *ConnectResponse) GetDefaultSerializerId() int32 + func (m *ConnectResponse) Marshal() (dAtA []byte, err error) + func (m *ConnectResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ConnectResponse) Reset() + func (m *ConnectResponse) Size() (n int) + 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_Size() int + func (m *ConnectResponse) XXX_Unmarshal(b []byte) error + func (this *ConnectResponse) Equal(that interface{}) bool + func (this *ConnectResponse) String() string + type EndpointConnectedEvent struct + Address string + type EndpointTerminatedEvent struct + Address string + type JsonMessage struct + Json string + TypeName string + type MessageBatch struct + Envelopes []*MessageEnvelope + TargetNames []string + TypeNames []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*MessageBatch) Descriptor() ([]byte, []int) + func (*MessageBatch) ProtoMessage() + func (dst *MessageBatch) XXX_Merge(src proto.Message) + 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 (m *MessageBatch) Reset() + func (m *MessageBatch) Size() (n int) + 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_Size() int + func (m *MessageBatch) XXX_Unmarshal(b []byte) error + func (this *MessageBatch) Equal(that interface{}) bool + func (this *MessageBatch) String() string + type MessageEnvelope struct + MessageData []byte + MessageHeader *MessageHeader + Sender *actor.PID + SerializerId int32 + Target int32 + TypeId int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*MessageEnvelope) Descriptor() ([]byte, []int) + func (*MessageEnvelope) ProtoMessage() + func (dst *MessageEnvelope) XXX_Merge(src proto.Message) + 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 (m *MessageEnvelope) Reset() + func (m *MessageEnvelope) Size() (n int) + 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_Size() int + func (m *MessageEnvelope) XXX_Unmarshal(b []byte) error + func (this *MessageEnvelope) Equal(that interface{}) bool + func (this *MessageEnvelope) String() string + type MessageHeader struct + HeaderData map[string]string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*MessageHeader) Descriptor() ([]byte, []int) + func (*MessageHeader) ProtoMessage() + func (dst *MessageHeader) XXX_Merge(src proto.Message) + func (m *MessageHeader) GetHeaderData() map[string]string + func (m *MessageHeader) Marshal() (dAtA []byte, err error) + func (m *MessageHeader) MarshalTo(dAtA []byte) (int, error) + func (m *MessageHeader) Reset() + func (m *MessageHeader) Size() (n int) + 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_Size() int + func (m *MessageHeader) XXX_Unmarshal(b []byte) error + func (this *MessageHeader) Equal(that interface{}) bool + func (this *MessageHeader) String() string + type RemotingClient interface + Connect func(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error) + Receive func(ctx context.Context, opts ...grpc.CallOption) (Remoting_ReceiveClient, error) + func NewRemotingClient(cc *grpc.ClientConn) RemotingClient + type RemotingOption func(*remoteConfig) + func WithCallOptions(options ...grpc.CallOption) RemotingOption + func WithDialOptions(options ...grpc.DialOption) RemotingOption + func WithEndpointManagerBatchSize(batchSize int) RemotingOption + func WithEndpointManagerQueueSize(queueSize int) RemotingOption + func WithEndpointWriterBatchSize(batchSize int) RemotingOption + func WithEndpointWriterQueueSize(queueSize int) RemotingOption + func WithServerOptions(options ...grpc.ServerOption) RemotingOption + type RemotingServer interface + Connect func(context.Context, *ConnectRequest) (*ConnectResponse, error) + Receive func(Remoting_ReceiveServer) error + type Remoting_ReceiveClient interface + Recv func() (*Unit, error) + Send func(*MessageBatch) error + type Remoting_ReceiveServer interface + Recv func() (*MessageBatch, error) + Send func(*Unit) error + type ResponseStatusCode int32 + const ResponseStatusCodeERROR + const ResponseStatusCodeOK + const ResponseStatusCodePROCESSNAMEALREADYEXIST + const ResponseStatusCodeTIMEOUT + const ResponseStatusCodeUNAVAILABLE + func (c ResponseStatusCode) ToInt32() int32 + type Serializer interface + Deserialize func(typeName string, bytes []byte) (interface{}, error) + GetTypeName func(msg interface{}) (string, error) + Serialize func(msg interface{}) ([]byte, error) + type Unit struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + func (*Unit) Descriptor() ([]byte, []int) + func (*Unit) ProtoMessage() + func (dst *Unit) XXX_Merge(src proto.Message) + func (m *Unit) Marshal() (dAtA []byte, err error) + func (m *Unit) MarshalTo(dAtA []byte) (int, error) + func (m *Unit) Reset() + func (m *Unit) Size() (n int) + 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_Size() int + func (m *Unit) XXX_Unmarshal(b []byte) error + func (this *Unit) Equal(that interface{}) bool + func (this *Unit) String() string
Go to main page