Versions in this module Expand all Collapse all v0 v0.9.1 Jan 22, 2019 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") + var MsgType_name = map[int32]string + var MsgType_value = map[string]int32 + 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 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 SetLogLevel(level log.Level) + func Shutdonw() + func SpawnFuture(address, name, kind string, timeout time.Duration) *actor.Future + func Start(address string) + type ActivatorError struct + Code int32 + DoNotPanic bool + func (e *ActivatorError) Error() string + type ActorPidRequest struct + Kind string + Name string + func (*ActorPidRequest) Descriptor() ([]byte, []int) + func (*ActorPidRequest) ProtoMessage() + 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 (this *ActorPidRequest) Equal(that interface{}) bool + func (this *ActorPidRequest) String() string + type ActorPidResponse struct + Pid *actor.PID + StatusCode 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 (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 (this *ActorPidResponse) Equal(that interface{}) bool + func (this *ActorPidResponse) 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 + func (*MessageBatch) Descriptor() ([]byte, []int) + func (*MessageBatch) ProtoMessage() + 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 (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 + func (*MessageEnvelope) Descriptor() ([]byte, []int) + func (*MessageEnvelope) ProtoMessage() + 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 (this *MessageEnvelope) Equal(that interface{}) bool + func (this *MessageEnvelope) String() string + type MessageHeader struct + HeaderData map[string]string + func (*MessageHeader) Descriptor() ([]byte, []int) + func (*MessageHeader) ProtoMessage() + 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 (this *MessageHeader) Equal(that interface{}) bool + func (this *MessageHeader) String() string + type MsgData struct + Data []byte + MsgType MsgType + func (*MsgData) Descriptor() ([]byte, []int) + func (*MsgData) ProtoMessage() + func (m *MsgData) GetData() []byte + func (m *MsgData) GetMsgType() MsgType + func (m *MsgData) Marshal() (dAtA []byte, err error) + func (m *MsgData) MarshalTo(dAtA []byte) (int, error) + func (m *MsgData) Reset() + func (m *MsgData) Size() (n int) + func (m *MsgData) Unmarshal(dAtA []byte) error + func (this *MsgData) Equal(that interface{}) bool + func (this *MsgData) String() string + type MsgType int32 + const ADDRESS_MSG_TYPE + const BLOCK_MSG_TYPE + const HEADER_MSG_TYPE + const TX_ATT_MSG_TYPE + const TX_MSG_TYPE + const VM_CODE_MSG_TYPE + func (MsgType) EnumDescriptor() ([]byte, []int) + func (x MsgType) String() string + 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)
Go to main page