tgtest

Mar 25, 2021

Changes in this version

type Server

+ func (s *Server) SendBool(req *Request, r bool) error

+ func (s *Server) SendErr(req *Request, e *tgerr.Error) error

Mar 22, 2021

Changes in this version

+ type Dispatcher struct

+ func NewDispatcher() *Dispatcher

+ func (d *Dispatcher) Fallback(h Handler) *Dispatcher

+ func (d *Dispatcher) Handle(id uint32, h Handler) *Dispatcher

+ func (d *Dispatcher) HandleFunc(id uint32, h func(server *Server, req *Request) error) *Dispatcher

+ func (d *Dispatcher) OnMessage(server *Server, req *Request) error

+ func (d *Dispatcher) Result(id uint32, msg bin.Encoder) *Dispatcher

+ func (d *Dispatcher) Vector(id uint32, msgs ...bin.Encoder) *Dispatcher

+ type Quorum struct

+ func NewQuorum(codec func() transport.Codec) *Quorum

+ func (q *Quorum) Common() *Dispatcher

+ func (q *Quorum) Config() tg.Config

+ func (q *Quorum) DC(id int, name string) *Server

+ func (q *Quorum) Dispatch(id int, name string) *Dispatcher

+ func (q *Quorum) Keys() []*rsa.PublicKey

+ func (q *Quorum) Ready() <-chan struct{}

+ func (q *Quorum) Up(ctx context.Context) error

+ func (q *Quorum) WithLogger(log *zap.Logger) *Quorum

+ type Request struct

+ Buf *bin.Buffer

+ DC int

+ MsgID int64

+ RequestCtx context.Context

+ Session Session

type Server

+ func (s *Server) Dispatcher() *Dispatcher

+ func (s *Server) SendVector(req *Request, msgs ...bin.Encoder) error

Mar 14, 2021

Changes in this version

type Server

+ func (s *Server) SendEternalSalt(k Session, msgID int64) error

+ func (s *Server) SendFutureSalts(k Session, msgID int64, salts ...proto.FutureSalt) error

Jan 17, 2021

Changes in this version

type Server

+ func (s *Server) AddSession(key crypto.AuthKey)

Dec 27, 2020

Changes in this version

+ type BufferedConn struct

+ func NewBufferedConn(conn transport.Conn) *BufferedConn

+ func (c *BufferedConn) Close() error

+ func (c *BufferedConn) Push(b *bin.Buffer)

+ func (c *BufferedConn) Recv(ctx context.Context, b *bin.Buffer) error

+ func (c *BufferedConn) Send(ctx context.Context, b *bin.Buffer) error

Dec 26, 2020

Changes in this version

type Server

+ func (s *Server) Serve() error

Dec 22, 2020

Changes in this version

+ type HandlerFunc func(s Session, msgID int64, in *bin.Buffer) error

+ func (h HandlerFunc) OnMessage(s Session, msgID int64, in *bin.Buffer) error

type Server

+ func TestTransport(s Suite, message string, codec func() transport.Codec) *Server

+ func (s *Server) ForceDisconnect(k Session)

+ func (s *Server) SendAck(k Session, ids ...int64) error

+ func (s *Server) SendConfig(k Session, id int64) error

+ func (s *Server) SendPong(k Session, msgID, pingID int64) error

+ func (s *Server) SendUpdates(k Session, updates ...tg.UpdateClass) error

+ func (s *Server) SetHandlerFunc(handler func(s Session, msgID int64, in *bin.Buffer) error)

+ type Suite struct

+ Ctx context.Context

+ Log *zap.Logger

+ func NewSuite(ctx context.Context, tb testing.TB, log *zap.Logger) Suite

Dec 19, 2020

Changes in this version

type Server

+ func (s *Server) Addr() net.Addr

type TB

+ Fatal func(args ...interface{})

Dec 18, 2020

Changes in this version

+ type Handler interface

+ OnMessage func(s Session, msgID int64, in *bin.Buffer) error

+ OnNewClient func(s Session) error

type Server

+ func (s *Server) Send(k Session, encoder bin.Encoder) error

+ func (s *Server) SendResult(k Session, id int64, msg bin.Encoder) error

+ func (s *Server) SetHandler(handler Handler)

+ type Session struct

+ Key crypto.AuthKey

+ SessionID int64

Dec 5, 2020

Changes in this version

+ type Server struct

+ Listener net.Listener

+ func NewServer(tb TB) *Server

+ func NewUnstartedServer(tb TB) *Server

+ func (s *Server) Close()

+ func (s *Server) Key() *rsa.PublicKey

+ func (s *Server) Start()

+ type TB interface

+ Log func(args ...interface{})

+ Logf func(format string, args ...interface{})