message

Documentation

Index

• type JSONTime
  • func (t JSONTime) MarshalJSON() ([]byte, error)
  • func (t *JSONTime) UnmarshalJSON(data []byte) (err error)
• type Message
  • func NewJSON(jsonString string) (Message, error)
  • func (curMessage *Message) JSONString() (string, error)
  • func (curMessage Message) MarshalZerologObject(e *zerolog.Event)

Types

type JSONTime

type JSONTime time.Time

JSONTime represent an timestamp

func (JSONTime) MarshalJSON

func (t JSONTime) MarshalJSON() ([]byte, error)

MarshalJSON will mashall an timestamp

func (*JSONTime) UnmarshalJSON

func (t *JSONTime) UnmarshalJSON(data []byte) (err error)

UnmarshalJSON unmashall the timestapm

type Message

type Message struct {

	// SendAsJSON will send this message as json to the Topic
	SendAsJSON bool `json:"o,omitempty"`

	// ReqID [OPTIONAL] represents the current request
	ReqID string `json:"r,omitempty"`

	// The topic
	Timestamp JSONTime `json:"s,omitempty"`

	// The topic
	Topic string `json:"t,omitempty"`

	// TopicReply [OPTIONAL] - the request should reply with this topic
	TopicReply string `json:"tr,omitempty"`

	// payload
	Payload string `json:"v"`
	// contains filtered or unexported fields
}

Message represent a single message from/to SSE

func NewJSON

func NewJSON(jsonString string) (Message, error)

NewJSON will convert an json-string to an message

func (*Message) JSONString

func (curMessage *Message) JSONString() (string, error)

JSONString will convert an message to an json string

func (Message) MarshalZerologObject

func (curMessage Message) MarshalZerologObject(e *zerolog.Event)

MarshalZerologObject implementation to use it with Object()