github.com/gotd/td/clock.Clock.Now (method)

47 uses

	github.com/gotd/td/clock (current package)
		clock.go#L12: 	Now() time.Time

	github.com/gotd/td/exchange
		client_flow.go#L69: 	start := c.clock.Now()
		client_flow.go#L76: 	c.log.Debug(ctx, "PQ decomposing complete", log.Duration("took", c.clock.Now().Sub(start)))
		client_flow.go#L289: 				result.ExpiresAt = c.clock.Now().Unix() + int64(c.expiresIn)
		proto.go#L31: 		MessageID:   int64(proto.NewMessageID(w.clock.Now(), w.output)),
		server_flow.go#L242: 		ServerTime:  int(s.clock.Now().Unix()),

	github.com/gotd/td/mtproto
		ack.go#L19: 		start := c.clock.Now()
		ack.go#L29: 			log.Duration("elapsed", c.clock.Now().Sub(start)),
		bind.go#L61: 		expiresAt = c.clock.Now().Unix() + int64(c.tempKeyTTL)
		bind.go#L202: 	return c.clock.Now().Unix()-createdAt > 60
		connect.go#L54: 		start := c.clock.Now()
		connect.go#L60: 			log.Duration("duration", c.clock.Now().Sub(start)),
		connect.go#L82: 		start := c.clock.Now()
		connect.go#L87: 			log.Duration("duration", c.clock.Now().Sub(start)),
		connect.go#L95: 	start := c.clock.Now()
		connect.go#L100: 		log.Duration("duration", c.clock.Now().Sub(start)),
		connect.go#L172: 	c.permKeyCreatedAt = c.clock.Now().Unix()
		connect.go#L191: 		expiresAt = c.clock.Now().Unix() + int64(c.tempKeyTTL)
		handle_session_created.go#L23: 	now := c.clock.Now()
		options.go#L168: 		opt.MessageID = proto.NewMessageIDGen(opt.Clock.Now)
		pfs.go#L33: 			expiresAt = c.clock.Now().Unix() + int64(c.tempKeyTTL)
		pfs.go#L38: 		wait := time.Unix(renewAt, 0).Sub(c.clock.Now())
		ping.go#L111: 			start := c.clock.Now()
		ping.go#L124: 					log.Duration("elapsed", c.clock.Now().Sub(start)),
		ping.go#L128: 			logger.Debug(ctx, "Ping acknowledged", log.Duration("elapsed", c.clock.Now().Sub(start)))
		read.go#L63: 	if err := checkMessageID(c.clock.Now(), msg.MessageID); err != nil {
		read.go#L96: 		start := c.clock.Now()
		read.go#L101: 			if waited := c.clock.Now().Sub(start); waited > slowWriteThreshold {
		salt.go#L26: 	salt, ok := c.salts.Get(c.clock.Now().Add(time.Minute * 5))
		write.go#L31: 	start := c.clock.Now()
		write.go#L43: 	locked := c.clock.Now()
		write.go#L67: 		logger.Debug(ctx, "Send failed", log.Error(err), log.Duration("elapsed", c.clock.Now().Sub(locked)))
		write.go#L71: 	if elapsed := c.clock.Now().Sub(locked); elapsed > slowWriteThreshold {

	github.com/gotd/td/mtproxy/faketls
		client_hello.go#L99: 	old ^= uint32(now.Now().Unix())

	github.com/gotd/td/tdsync
		log_group.go#L41: 		start := g.clock.Now()
		log_group.go#L46: 			elapsed := g.clock.Now().Sub(start)
		log_group.go#L51: 		elapsed := g.clock.Now().Sub(start)

	github.com/gotd/td/telegram
		options.go#L182: 		opt.MessageID = proto.NewMessageIDGen(opt.Clock.Now)

	github.com/gotd/td/telegram/auth/qrlogin
		qrlogin.go#L153: 		return token.Expires().Sub(q.clock.Now()).Truncate(time.Second)

	github.com/gotd/td/telegram/internal/manager
		conn.go#L137: 	start := c.clock.Now()
		conn.go#L150: 		end := c.clock.Now()
		conn.go#L193: 	start := c.clock.Now()
		conn.go#L198: 		c.log.Debug(ctx, "Connection became ready", log.Duration("waited", c.clock.Now().Sub(start)))
		conn.go#L201: 		c.log.Debug(ctx, "Connection died while waiting for readiness", log.Duration("waited", c.clock.Now().Sub(start)))
		conn.go#L205: 			log.Duration("waited", c.clock.Now().Sub(start)),
		conn.go#L347: 		c.latest = c.clock.Now()
		conn.go#L401: 	c.latest = c.clock.Now()