proto

Documentation

Index

• Variables
• type Message
  • func NewMessage(name string, payload interface{}) *Message
  • func (m *Message) UnmarshalJSON(b []byte) error
• type MessageHeader
• type ResponseReader
  • func NewResponseReader(resp *http.Response) (*ResponseReader, error)
  • func (r *ResponseReader) Close() error
  • func (r *ResponseReader) ReadAttach() (io.ReadCloser, error)
  • func (r *ResponseReader) ReadDirective() (*Message, error)
  • func (r *ResponseReader) ReadJSON() (*gjson.Result, error)

Variables

var (
	ErrEmptyBody = errors.New("empty body")
)

Types

type Message

type Message struct {
	Header      MessageHeader `json:"header"`
	Payload     interface{}   `json:"payload"`
	PayloadJSON gjson.Result  `json:"-"`
	Attach      io.ReadCloser `json:"-"`
}

func NewMessage

func NewMessage(name string, payload interface{}) *Message

func (*Message) UnmarshalJSON

func (m *Message) UnmarshalJSON(b []byte) error

type MessageHeader

type MessageHeader struct {
	Namespace       string `json:"namespace"`
	Name            string `json:"name"`
	MessageId       string `json:"messageId"`
	DialogRequestId string `json:"dialogRequestId"`
}

type ResponseReader

type ResponseReader struct {
	*http.Response
	// contains filtered or unexported fields
}

func NewResponseReader

func NewResponseReader(resp *http.Response) (*ResponseReader, error)

func (*ResponseReader) Close

func (r *ResponseReader) Close() error

func (*ResponseReader) ReadAttach

func (r *ResponseReader) ReadAttach() (io.ReadCloser, error)

func (*ResponseReader) ReadDirective

func (r *ResponseReader) ReadDirective() (*Message, error)

func (*ResponseReader) ReadJSON

func (r *ResponseReader) ReadJSON() (*gjson.Result, error)