Documentation
¶
Index ¶
- type Handler
- func (h *Handler) Accumulate(ctx context.Context, userID, deviceID, roomID, prevBatch string, ...)
- func (h *Handler) AddToDeviceMessages(ctx context.Context, userID, deviceID string, msgs []json.RawMessage)
- func (h *Handler) EnsurePolling(p *pubsub.V3EnsurePolling)
- func (h *Handler) Initialise(ctx context.Context, roomID string, state []json.RawMessage) []json.RawMessage
- func (h *Handler) Listen()
- func (h *Handler) OnAccountData(ctx context.Context, userID, roomID string, events []json.RawMessage)
- func (h *Handler) OnBulkDeviceDataUpdate(payload *pubsub.V2DeviceData)
- func (h *Handler) OnE2EEData(ctx context.Context, userID, deviceID string, otkCounts map[string]int, ...)
- func (h *Handler) OnExpiredToken(ctx context.Context, accessTokenHash, userID, deviceID string)
- func (h *Handler) OnInvite(ctx context.Context, userID, roomID string, inviteState []json.RawMessage)
- func (h *Handler) OnLeftRoom(ctx context.Context, userID, roomID string)
- func (h *Handler) OnReceipt(ctx context.Context, userID, roomID, ephEventType string, ...)
- func (h *Handler) OnTerminated(ctx context.Context, userID, deviceID string)
- func (h *Handler) SetTyping(ctx context.Context, roomID string, ephEvent json.RawMessage)
- func (h *Handler) StartV2Pollers()
- func (h *Handler) Teardown()
- func (h *Handler) UpdateDeviceSince(ctx context.Context, userID, deviceID, since string)
- func (h *Handler) UpdateUnreadCounts(ctx context.Context, roomID, userID string, highlightCount, notifCount *int)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
Handler is responsible for starting v2 pollers at startup; processing v2 data (as a sync2.V2DataReceiver) and publishing updates (pubsub.Payload to V2Listeners); and receiving and processing EnsurePolling events.
func NewHandler ¶
func (*Handler) Accumulate ¶
func (*Handler) AddToDeviceMessages ¶
func (*Handler) EnsurePolling ¶
func (h *Handler) EnsurePolling(p *pubsub.V3EnsurePolling)
func (*Handler) Initialise ¶
func (h *Handler) Initialise(ctx context.Context, roomID string, state []json.RawMessage) []json.RawMessage
func (*Handler) OnAccountData ¶
func (*Handler) OnBulkDeviceDataUpdate ¶ added in v0.99.4
func (h *Handler) OnBulkDeviceDataUpdate(payload *pubsub.V2DeviceData)
Called periodically by deviceDataTicker, contains many updates
func (*Handler) OnE2EEData ¶
func (*Handler) OnExpiredToken ¶ added in v0.99.2
func (*Handler) OnLeftRoom ¶
func (*Handler) OnTerminated ¶
func (*Handler) StartV2Pollers ¶
func (h *Handler) StartV2Pollers()
func (*Handler) UpdateDeviceSince ¶
Emits nothing as no downstream components need it.
Source Files
Click to show internal directories.
Click to hide internal directories.