core

Documentation

Index

• type UpdatesCore
  • func New(ctx context.Context, svcCtx *svc.ServiceContext) *UpdatesCore
  • func (c *UpdatesCore) GetMergedUpdateList(userId int64, authId int64, pts, date, limit int32) ([]*mtproto.Update, int32, int32, int64)
  • func (c *UpdatesCore) UpdatesGetChannelDifferenceV2(in *updates.TLUpdatesGetChannelDifferenceV2) (*updates.ChannelDifference, error)
  • func (c *UpdatesCore) UpdatesGetDifferenceV2(in *updates.TLUpdatesGetDifferenceV2) (*updates.Difference, error)
  • func (c *UpdatesCore) UpdatesGetState(in *updates.TLUpdatesGetState) (*mtproto.Updates_State, error)

Types

type UpdatesCore

type UpdatesCore struct {
	logx.Logger
	MD *metadata.RpcMetadata
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, svcCtx *svc.ServiceContext) *UpdatesCore

func (*UpdatesCore) GetMergedUpdateList

func (c *UpdatesCore) GetMergedUpdateList(userId int64, authId int64, pts, date, limit int32) ([]*mtproto.Update, int32, int32, int64)

func (*UpdatesCore) UpdatesGetChannelDifferenceV2

func (c *UpdatesCore) UpdatesGetChannelDifferenceV2(in *updates.TLUpdatesGetChannelDifferenceV2) (*updates.ChannelDifference, error)

UpdatesGetChannelDifferenceV2 updates.getChannelDifferenceV2 auth_key_id:long user_id:long channel_id:long pts:int limit:int = ChannelDifference;

func (*UpdatesCore) UpdatesGetDifferenceV2

func (c *UpdatesCore) UpdatesGetDifferenceV2(in *updates.TLUpdatesGetDifferenceV2) (*updates.Difference, error)

UpdatesGetDifferenceV2 updates.getDifferenceV2 flags:# auth_key_id:long user_id:long pts:int pts_total_limit:flags.0?int date:long = Difference;

func (*UpdatesCore) UpdatesGetState

func (c *UpdatesCore) UpdatesGetState(in *updates.TLUpdatesGetState) (*mtproto.Updates_State, error)

UpdatesGetState updates.getState auth_key_id:long user_id:long = updates.State;