msgenvelope

Documentation

Overview

Package msgenvelope @Title 数据信封 @Description 用于不同service之间的数据传递 @Author yr 2024/9/2 下午3:40 @Update yr 2024/9/2 下午3:40

Index

• func ReleaseMsgEnvelope(envelope inf.IEnvelope)
• type MsgEnvelope
  • 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()

Functions

func ReleaseMsgEnvelope

func ReleaseMsgEnvelope(envelope inf.IEnvelope)

Types

type MsgEnvelope

type MsgEnvelope struct {
	def.DataRef
	// contains filtered or unexported fields
}

func NewMsgEnvelope

func NewMsgEnvelope() *MsgEnvelope

func (*MsgEnvelope) Done

func (e *MsgEnvelope) Done()

func (*MsgEnvelope) GetErrStr

func (e *MsgEnvelope) GetErrStr() string

func (*MsgEnvelope) GetError

func (e *MsgEnvelope) GetError() error

func (*MsgEnvelope) GetHeader

func (e *MsgEnvelope) GetHeader(key string) string

func (*MsgEnvelope) GetHeaders

func (e *MsgEnvelope) GetHeaders() def.Header

func (*MsgEnvelope) GetMethod

func (e *MsgEnvelope) GetMethod() string

func (*MsgEnvelope) GetReceiver

func (e *MsgEnvelope) GetReceiver() *actor.PID

func (*MsgEnvelope) GetReqId

func (e *MsgEnvelope) GetReqId() uint64

func (*MsgEnvelope) GetRequest

func (e *MsgEnvelope) GetRequest() interface{}

func (*MsgEnvelope) GetResponse

func (e *MsgEnvelope) GetResponse() interface{}

func (*MsgEnvelope) GetSender

func (e *MsgEnvelope) GetSender() *actor.PID

func (*MsgEnvelope) GetSenderClient

func (e *MsgEnvelope) GetSenderClient() inf.IRpcSender

func (*MsgEnvelope) GetTimeout

func (e *MsgEnvelope) GetTimeout() time.Duration

func (*MsgEnvelope) IsReply

func (e *MsgEnvelope) IsReply() bool

func (*MsgEnvelope) NeedCallback

func (e *MsgEnvelope) NeedCallback() bool

func (*MsgEnvelope) NeedResponse

func (e *MsgEnvelope) NeedResponse() bool

func (*MsgEnvelope) Reset

func (e *MsgEnvelope) Reset()

func (*MsgEnvelope) RunCompletions

func (e *MsgEnvelope) RunCompletions()

func (*MsgEnvelope) SetCallback

func (e *MsgEnvelope) SetCallback(cbs []def.CompletionFunc)

func (*MsgEnvelope) SetErrStr

func (e *MsgEnvelope) SetErrStr(err string)

func (*MsgEnvelope) SetError

func (e *MsgEnvelope) SetError(err error)

func (*MsgEnvelope) SetHeader

func (e *MsgEnvelope) SetHeader(key string, value string)

func (*MsgEnvelope) SetHeaders

func (e *MsgEnvelope) SetHeaders(header def.Header)

func (*MsgEnvelope) SetMethod

func (e *MsgEnvelope) SetMethod(method string)

func (*MsgEnvelope) SetNeedResponse

func (e *MsgEnvelope) SetNeedResponse(need bool)

func (*MsgEnvelope) SetReceiver

func (e *MsgEnvelope) SetReceiver(receiver *actor.PID)

func (*MsgEnvelope) SetReply

func (e *MsgEnvelope) SetReply()

func (*MsgEnvelope) SetReqId

func (e *MsgEnvelope) SetReqId(reqId uint64)

func (*MsgEnvelope) SetRequest

func (e *MsgEnvelope) SetRequest(req interface{})

func (*MsgEnvelope) SetResponse

func (e *MsgEnvelope) SetResponse(res interface{})

func (*MsgEnvelope) SetSender

func (e *MsgEnvelope) SetSender(sender *actor.PID)

func (*MsgEnvelope) SetSenderClient

func (e *MsgEnvelope) SetSenderClient(client inf.IRpcSender)

func (*MsgEnvelope) SetTimeout

func (e *MsgEnvelope) SetTimeout(timeout time.Duration)

func (*MsgEnvelope) ToProtoMsg

func (e *MsgEnvelope) ToProtoMsg() *actor.Message

func (*MsgEnvelope) Wait

func (e *MsgEnvelope) Wait()