encoder

Documentation

Index

• type EncoderDecoder
  • func NewEncoderDecoder() EncoderDecoder
• type MockEncoderDecoder
  • func (m *MockEncoderDecoder) Decode(msg []byte) (messages.Message, error)
  • func (m *MockEncoderDecoder) DecodeConnectionAcceptMessage(data []byte) (messages.ConnectionAcceptMessage, error)
  • func (m *MockEncoderDecoder) DecodeConnectionFailedMessage(data []byte) (messages.ConnectionFailedMessage, error)
  • func (m *MockEncoderDecoder) DecodeConnectionOpenMessage(data []byte) (messages.ConnectionOpenMessage, error)
  • func (m *MockEncoderDecoder) DecodeDataAckMessage(data []byte) (messages.DataAckMessage, error)
  • func (m *MockEncoderDecoder) DecodeDataMessage(data []byte) (messages.DataMessage, error)
  • func (m *MockEncoderDecoder) DecodeDatagramMessage(data []byte) (messages.DatagramMessage, error)
  • func (m *MockEncoderDecoder) Encode(msg messages.Message) ([]byte, error)
  • func (m *MockEncoderDecoder) EncodeConnectionAcceptMessage(dm messages.ConnectionAcceptMessage) ([]byte, error)
  • func (m *MockEncoderDecoder) EncodeConnectionFailedMessage(dm messages.ConnectionFailedMessage) ([]byte, error)
  • func (m *MockEncoderDecoder) EncodeConnectionOpenMessage(dm messages.ConnectionOpenMessage) ([]byte, error)
  • func (m *MockEncoderDecoder) EncodeDataAckMessage(dm messages.DataAckMessage) ([]byte, error)
  • func (m *MockEncoderDecoder) EncodeDataMessage(dm messages.DataMessage) ([]byte, error)
  • func (m *MockEncoderDecoder) EncodeDatagramMessage(dm messages.DatagramMessage) ([]byte, error)

Types

type EncoderDecoder

type EncoderDecoder interface {
	// Encode encodes a message
	Encode(messages.Message) ([]byte, error)

	// Decode decodes a message
	Decode([]byte) (messages.Message, error)

	// DecodeConnectionOpenMessage decodes a connection open message
	DecodeConnectionOpenMessage([]byte) (messages.ConnectionOpenMessage, error)

	// EncodeConnectionOpenMessage encodes a connection open message
	EncodeConnectionOpenMessage(messages.ConnectionOpenMessage) ([]byte, error)

	// Decode ConnectionAcceptMessage decodes a connection accept message
	DecodeConnectionAcceptMessage([]byte) (messages.ConnectionAcceptMessage, error)

	// EncodeConnectionAcceptMessage encodes a connection accept message
	EncodeConnectionAcceptMessage(messages.ConnectionAcceptMessage) ([]byte, error)

	// Decode ConnectionFailedMessage decodes a connection failed message
	DecodeConnectionFailedMessage([]byte) (messages.ConnectionFailedMessage, error)

	// EncodeConnectionFailedMessage encodes a connection failed message
	EncodeConnectionFailedMessage(messages.ConnectionFailedMessage) ([]byte, error)

	// Decode DataMessage decodes a data message
	DecodeDataMessage([]byte) (messages.DataMessage, error)

	// EncodeDataMessage encodes a data message
	EncodeDataMessage(messages.DataMessage) ([]byte, error)

	// EncodeDatagramMessage encodes a datagram message
	EncodeDatagramMessage(messages.DatagramMessage) ([]byte, error)

	// Decode DataAckMessage decodes a ack message
	DecodeDataAckMessage([]byte) (messages.DataAckMessage, error)

	// EncodeDataAckMessage encodes a ack message
	EncodeDataAckMessage(messages.DataAckMessage) ([]byte, error)
}

EncoderDecoder is the interface for encoding and decoding messages (using msgpack).

func NewEncoderDecoder

func NewEncoderDecoder() EncoderDecoder

NewEncoderDecoder creates a new encoder/decoder.

type MockEncoderDecoder

type MockEncoderDecoder struct {
	mock.Mock
}

func (*MockEncoderDecoder) Decode

func (m *MockEncoderDecoder) Decode(msg []byte) (messages.Message, error)

func (*MockEncoderDecoder) DecodeConnectionAcceptMessage

func (m *MockEncoderDecoder) DecodeConnectionAcceptMessage(data []byte) (messages.ConnectionAcceptMessage, error)

func (*MockEncoderDecoder) DecodeConnectionFailedMessage

func (m *MockEncoderDecoder) DecodeConnectionFailedMessage(data []byte) (messages.ConnectionFailedMessage, error)

func (*MockEncoderDecoder) DecodeConnectionOpenMessage

func (m *MockEncoderDecoder) DecodeConnectionOpenMessage(data []byte) (messages.ConnectionOpenMessage, error)

func (*MockEncoderDecoder) DecodeDataAckMessage

func (m *MockEncoderDecoder) DecodeDataAckMessage(data []byte) (messages.DataAckMessage, error)

func (*MockEncoderDecoder) DecodeDataMessage

func (m *MockEncoderDecoder) DecodeDataMessage(data []byte) (messages.DataMessage, error)

func (*MockEncoderDecoder) DecodeDatagramMessage

func (m *MockEncoderDecoder) DecodeDatagramMessage(data []byte) (messages.DatagramMessage, error)

func (*MockEncoderDecoder) Encode

func (m *MockEncoderDecoder) Encode(msg messages.Message) ([]byte, error)

func (*MockEncoderDecoder) EncodeConnectionAcceptMessage

func (m *MockEncoderDecoder) EncodeConnectionAcceptMessage(dm messages.ConnectionAcceptMessage) ([]byte, error)

func (*MockEncoderDecoder) EncodeConnectionFailedMessage

func (m *MockEncoderDecoder) EncodeConnectionFailedMessage(dm messages.ConnectionFailedMessage) ([]byte, error)

func (*MockEncoderDecoder) EncodeConnectionOpenMessage

func (m *MockEncoderDecoder) EncodeConnectionOpenMessage(dm messages.ConnectionOpenMessage) ([]byte, error)

func (*MockEncoderDecoder) EncodeDataAckMessage

func (m *MockEncoderDecoder) EncodeDataAckMessage(dm messages.DataAckMessage) ([]byte, error)

func (*MockEncoderDecoder) EncodeDataMessage

func (m *MockEncoderDecoder) EncodeDataMessage(dm messages.DataMessage) ([]byte, error)

func (*MockEncoderDecoder) EncodeDatagramMessage

func (m *MockEncoderDecoder) EncodeDatagramMessage(dm messages.DatagramMessage) ([]byte, error)