handler

Nov 9, 2023

Changes in this version

type ConnState

+ func (s *ConnState) SetCancelCallback(cancel context.CancelFunc)

type SyncLiveHandler

+ func (h *SyncLiveHandler) OnStateRedaction(p *pubsub.V2StateRedaction)

Oct 11, 2023

Changes in this version

type SyncLiveHandler

+ func (h *SyncLiveHandler) OnInvalidateRoom(p *pubsub.V2InvalidateRoom)

Aug 23, 2023

Changes in this version

type JoinChecker

+ IsUserInvited func(userID, roomID string) bool

Aug 2, 2023

Changes in this version

type ConnState

+ func (s *ConnState) PublishEventsUpTo(roomID string, nid int64)

+ type TxnIDWaiter struct

+ func NewTxnIDWaiter(userID string, maxDelay time.Duration, publish func(bool, caches.Update)) *TxnIDWaiter

+ func (t *TxnIDWaiter) Ingest(up caches.Update)

+ func (t *TxnIDWaiter) PublishUpToNID(roomID string, publishNID int64)

Jun 19, 2023

Changes in this version

type EnsurePoller

+ func (p *EnsurePoller) OnExpiredToken(payload *pubsub.V2ExpiredToken)

type SyncLiveHandler

+ EnsurePoller *EnsurePoller

+ func (h *SyncLiveHandler) OnTransactionID(p *pubsub.V2TransactionID)

Apr 27, 2023

Changes in this version

type SyncLiveHandler

+ func (h *SyncLiveHandler) OnExpiredToken(p *pubsub.V2ExpiredToken)

Feb 24, 2023

Changes in this version

+ var BufferWaitTime = time.Second * 5

Jan 12, 2023

Changes in this version

type SyncLiveHandler

+ func (h *SyncLiveHandler) OnDeviceMessages(p *pubsub.V2DeviceMessages)

Dec 16, 2022

Changes in this version

+ const DefaultSessionID

+ var MaxPendingEventUpdates = 2000

+ type BuiltSubscription struct

+ RoomIDs []string

+ RoomSubscription sync3.RoomSubscription

+ type ConnState struct

+ func NewConnState(userID, deviceID string, userCache *caches.UserCache, ...) *ConnState

+ func (s *ConnState) Alive() bool

+ func (s *ConnState) Destroy()

+ func (s *ConnState) OnIncomingRequest(ctx context.Context, cid sync3.ConnID, req *sync3.Request, isInitial bool) (*sync3.Response, error)

+ func (s *ConnState) OnRoomUpdate(up caches.RoomUpdate)

+ func (s *ConnState) OnUpdate(up caches.Update)

+ func (s *ConnState) UserID() string

+ type EnsurePoller struct

+ func NewEnsurePoller(notifier pubsub.Notifier) *EnsurePoller

+ func (p *EnsurePoller) EnsurePolling(userID, deviceID string)

+ func (p *EnsurePoller) OnInitialSyncComplete(payload *pubsub.V2InitialSyncComplete)

+ func (p *EnsurePoller) Teardown()

+ type JoinChecker interface

+ IsUserJoined func(userID, roomID string) bool

+ type LazyCache struct

+ func NewLazyCache() *LazyCache

+ func (lc *LazyCache) Add(roomID string, userIDs ...string)

+ func (lc *LazyCache) AddUser(roomID, userID string) bool

+ func (lc *LazyCache) IsLazyLoading(roomID string) bool

+ func (lc *LazyCache) IsSet(roomID, userID string) bool

+ type RoomsBuilder struct

+ func NewRoomsBuilder() *RoomsBuilder

+ func (rb *RoomsBuilder) AddRoomsToSubscription(id int, roomIDs []string)

+ func (rb *RoomsBuilder) AddSubscription(rs sync3.RoomSubscription) (id int)

+ func (rb *RoomsBuilder) BuildSubscriptions() (result []BuiltSubscription)

+ func (rb *RoomsBuilder) IncludesRoom(roomID string) bool

+ type SyncLiveHandler struct

+ ConnMap *sync3.ConnMap

+ Dispatcher *sync3.Dispatcher

+ Extensions *extensions.Handler

+ GlobalCache *caches.GlobalCache

+ Storage *state.Storage

+ V2 sync2.Client

+ V2Store *sync2.Storage

+ V2Sub *pubsub.V2Sub

+ V3Pub *EnsurePoller

+ func NewSync3Handler(store *state.Storage, storev2 *sync2.Storage, v2Client sync2.Client, ...) (*SyncLiveHandler, error)

+ func (h *SyncLiveHandler) Accumulate(p *pubsub.V2Accumulate)

+ func (h *SyncLiveHandler) CacheForUser(userID string) *caches.UserCache

+ func (h *SyncLiveHandler) DeviceData(userID, deviceID string, isInitial bool) *internal.DeviceData

+ func (h *SyncLiveHandler) Initialise(p *pubsub.V2Initialise)

+ func (h *SyncLiveHandler) Listen()

+ func (h *SyncLiveHandler) OnAccountData(p *pubsub.V2AccountData)

+ func (h *SyncLiveHandler) OnDeviceData(p *pubsub.V2DeviceData)

+ func (h *SyncLiveHandler) OnInitialSyncComplete(p *pubsub.V2InitialSyncComplete)

+ func (h *SyncLiveHandler) OnInvite(p *pubsub.V2InviteRoom)

+ func (h *SyncLiveHandler) OnLeftRoom(p *pubsub.V2LeaveRoom)

+ func (h *SyncLiveHandler) OnReceipt(p *pubsub.V2Receipt)

+ func (h *SyncLiveHandler) OnTyping(p *pubsub.V2Typing)

+ func (h *SyncLiveHandler) OnUnreadCounts(p *pubsub.V2UnreadCounts)

+ func (h *SyncLiveHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (h *SyncLiveHandler) Startup(storeSnapshot *state.StartupSnapshot) error

+ func (h *SyncLiveHandler) Teardown()

+ func (h *SyncLiveHandler) TransactionIDForEvents(userID string, eventIDs []string) (eventIDToTxnID map[string]string)