Documentation ¶
Index ¶
- type SyncMng
- func (sm *SyncMng) FillSortEventOffset(res *syncapitypes.Response, req *request)
- func (sm *SyncMng) GetOnlineRepo() *repos.OnlineUserRepo
- func (sm *SyncMng) GetPushkeyByUserDeviceID(userID, deviceID string) []types.PushKeyContent
- func (sm *SyncMng) OnStateChange(state *types.NotifyDeviceState)
- func (sm *SyncMng) OnSyncRequest(ctx context.Context, req *types.HttpReq, device *authtypes.Device) (int, *syncapitypes.Response)
- func (sm *SyncMng) OnUserStateChange(state *types.NotifyUserState)
- func (sm *SyncMng) SetCache(cache service.Cache) *SyncMng
- func (sm *SyncMng) SetClientDataStreamRepo(clientDataStreamRepo *repos.ClientDataStreamRepo) *SyncMng
- func (sm *SyncMng) SetComplexCache(complexCache *common.ComplexCache) *SyncMng
- func (sm *SyncMng) SetKeyChangeRepo(kChangeRepo *repos.KeyChangeStreamRepo) *SyncMng
- func (sm *SyncMng) SetOnlineRepo(onlineRepo *repos.OnlineUserRepo) *SyncMng
- func (sm *SyncMng) SetPresenceStreamRepo(presenceStreamRepo *repos.PresenceDataStreamRepo) *SyncMng
- func (sm *SyncMng) SetStdEventStreamRepo(stdEventRepo *repos.STDEventStreamRepo) *SyncMng
- func (sm *SyncMng) SetTypingConsumer(typingConsumer *consumers.TypingConsumer) *SyncMng
- func (sm *SyncMng) SetUserDeviceActiveTsRepo(userDeviceActiveTsRepo *repos.UserDeviceActiveRepo) *SyncMng
- func (sm *SyncMng) SetUserTimeLine(userTimeLine *repos.UserTimeLineRepo) *SyncMng
- func (sm *SyncMng) Start()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SyncMng ¶
type SyncMng struct {
// contains filtered or unexported fields
}
func NewSyncMng ¶
func (*SyncMng) FillSortEventOffset ¶
func (sm *SyncMng) FillSortEventOffset(res *syncapitypes.Response, req *request)
func (*SyncMng) GetOnlineRepo ¶
func (sm *SyncMng) GetOnlineRepo() *repos.OnlineUserRepo
func (*SyncMng) GetPushkeyByUserDeviceID ¶
func (sm *SyncMng) GetPushkeyByUserDeviceID(userID, deviceID string) []types.PushKeyContent
func (*SyncMng) OnStateChange ¶
func (sm *SyncMng) OnStateChange(state *types.NotifyDeviceState)
func (*SyncMng) OnSyncRequest ¶
func (*SyncMng) OnUserStateChange ¶
func (sm *SyncMng) OnUserStateChange(state *types.NotifyUserState)
func (*SyncMng) SetClientDataStreamRepo ¶
func (sm *SyncMng) SetClientDataStreamRepo(clientDataStreamRepo *repos.ClientDataStreamRepo) *SyncMng
func (*SyncMng) SetComplexCache ¶
func (sm *SyncMng) SetComplexCache(complexCache *common.ComplexCache) *SyncMng
func (*SyncMng) SetKeyChangeRepo ¶
func (sm *SyncMng) SetKeyChangeRepo(kChangeRepo *repos.KeyChangeStreamRepo) *SyncMng
func (*SyncMng) SetOnlineRepo ¶
func (sm *SyncMng) SetOnlineRepo(onlineRepo *repos.OnlineUserRepo) *SyncMng
func (*SyncMng) SetPresenceStreamRepo ¶
func (sm *SyncMng) SetPresenceStreamRepo(presenceStreamRepo *repos.PresenceDataStreamRepo) *SyncMng
func (*SyncMng) SetStdEventStreamRepo ¶
func (sm *SyncMng) SetStdEventStreamRepo(stdEventRepo *repos.STDEventStreamRepo) *SyncMng
func (*SyncMng) SetTypingConsumer ¶
func (sm *SyncMng) SetTypingConsumer(typingConsumer *consumers.TypingConsumer) *SyncMng
func (*SyncMng) SetUserDeviceActiveTsRepo ¶
func (sm *SyncMng) SetUserDeviceActiveTsRepo(userDeviceActiveTsRepo *repos.UserDeviceActiveRepo) *SyncMng
func (*SyncMng) SetUserTimeLine ¶
func (sm *SyncMng) SetUserTimeLine(userTimeLine *repos.UserTimeLineRepo) *SyncMng
Click to show internal directories.
Click to hide internal directories.