Documentation
¶
Index ¶
- type Dao
- func (d *Dao) AddSeqToUpdatesQueue(ctx context.Context, authId, userId int64, updateType int32, updateData []byte) int32
- func (d *Dao) AddToPtsQueue(ctx context.Context, userId int64, pts, ptsCount int32, update *mtproto.Update) int32
- func (d *Dao) PushRpcResultToSession(ctx context.Context, serverId string, msg *session.TLSessionPushRpcResultData) (err error)
- func (d *Dao) PushSessionUpdatesToSession(ctx context.Context, serverId string, ...) (err error)
- func (d *Dao) PushUpdatesToSession(ctx context.Context, serverId string, msg *session.TLSessionPushUpdatesData) (err error)
- type Mysql
- type Session
- func (c *Session) Close() (err error)
- func (c *Session) PushRpcResult(ctx context.Context, msg *session.TLSessionPushRpcResultData) (err error)
- func (c *Session) PushSessionUpdates(ctx context.Context, msg *session.TLSessionPushSessionUpdatesData) (err error)
- func (c *Session) PushUpdates(ctx context.Context, msg *session.TLSessionPushUpdatesData) (err error)
- type SessionOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dao ¶
type Dao struct { *Mysql idgen_client.IDGenClient2 status_client.StatusClient chat_client.ChatClient PushClient sync_client.SyncClient // contains filtered or unexported fields }
func (*Dao) AddSeqToUpdatesQueue ¶
func (*Dao) AddToPtsQueue ¶
func (*Dao) PushRpcResultToSession ¶
func (*Dao) PushSessionUpdatesToSession ¶
func (*Dao) PushUpdatesToSession ¶
type Mysql ¶
type Mysql struct { *sqlx.DB *mysql_dao.AuthSeqUpdatesDAO *mysql_dao.UserPtsUpdatesDAO *sqlx.CommonDAO }
type Session ¶
type Session struct {
// contains filtered or unexported fields
}
Session is a gateway.
func NewSession ¶
func NewSession(c zrpc.RpcClientConf, options SessionOptions) (*Session, error)
NewSession new a comet.
func (*Session) PushRpcResult ¶
func (*Session) PushSessionUpdates ¶
func (*Session) PushUpdates ¶
type SessionOptions ¶
SessionOptions comet options.
Click to show internal directories.
Click to hide internal directories.