wssender

Documentation

Index

• Constants
• func TransformToResponse(message proto.Message) []byte
• type Message
  • func DecodeMessage(data []byte) (msg Message, err error)
  • func ProtoToMessage(m contracts.WebsocketMessage, id string) Message
  • func (m Message) Marshal() []byte

Constants

const BroadcastRoom = "all"

const MessageChSize = 100

Functions

func TransformToResponse

func TransformToResponse(message proto.Message) []byte

Types

type Message

type Message struct {
	Data []byte
	To   websocket_pb.To
	ID   string
}

func DecodeMessage

func DecodeMessage(data []byte) (msg Message, err error)

func ProtoToMessage

func ProtoToMessage(m contracts.WebsocketMessage, id string) Message

func (Message) Marshal

func (m Message) Marshal() []byte