encoders

Documentation

Index

• type CachedEncodedMessage
  • func NewCachedEncodedMessage(msg EncodedMessage) *CachedEncodedMessage
  • func (msg *CachedEncodedMessage) Fetch(id string, callback EncodingFunction) (*ws.SentFrame, error)
  • func (msg *CachedEncodedMessage) GetType() string
  • func (msg *CachedEncodedMessage) MarshalJSON() ([]byte, error)
• type EncodedMessage
• type Encoder
• type EncodingCache
  • func NewEncodingCache() *EncodingCache
  • func (m *EncodingCache) Fetch(msg EncodedMessage, encoder string, callback EncodingFunction) (*ws.SentFrame, error)
• type EncodingFunction
• type JSON
  • func (JSON) Decode(raw []byte) (*common.Message, error)
  • func (JSON) Encode(msg EncodedMessage) (*ws.SentFrame, error)
  • func (JSON) EncodeTransmission(msg string) (*ws.SentFrame, error)
  • func (JSON) ID() string

Types

type CachedEncodedMessage

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

func NewCachedEncodedMessage

func NewCachedEncodedMessage(msg EncodedMessage) *CachedEncodedMessage

func (*CachedEncodedMessage) Fetch

func (msg *CachedEncodedMessage) Fetch(id string, callback EncodingFunction) (*ws.SentFrame, error)

func (*CachedEncodedMessage) GetType

func (msg *CachedEncodedMessage) GetType() string

func (*CachedEncodedMessage) MarshalJSON

func (msg *CachedEncodedMessage) MarshalJSON() ([]byte, error)

type EncodedMessage

type EncodedMessage interface {
	GetType() string
}

type Encoder

type Encoder interface {
	ID() string
	Encode(msg EncodedMessage) (*ws.SentFrame, error)
	EncodeTransmission(msg string) (*ws.SentFrame, error)
	Decode(payload []byte) (*common.Message, error)
}

type EncodingCache

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

func NewEncodingCache

func NewEncodingCache() *EncodingCache

func (*EncodingCache) Fetch

func (m *EncodingCache) Fetch(
	msg EncodedMessage,
	encoder string,
	callback EncodingFunction,
) (*ws.SentFrame, error)

type EncodingFunction

type EncodingFunction = func(EncodedMessage) (*ws.SentFrame, error)

type JSON

type JSON struct {
}

func (JSON) Decode

func (JSON) Decode(raw []byte) (*common.Message, error)

func (JSON) Encode

func (JSON) Encode(msg EncodedMessage) (*ws.SentFrame, error)

func (JSON) EncodeTransmission

func (JSON) EncodeTransmission(msg string) (*ws.SentFrame, error)

func (JSON) ID

func (JSON) ID() string