messages

README

消息

介绍

• 消息的封装与返回
• 如果需要自定义小则需要实现: Message 接口

Proto

• Proto消息实现 -> ProtoMessage

Documentation

Index

• Variables
• type JsonMessage
  • func (j *JsonMessage) Bind(v interface{}) (err error)
  • func (j *JsonMessage) GetBody() []byte
  • func (j *JsonMessage) GetBytesResult() []byte
  • func (j *JsonMessage) GetCode() int64
  • func (j *JsonMessage) GetHeaders() string
  • func (j *JsonMessage) GetHeartbeat() bool
  • func (j *JsonMessage) GetMerge() int64
  • func (j *JsonMessage) GetMessage() string
  • func (j *JsonMessage) SetBody(data interface{})
  • func (j *JsonMessage) SetCode(code int64)
  • func (j *JsonMessage) SetMerge(merge int64)
  • func (j *JsonMessage) SetMessage(message string)
• type Message
• type ProtoMessage
  • func (p *ProtoMessage) Bind(v interface{}) (err error)
  • func (p *ProtoMessage) GetBody() []byte
  • func (p *ProtoMessage) GetBytesResult() []byte
  • func (p *ProtoMessage) GetCode() int64
  • func (p *ProtoMessage) GetHeaders() string
  • func (p *ProtoMessage) GetHeartbeat() bool
  • func (p *ProtoMessage) GetMerge() int64
  • func (p *ProtoMessage) GetMessage() string
  • func (p *ProtoMessage) SetBody(data interface{})
  • func (p *ProtoMessage) SetCode(code int64)
  • func (p *ProtoMessage) SetMerge(merge int64)
  • func (p *ProtoMessage) SetMessage(message string)

Variables

var MsgKit = kit{}

Types

type JsonMessage

type JsonMessage struct {
	Merge     int64  `json:"merge,omitempty"`
	Body      []byte `json:"body,omitempty"`
	Heartbeat bool   `json:"heartbeat,omitempty"`
	Code      int64  `json:"code,omitempty"`
	Message   string `json:"message,omitempty"`
	Headers   string `json:"headers,omitempty"`
}

JsonMessage 必须实现 Message 接口 Json处理则必须先转换为json才能继续处理其他东西

func (*JsonMessage) Bind

func (j *JsonMessage) Bind(v interface{}) (err error)

func (*JsonMessage) GetBody

func (j *JsonMessage) GetBody() []byte

func (*JsonMessage) GetBytesResult

func (j *JsonMessage) GetBytesResult() []byte

func (*JsonMessage) GetCode

func (j *JsonMessage) GetCode() int64

func (*JsonMessage) GetHeaders

func (j *JsonMessage) GetHeaders() string

func (*JsonMessage) GetHeartbeat

func (j *JsonMessage) GetHeartbeat() bool

func (*JsonMessage) GetMerge

func (j *JsonMessage) GetMerge() int64

func (*JsonMessage) GetMessage

func (j *JsonMessage) GetMessage() string

func (*JsonMessage) SetBody

func (j *JsonMessage) SetBody(data interface{})

func (*JsonMessage) SetCode

func (j *JsonMessage) SetCode(code int64)

func (*JsonMessage) SetMerge

func (j *JsonMessage) SetMerge(merge int64)

func (*JsonMessage) SetMessage

func (j *JsonMessage) SetMessage(message string)

type Message

type Message interface {
	GetMerge() int64           //获取路由
	GetBody() []byte           //获取数据
	GetHeartbeat() bool        //心跳
	GetCode() int64            //获取状态码,0为成功
	GetMessage() string        //消息
	GetBytesResult() []byte    //转换为字节数据
	SetBody(data any)          // 其内部适应了两种类型, []byte 和对应实现的类型
	GetHeaders() string        //用于扩展其他参数
	Bind(v any) (err error)    //绑定到对象上
	SetMerge(merge int64)      //设置路由
	SetCode(code int64)        //设置状态码
	SetMessage(message string) //错误消息
}

type ProtoMessage

type ProtoMessage struct {
	protof.Message
}

func (*ProtoMessage) Bind

func (p *ProtoMessage) Bind(v interface{}) (err error)

func (*ProtoMessage) GetBody

func (p *ProtoMessage) GetBody() []byte

func (*ProtoMessage) GetBytesResult

func (p *ProtoMessage) GetBytesResult() []byte

func (*ProtoMessage) GetCode

func (p *ProtoMessage) GetCode() int64

func (*ProtoMessage) GetHeaders

func (p *ProtoMessage) GetHeaders() string

func (*ProtoMessage) GetHeartbeat

func (p *ProtoMessage) GetHeartbeat() bool

func (*ProtoMessage) GetMerge

func (p *ProtoMessage) GetMerge() int64

func (*ProtoMessage) GetMessage

func (p *ProtoMessage) GetMessage() string

func (*ProtoMessage) SetBody

func (p *ProtoMessage) SetBody(data interface{})

func (*ProtoMessage) SetCode

func (p *ProtoMessage) SetCode(code int64)

func (*ProtoMessage) SetMerge

func (p *ProtoMessage) SetMerge(merge int64)

func (*ProtoMessage) SetMessage

func (p *ProtoMessage) SetMessage(message string)