Versions in this module Expand all Collapse all v1 v1.0.2 Dec 5, 2024 Changes in this version type MsgEnvelope + func (e *MsgEnvelope) GetReceiverPid() *actor.PID + func (e *MsgEnvelope) GetSenderPid() *actor.PID + func (e *MsgEnvelope) SetReceiverPid(receiver *actor.PID) + func (e *MsgEnvelope) SetSenderPid(sender *actor.PID) v1.0.1 Nov 16, 2024 Changes in this version + func ReleaseMsgEnvelope(envelope inf.IEnvelope) + type MsgEnvelope struct + func NewMsgEnvelope() *MsgEnvelope + func (e *MsgEnvelope) Done() + func (e *MsgEnvelope) GetErrStr() string + func (e *MsgEnvelope) GetError() error + func (e *MsgEnvelope) GetHeader(key string) string + func (e *MsgEnvelope) GetHeaders() def.Header + func (e *MsgEnvelope) GetMethod() string + func (e *MsgEnvelope) GetReceiver() *actor.PID + func (e *MsgEnvelope) GetReqId() uint64 + func (e *MsgEnvelope) GetRequest() interface{} + func (e *MsgEnvelope) GetResponse() interface{} + func (e *MsgEnvelope) GetSender() *actor.PID + func (e *MsgEnvelope) GetSenderClient() inf.IRpcSender + func (e *MsgEnvelope) GetTimeout() time.Duration + func (e *MsgEnvelope) IsReply() bool + func (e *MsgEnvelope) NeedCallback() bool + func (e *MsgEnvelope) NeedResponse() bool + func (e *MsgEnvelope) Reset() + func (e *MsgEnvelope) RunCompletions() + func (e *MsgEnvelope) SetCallback(cbs []def.CompletionFunc) + func (e *MsgEnvelope) SetErrStr(err string) + func (e *MsgEnvelope) SetError(err error) + func (e *MsgEnvelope) SetHeader(key string, value string) + func (e *MsgEnvelope) SetHeaders(header def.Header) + func (e *MsgEnvelope) SetMethod(method string) + func (e *MsgEnvelope) SetNeedResponse(need bool) + func (e *MsgEnvelope) SetReceiver(receiver *actor.PID) + func (e *MsgEnvelope) SetReply() + func (e *MsgEnvelope) SetReqId(reqId uint64) + func (e *MsgEnvelope) SetRequest(req interface{}) + func (e *MsgEnvelope) SetResponse(res interface{}) + func (e *MsgEnvelope) SetSender(sender *actor.PID) + func (e *MsgEnvelope) SetSenderClient(client inf.IRpcSender) + func (e *MsgEnvelope) SetTimeout(timeout time.Duration) + func (e *MsgEnvelope) ToProtoMsg() *actor.Message + func (e *MsgEnvelope) Wait()
Go to main page