model

Documentation

Index

• type Message
  • func NewMessage(name string, d []byte) Message
  • func (e *Message) Data() []byte
  • func (e *Message) MarshalJSON() ([]byte, error)
  • func (e *Message) Name() string
  • func (e *Message) UnmarshalJSON(data []byte) error
  • func (e *Message) Write(w io.Writer)

Types

type Message

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

Message is the event sent or received from a Channel

func NewMessage

func NewMessage(name string, d []byte) Message

NewMessage creates a new Message

func (*Message) Data

func (e *Message) Data() []byte

Data returns the message data

func (*Message) MarshalJSON

func (e *Message) MarshalJSON() ([]byte, error)

MarshalJSON marshal a model.Message into an byte slice

func (*Message) Name

func (e *Message) Name() string

Name returns the message name

func (*Message) UnmarshalJSON

func (e *Message) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshal byte slice into a model.Message

func (*Message) Write

func (e *Message) Write(w io.Writer)