packet

Documentation

Overview

Package packet is a generated protocol buffer package.

It is generated from these files:

tmp.proto

It has these top-level messages:

Header
BytesMessage
StringMessage

Index

• type BytesMessage
  • func (*BytesMessage) Descriptor() ([]byte, []int)
  • func (m *BytesMessage) GetBody() []byte
  • func (m *BytesMessage) GetHeader() *Header
  • func (*BytesMessage) ProtoMessage()
  • func (m *BytesMessage) Reset()
  • func (m *BytesMessage) String() string
• type Header
  • func (*Header) Descriptor() ([]byte, []int)
  • func (m *Header) GetMessageId() string
  • func (m *Header) GetTopic() string
  • func (*Header) ProtoMessage()
  • func (m *Header) Reset()
  • func (m *Header) String() string
• type PacketOpBase64
  • func (self *PacketOpBase64) Init(direct bool, params []interface{}) bool
  • func (self *PacketOpBase64) Operate(input interface{}, output interface{}) (bool, error)
  • func (*PacketOpBase64) Pack(originData interface{}) ([]byte, error)
  • func (*PacketOpBase64) Unpack(packData []byte, obj interface{}) error
• type PacketOpJson
  • func (self *PacketOpJson) Init(direct bool, params []interface{}) bool
  • func (self *PacketOpJson) Operate(input interface{}, output interface{}) (bool, error)
  • func (*PacketOpJson) Pack(originData interface{}) ([]byte, error)
  • func (*PacketOpJson) Unpack(packData []byte, obj interface{}) error
• type PacketOpProtobuf
  • func (self *PacketOpProtobuf) Init(direct bool, params []interface{}) bool
  • func (self *PacketOpProtobuf) Operate(input interface{}, output interface{}) (bool, error)
  • func (*PacketOpProtobuf) Pack(originData interface{}) ([]byte, error)
  • func (*PacketOpProtobuf) Unpack(packData []byte, obj interface{}) error
• type PacketOpXml
  • func (self *PacketOpXml) Init(direct bool, params []interface{}) bool
  • func (self *PacketOpXml) Operate(input interface{}, output interface{}) (bool, error)
  • func (*PacketOpXml) Pack(originData interface{}) ([]byte, error)
  • func (*PacketOpXml) Unpack(packData []byte, obj interface{}) error
• type StringMessage
  • func (*StringMessage) Descriptor() ([]byte, []int)
  • func (m *StringMessage) GetBody() string
  • func (m *StringMessage) GetHeader() *Header
  • func (*StringMessage) ProtoMessage()
  • func (m *StringMessage) Reset()
  • func (m *StringMessage) String() string

Types

type BytesMessage

type BytesMessage struct {
	Header           *Header `protobuf:"bytes,1,req,name=header" json:"header,omitempty"`
	Body             []byte  `protobuf:"bytes,2,req,name=body" json:"body,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

byte类消息

func (*BytesMessage) Descriptor

func (*BytesMessage) Descriptor() ([]byte, []int)

func (*BytesMessage) GetBody

func (m *BytesMessage) GetBody() []byte

func (*BytesMessage) GetHeader

func (m *BytesMessage) GetHeader() *Header

func (*BytesMessage) ProtoMessage

func (*BytesMessage) ProtoMessage()

func (*BytesMessage) Reset

func (m *BytesMessage) Reset()

func (*BytesMessage) String

func (m *BytesMessage) String() string

type Header

type Header struct {
	MessageId        *string `protobuf:"bytes,1,req,name=messageId" json:"messageId,omitempty"`
	Topic            *string `protobuf:"bytes,2,req,name=topic" json:"topic,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Header) Descriptor

func (*Header) Descriptor() ([]byte, []int)

func (*Header) GetMessageId

func (m *Header) GetMessageId() string

func (*Header) GetTopic

func (m *Header) GetTopic() string

func (*Header) ProtoMessage

func (*Header) ProtoMessage()

func (*Header) Reset

func (m *Header) Reset()

func (*Header) String

func (m *Header) String() string

type PacketOpBase64

type PacketOpBase64 struct {
	// contains filtered or unexported fields
}

func (*PacketOpBase64) Init

func (self *PacketOpBase64) Init(direct bool, params []interface{}) bool

func (*PacketOpBase64) Operate

func (self *PacketOpBase64) Operate(input interface{}, output interface{}) (bool, error)

func (*PacketOpBase64) Pack

func (*PacketOpBase64) Pack(originData interface{}) ([]byte, error)

此函数中需要检查入参是否为 string / []byte

func (*PacketOpBase64) Unpack

func (*PacketOpBase64) Unpack(packData []byte, obj interface{}) error

type PacketOpJson

type PacketOpJson struct {
	// contains filtered or unexported fields
}

func (*PacketOpJson) Init

func (self *PacketOpJson) Init(direct bool, params []interface{}) bool

func (*PacketOpJson) Operate

func (self *PacketOpJson) Operate(input interface{}, output interface{}) (bool, error)

func (*PacketOpJson) Pack

func (*PacketOpJson) Pack(originData interface{}) ([]byte, error)

func (*PacketOpJson) Unpack

func (*PacketOpJson) Unpack(packData []byte, obj interface{}) error

type PacketOpProtobuf

type PacketOpProtobuf struct {
	// contains filtered or unexported fields
}

func (*PacketOpProtobuf) Init

func (self *PacketOpProtobuf) Init(direct bool, params []interface{}) bool

func (*PacketOpProtobuf) Operate

func (self *PacketOpProtobuf) Operate(input interface{}, output interface{}) (bool, error)

func (*PacketOpProtobuf) Pack

func (*PacketOpProtobuf) Pack(originData interface{}) ([]byte, error)

func (*PacketOpProtobuf) Unpack

func (*PacketOpProtobuf) Unpack(packData []byte, obj interface{}) error

type PacketOpXml

type PacketOpXml struct {
	// contains filtered or unexported fields
}

func (*PacketOpXml) Init

func (self *PacketOpXml) Init(direct bool, params []interface{}) bool

func (*PacketOpXml) Operate

func (self *PacketOpXml) Operate(input interface{}, output interface{}) (bool, error)

func (*PacketOpXml) Pack

func (*PacketOpXml) Pack(originData interface{}) ([]byte, error)

todo: xml是不能对 map 编码的, 这里需要添加检查 https://stackoverflow.com/questions/30928770/marshall-map-to-xml-in-go?utm_medium=organic&utm_source=google_rich_qa&utm_campaign=google_rich_qa

func (*PacketOpXml) Unpack

func (*PacketOpXml) Unpack(packData []byte, obj interface{}) error

type StringMessage

type StringMessage struct {
	Header           *Header `protobuf:"bytes,1,req,name=header" json:"header,omitempty"`
	Body             *string `protobuf:"bytes,2,req,name=body" json:"body,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

string类型的message

func (*StringMessage) Descriptor

func (*StringMessage) Descriptor() ([]byte, []int)

func (*StringMessage) GetBody

func (m *StringMessage) GetBody() string

func (*StringMessage) GetHeader

func (m *StringMessage) GetHeader() *Header

func (*StringMessage) ProtoMessage

func (*StringMessage) ProtoMessage()

func (*StringMessage) Reset

func (m *StringMessage) Reset()

func (*StringMessage) String

func (m *StringMessage) String() string