mtproto

Feb 25, 2024

Changes in this version

type Conn

+ func (c *Conn) Invoke(ctx context.Context, input bin.Encoder, output bin.Decoder) error

+ type Dialer func(ctx context.Context) (transport.Conn, error)

+ type MessageBuf interface

+ Consume func(id int64) bool

type Options

+ CompressThreshold int

+ DC int

+ PingInterval time.Duration

+ PingTimeout time.Duration

+ RequestTimeout func(req uint32) time.Duration

+ SaltFetchInterval time.Duration

+ Tracer trace.Tracer

Feb 17, 2021

Changes in this version

type Options

+ DialTimeout time.Duration

+ ExchangeTimeout time.Duration

Feb 6, 2021

Changes in this version

+ const ErrFloodWait

+ func AsFloodWait(err error) (d time.Duration, ok bool)

+ func IsErr(err error, tt ...string) bool

+ func IsErrCode(err error, code ...int) bool

type Error

+ func AsErr(err error) (rpcErr *Error, ok bool)

+ func AsTypeErr(err error, t string) (rpcErr *Error, ok bool)

+ func NewError(code int, msg string) *Error

+ func (e *Error) IsCode(code int) bool

+ func (e *Error) IsCodeOneOf(codes ...int) bool

+ func (e *Error) IsOneOf(tt ...string) bool

+ func (e *Error) IsType(t string) bool

Jan 8, 2021

Changes in this version

+ type Cipher interface

+ DecryptFromBuffer func(k crypto.AuthKey, buf *bin.Buffer) (*crypto.EncryptedMessageData, error)

+ Encrypt func(key crypto.AuthKey, data crypto.EncryptedMessageData, b *bin.Buffer) error

type Options

+ Cipher Cipher

Jan 5, 2021

Changes in this version

type Conn

+ func New(addr string, opt Options) *Conn

+ func (c *Conn) Run(ctx context.Context, f func(ctx context.Context) error) error

type Handler

+ OnMessage func(b *bin.Buffer) error

+ OnSession func(session Session) error

type Options

+ ReadConcurrency int

type Session

+ ID int64

Jan 4, 2021

Changes in this version

+ type Conn struct

+ func NewConn(addr string, opt Options) *Conn

+ func (c *Conn) Close() error

+ func (c *Conn) Connect(ctx context.Context) (err error)

+ func (c *Conn) InvokeRaw(ctx context.Context, input bin.Encoder, output bin.Decoder) error

+ func (c *Conn) Ping(ctx context.Context) error

+ func (c *Conn) Reconnect(ctx context.Context) error

+ func (c *Conn) Session() Session

+ type Error struct

+ Argument int

+ Code int

+ Message string

+ Type string

+ func (e *Error) ExtractArgument()

+ func (e Error) Error() string

+ type Handler func(b *bin.Buffer) error

+ type MessageIDSource interface

+ New func(t proto.MessageType) int64

+ type Options struct

+ AckBatchSize int

+ AckInterval time.Duration

+ Clock clock.Clock

+ Handler Handler

+ Key crypto.AuthKeyWithID

+ Logger *zap.Logger

+ MaxRetries int

+ MessageID MessageIDSource

+ Network string

+ OnReconnect func() error

+ PublicKeys []*rsa.PublicKey

+ Random io.Reader

+ RetryInterval time.Duration

+ Salt int64

+ Transport Transport

+ Types *tmap.Map

+ type Session struct

+ Key crypto.AuthKeyWithID

+ Salt int64

+ type Transport interface

+ Codec func() transport.Codec

+ DialContext func(ctx context.Context, network, address string) (transport.Conn, error)