queue

Documentation

Index

• type Message
  • func Build(data interface{}) *Message
  • func (msg *Message) Encode() ([]byte, error)
  • func (msg *Message) Length() int

Types

type Message

type Message struct {
	Data interface{} `json:"data"`
	// contains filtered or unexported fields
}

func Build

func Build(data interface{}) *Message

func (*Message) Encode

func (msg *Message) Encode() ([]byte, error)

func (*Message) Length

func (msg *Message) Length() int