type github.com/gotd/td/rpc.Engine
15 uses
github.com/gotd/td/rpc (current package)
ack.go#L10: func (e *Engine) NotifyAcks(ids []int64) {
ack.go#L26: func (e *Engine) waitAck(id int64) chan struct{} {
ack.go#L43: func (e *Engine) removeAck(id int64) {
engine.go#L17: type Engine struct {
engine.go#L39: func New(send Send, cfg Options) *Engine {
engine.go#L49: return &Engine{
engine.go#L76: func (e *Engine) Do(ctx context.Context, req Request) error {
engine.go#L189: func (e *Engine) retryUntilAck(ctx context.Context, req Request) (sent bool, err error) {
engine.go#L257: func (e *Engine) NotifyResult(msgID int64, b *bin.Buffer) error {
engine.go#L270: func (e *Engine) NotifyError(msgID int64, rpcErr error) {
engine.go#L283: func (e *Engine) isClosed() bool {
engine.go#L290: func (e *Engine) Close() {
engine.go#L299: func (e *Engine) ForceClose() {
github.com/gotd/td/mtproto
conn.go#L57: rpc *rpc.Engine
options.go#L94: engine *rpc.Engine
![]() |
The pages are generated with Golds v0.8.4. (GOOS=linux GOARCH=amd64) Golds is a Go 101 project developed by Tapir Liu. PR and bug reports are welcome and can be submitted to the issue list. Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds. |