comm

Documentation

Index

• type Message
  • func (u *Message) IsNil() bool
  • func (m *Message) MarshalJSONObject(enc *gojay.Encoder)
  • func (m *Message) NKeys() int
  • func (m *Message) UnmarshalJSONObject(dec *gojay.Decoder, k string) error
• type Receiver
  • func (s Receiver) UnmarshalStream(dec *gojay.StreamDecoder) error
• type Sender
  • func (s Sender) MarshalStream(enc *gojay.StreamEncoder)
• type SenderReceiver
  • func (sc *SenderReceiver) Init(sender int) *SenderReceiver
  • func (c *SenderReceiver) OnMessage(f func(*Message)) error
  • func (sc *SenderReceiver) SendMessage(m gojay.MarshalerJSONObject) error
  • func (sc *SenderReceiver) SetReceiver()
  • func (sc *SenderReceiver) SetSender(nCons int)

Types

type Message

type Message struct {
	Message  string
	UserName string
}

func (*Message) IsNil

func (u *Message) IsNil() bool

func (*Message) MarshalJSONObject

func (m *Message) MarshalJSONObject(enc *gojay.Encoder)

func (*Message) NKeys

func (m *Message) NKeys() int

func (*Message) UnmarshalJSONObject

func (m *Message) UnmarshalJSONObject(dec *gojay.Decoder, k string) error

type Receiver

type Receiver chan *Message

func (Receiver) UnmarshalStream

func (s Receiver) UnmarshalStream(dec *gojay.StreamDecoder) error

type Sender

type Sender chan gojay.MarshalerJSONObject

Here are defined our communication types

func (Sender) MarshalStream

func (s Sender) MarshalStream(enc *gojay.StreamEncoder)

type SenderReceiver

type SenderReceiver struct {
	Send    Sender
	Receive Receiver
	Dec     *gojay.StreamDecoder
	Enc     *gojay.StreamEncoder
	Conn    *websocket.Conn
}

func (*SenderReceiver) Init

func (sc *SenderReceiver) Init(sender int) *SenderReceiver

func (*SenderReceiver) OnMessage

func (c *SenderReceiver) OnMessage(f func(*Message)) error

func (*SenderReceiver) SendMessage

func (sc *SenderReceiver) SendMessage(m gojay.MarshalerJSONObject) error

func (*SenderReceiver) SetReceiver

func (sc *SenderReceiver) SetReceiver()

func (*SenderReceiver) SetSender

func (sc *SenderReceiver) SetSender(nCons int)