codec

Documentation

Overview

Package codec contains MTProto transport encoding implementations.

See https://core.telegram.org/mtproto/mtproto-transports

Index

• Constants
• Variables
• type Full
  • func (i *Full) Read(r io.Reader, b *bin.Buffer) error
  • func (i *Full) ReadHeader(r io.Reader) (err error)
  • func (i *Full) Write(w io.Writer, b *bin.Buffer) error
  • func (i *Full) WriteHeader(w io.Writer) (err error)
• type Intermediate
  • func (i Intermediate) Read(r io.Reader, b *bin.Buffer) error
  • func (i Intermediate) ReadHeader(r io.Reader) (err error)
  • func (i Intermediate) Write(w io.Writer, b *bin.Buffer) error
  • func (i Intermediate) WriteHeader(w io.Writer) (err error)
• type ProtocolErr
  • func (p ProtocolErr) Error() string

Constants

const (
	// CodeAuthKeyNotFound means that specified auth key ID cannot be found by the DC.
	CodeAuthKeyNotFound = 404

	// CodeTransportFlood means that too many transport connections are
	// established to the same IP in a too short lapse of time, or if any
	// of the container/service message limits are reached.
	CodeTransportFlood = 429
)

Variables

var ErrProtocolHeaderMismatch = errors.New("protocol header mismatch")

ErrProtocolHeaderMismatch means that received protocol header is mismatched with expected.

var IntermediateClientStart = [4]byte{0xee, 0xee, 0xee, 0xee}

IntermediateClientStart is starting bytes sent by client in Intermediate mode.

Note that server does not respond with it.

Types

type Full

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

Full is full MTProto transport.

See https://core.telegram.org/mtproto/mtproto-transports#full

func (*Full) Read

func (i *Full) Read(r io.Reader, b *bin.Buffer) error

Read fills buffer with received message.

func (*Full) ReadHeader

func (i *Full) ReadHeader(r io.Reader) (err error)

ReadHeader reads protocol tag.

func (*Full) Write

func (i *Full) Write(w io.Writer, b *bin.Buffer) error

Write encode to writer message from given buffer.

func (*Full) WriteHeader

func (i *Full) WriteHeader(w io.Writer) (err error)

WriteHeader sends protocol tag.

type Intermediate

type Intermediate struct{}

Intermediate is intermediate MTProto transport.

See https://core.telegram.org/mtproto/mtproto-transports#intermediate

func (Intermediate) Read

func (i Intermediate) Read(r io.Reader, b *bin.Buffer) error

Read fills buffer with received message.

func (Intermediate) ReadHeader

func (i Intermediate) ReadHeader(r io.Reader) (err error)

ReadHeader reads protocol tag.

func (Intermediate) Write

func (i Intermediate) Write(w io.Writer, b *bin.Buffer) error

Write encode to writer message from given buffer.

func (Intermediate) WriteHeader

func (i Intermediate) WriteHeader(w io.Writer) (err error)

WriteHeader sends protocol tag.

type ProtocolErr

type ProtocolErr struct {
	Code int32
}

ProtocolErr represents protocol level error.

func (ProtocolErr) Error

func (p ProtocolErr) Error() string