dao

Documentation

Index

• type Dao
  • func New(c config.Config) *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 NewSession(c zrpc.RpcClientConf, options SessionOptions) (*Session, error)
  • 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

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 New

func New(c config.Config) *Dao

func (*Dao) AddSeqToUpdatesQueue

func (d *Dao) AddSeqToUpdatesQueue(ctx context.Context, authId, userId int64, updateType int32, updateData []byte) int32

func (*Dao) AddToPtsQueue

func (d *Dao) AddToPtsQueue(ctx context.Context, userId int64, pts, ptsCount int32, update *mtproto.Update) int32

func (*Dao) PushRpcResultToSession

func (d *Dao) PushRpcResultToSession(ctx context.Context, serverId string, msg *session.TLSessionPushRpcResultData) (err error)

func (*Dao) PushSessionUpdatesToSession

func (d *Dao) PushSessionUpdatesToSession(ctx context.Context, serverId string, msg *session.TLSessionPushSessionUpdatesData) (err error)

func (*Dao) PushUpdatesToSession

func (d *Dao) PushUpdatesToSession(ctx context.Context, serverId string, msg *session.TLSessionPushUpdatesData) (err error)

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) Close

func (c *Session) Close() (err error)

func (*Session) PushRpcResult

func (c *Session) PushRpcResult(ctx context.Context, msg *session.TLSessionPushRpcResultData) (err error)

func (*Session) PushSessionUpdates

func (c *Session) PushSessionUpdates(ctx context.Context, msg *session.TLSessionPushSessionUpdatesData) (err error)

func (*Session) PushUpdates

func (c *Session) PushUpdates(ctx context.Context, msg *session.TLSessionPushUpdatesData) (err error)

type SessionOptions

type SessionOptions struct {
	RoutineSize uint64
	RoutineChan uint64
}

SessionOptions comet options.