sync3

Dec 6, 2022

Changes in this version

type Room

+ NumLive int

Nov 29, 2022

Changes in this version

type Dispatcher

+ func (d *Dispatcher) OnEphemeralEvent(roomID string, ephEvent json.RawMessage)

Nov 22, 2022

Changes in this version

type Dispatcher

+ func (d *Dispatcher) OnTyping(roomID string, ephEvent json.RawMessage)

type Receiver

+ OnEphemeralEvent func(roomID string, ephEvent json.RawMessage)

Oct 31, 2022

Changes in this version

+ var StateKeyLazy = "$LAZY"

+ var StateKeyMe = "$ME"

+ var Wildcard = "*"

type RoomSubscription

+ func (rs RoomSubscription) LazyLoadMembers() bool

Oct 24, 2022

Changes in this version

+ var SortByNotificationLevel = "by_notification_level"

type RoomSubscription

+ IncludeOldRooms *RoomSubscription

Oct 18, 2022

Changes in this version

type Dispatcher

+ func (d *Dispatcher) OnNewInitialRoomState(roomID string, state []json.RawMessage)

type JoinedRoomsTracker

+ func (t *JoinedRoomsTracker) Startup(roomToJoinedUsers map[string][]string)

+ func (t *JoinedRoomsTracker) UsersInvitedToRoom(userIDs []string, roomID string)

+ func (t *JoinedRoomsTracker) UsersJoinedRoom(userIDs []string, roomID string) bool

Oct 12, 2022

Changes in this version

type ConnMap

+ func (m *ConnMap) Len() int

Oct 4, 2022

Changes in this version

type ConnMap

+ func (m *ConnMap) Teardown()

Sep 5, 2022

Changes in this version

type InternalRequestLists

+ func (s *InternalRequestLists) Get(listIndex int) *FilteredSortableRooms

+ func (s *InternalRequestLists) Room(roomID string) *RoomConnMetadata

+ func (s *InternalRequestLists) SetRoom(r RoomConnMetadata) (delta RoomDelta)

type JoinedRoomsTracker

+ func (t *JoinedRoomsTracker) NumInvitedUsersForRoom(roomID string) int

+ func (t *JoinedRoomsTracker) UserInvitedToRoom(userID, roomID string)

+ type List interface

+ Add func(roomID string) bool

+ Get func(index int) string

+ IndexOf func(roomID string) (int, bool)

+ Len func() int64

+ Remove func(roomID string) int

+ Sort func(sortBy []string) error

+ type ListOp uint8

+ var ListOpAdd ListOp = 1

+ var ListOpChange ListOp = 3

+ var ListOpDel ListOp = 2

type ResponseOp

+ func CalculateListOps(reqList *RequestList, list List, roomID string, listOp ListOp) (ops []ResponseOp, subs []string)

type Room

+ InvitedCount int

+ JoinedCount int

+ type RoomDelta struct

+ InviteCountChanged bool

+ JoinCountChanged bool

+ Lists []RoomListDelta

+ RoomNameChanged bool

+ type RoomFinder interface

+ Room func(roomID string) *RoomConnMetadata

+ type RoomListDelta struct

+ ListIndex int

+ Op ListOp

Aug 23, 2022

Changes in this version

type RequestFilters

+ NotTags []string

+ Tags []string

Aug 16, 2022

Changes in this version

type Conn

+ func (c *Conn) UserID() string

type InternalRequestLists

+ func NewInternalRequestLists() *InternalRequestLists

+ func (s *InternalRequestLists) UpdateRoom(metadata *internal.RoomMetadata) (sameRoomName bool)

Aug 5, 2022

Changes in this version

type Request

+ TxnID string

type Response

+ TxnID string

Aug 1, 2022

Changes in this version

type Receiver

+ OnRegistered func(latestPos int64) error

type RequestFilters

+ NotRoomTypes []*string

+ RoomTypes []*string

Jul 21, 2022

Changes in this version

+ type InternalRequestLists struct

+ func (s *InternalRequestLists) AddRoomIfNotExists(room RoomConnMetadata)

+ func (s *InternalRequestLists) AddRooms(rooms []RoomConnMetadata)

+ func (s *InternalRequestLists) AssignList(index int, filters *RequestFilters, sort []string, ...) (*FilteredSortableRooms, bool)

+ func (s *InternalRequestLists) Count(index int) int

+ func (s *InternalRequestLists) DeleteList(index int)

+ func (s *InternalRequestLists) ForEach(fn func(index int, fsr *FilteredSortableRooms))

+ func (s *InternalRequestLists) Len() int

+ func (s *InternalRequestLists) RemoveRoom(roomID string)

+ type OverwriteVal bool

+ var DoNotOverwrite OverwriteVal = false

+ var Overwrite OverwriteVal = true

+ type RequestDelta struct

+ Lists []RequestListDelta

+ Subs []string

+ Unsubs []string

type RequestList

+ SlowGetAllRooms *bool

+ func (rl *RequestList) CalculateMoveIndexes(fromIndex, toIndex int) (fromTos [][2]int, ok bool)

+ func (rl *RequestList) FiltersChanged(next *RequestList) bool

+ func (rl *RequestList) ShouldGetAllRooms() bool

+ func (rl *RequestList) SortOrderChanged(next *RequestList) bool

+ func (rl *RequestList) WriteDeleteOp(deletedIndex int) *ResponseOpSingle

+ func (rl *RequestList) WriteInsertOp(insertedIndex int, roomID string) *ResponseOpSingle

+ func (rl *RequestList) WriteSwapOp(roomID string, fromIndex, toIndex int) []ResponseOp

+ type RequestListDelta struct

+ Curr *RequestList

+ Prev *RequestList

type Response

+ Lists []ResponseList

+ Rooms map[string]Room

+ func (r *Response) ListOps() int

+ type ResponseList struct

+ Count int

+ Ops []ResponseOp

type ResponseOpRange

+ RoomIDs []string

type ResponseOpSingle

+ RoomID string

type RoomSubscription

+ func (rs RoomSubscription) Combine(other RoomSubscription) RoomSubscription

+ func (rs RoomSubscription) RequiredStateMap() *internal.RequiredStateMap

type SliceRanges

+ func (r SliceRanges) ClosestInDirection(i int64, towardsZero bool) (closestIndex int64)

Apr 26, 2022

Changes in this version

type Request

+ func (r *Request) GetRequiredStateForList(listIndex int) [][2]string

+ func (r *Request) GetRequiredStateForRoom(roomID string) [][2]string

Apr 1, 2022

Changes in this version

+ const DispatcherAllUsers

+ const OpDelete

+ const OpInsert

+ const OpInvalidate

+ const OpSync

+ const OpUpdate

+ var DefaultTimelineLimit = int64(20)

+ var DefaultTimeoutMSecs = 10 * 1000

+ var SortBy = []string

+ var SortByHighlightCount = "by_highlight_count"

+ var SortByName = "by_name"

+ var SortByNotificationCount = "by_notification_count"

+ var SortByRecency = "by_recency"

+ func ChangedFilters(prev, next *RequestFilters) bool

+ func IncludedRoomIDsInOps(ops []ResponseOp) map[string]struct

+ type Conn struct

+ ConnID ConnID

+ func NewConn(connID ConnID, h ConnHandler) *Conn

+ func (c *Conn) Alive() bool

+ func (c *Conn) OnIncomingRequest(ctx context.Context, req *Request) (resp *Response, herr *internal.HandlerError)

+ type ConnHandler interface

+ Alive func() bool

+ Destroy func()

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

+ UserID func() string

+ type ConnID struct

+ DeviceID string

+ func (c *ConnID) String() string

+ type ConnMap struct

+ func NewConnMap() *ConnMap

+ func (m *ConnMap) CloseConn(connID ConnID)

+ func (m *ConnMap) Conn(cid ConnID) *Conn

+ func (m *ConnMap) CreateConn(cid ConnID, newConnHandler func() ConnHandler) (*Conn, bool)

+ type Dispatcher struct

+ func NewDispatcher() *Dispatcher

+ func (d *Dispatcher) IsUserJoined(userID, roomID string) bool

+ func (d *Dispatcher) OnNewEvents(roomID string, events []json.RawMessage, latestPos int64)

+ func (d *Dispatcher) Register(userID string, r Receiver)

+ func (d *Dispatcher) Startup(roomToJoinedUsers map[string][]string) error

+ func (d *Dispatcher) Unregister(userID string)

+ type FilteredSortableRooms struct

+ func NewFilteredSortableRooms(rooms []RoomConnMetadata, filter *RequestFilters) *FilteredSortableRooms

+ func (f *FilteredSortableRooms) Add(r RoomConnMetadata) bool

+ func (f *FilteredSortableRooms) UpdateGlobalRoomMetadata(r *internal.RoomMetadata) int

+ func (f *FilteredSortableRooms) UpdateUserRoomMetadata(roomID string, userEvent *caches.UserRoomData) int

+ type JoinedRoomsTracker struct

+ func NewJoinedRoomsTracker() *JoinedRoomsTracker

+ func (t *JoinedRoomsTracker) IsUserJoined(userID, roomID string) bool

+ func (t *JoinedRoomsTracker) JoinedRoomsForUser(userID string) []string

+ func (t *JoinedRoomsTracker) JoinedUsersForRoom(roomID string) []string

+ func (t *JoinedRoomsTracker) UserJoinedRoom(userID, roomID string) bool

+ func (t *JoinedRoomsTracker) UserLeftRoom(userID, roomID string)

+ type Receiver interface

+ OnNewEvent func(event *caches.EventData)

+ type Request struct

+ Extensions extensions.Request

+ Lists []RequestList

+ RoomSubscriptions map[string]RoomSubscription

+ UnsubscribeRooms []string

+ func (r *Request) ApplyDelta(nextReq *Request) (result *Request, subs, unsubs []string)

+ func (r *Request) GetRequiredState(listIndex int, roomID string) [][2]string

+ func (r *Request) GetTimelineLimit(listIndex int, roomID string) int64

+ func (r *Request) Same(other *Request) bool

+ func (r *Request) SetPos(pos int64)

+ func (r *Request) SetTimeoutMSecs(timeout int)

+ func (r *Request) TimeoutMSecs() int

+ type RequestFilters struct

+ IsDM *bool

+ IsEncrypted *bool

+ IsInvite *bool

+ IsTombstoned *bool

+ RoomNameFilter string

+ Spaces []string

+ func (rf *RequestFilters) Include(r *RoomConnMetadata) bool

+ type RequestList struct

+ Filters *RequestFilters

+ Ranges SliceRanges

+ Sort []string

+ type Response struct

+ Counts []int

+ Extensions extensions.Response

+ Ops []ResponseOp

+ Pos string

+ RoomSubscriptions map[string]Room

+ Session string

+ func (r *Response) PosInt() int64

+ func (r *Response) UnmarshalJSON(b []byte) error

+ type ResponseOp interface

+ IncludedRoomIDs func() []string

+ Op func() string

+ type ResponseOpRange struct

+ List int

+ Operation string

+ Range []int64

+ Rooms []Room

+ func (r *ResponseOpRange) IncludedRoomIDs() []string

+ func (r *ResponseOpRange) Op() string

+ type ResponseOpSingle struct

+ Index *int

+ List int

+ Operation string

+ Room *Room

+ func (r *ResponseOpSingle) IncludedRoomIDs() []string

+ func (r *ResponseOpSingle) Op() string

+ type Room struct

+ HighlightCount int64

+ Initial bool

+ InviteState []json.RawMessage

+ IsDM bool

+ Name string

+ NotificationCount int64

+ PrevBatch string

+ RequiredState []json.RawMessage

+ RoomID string

+ Timeline []json.RawMessage

+ type RoomConnMetadata struct

+ CanonicalisedName string

+ type RoomSubscription struct

+ RequiredState [][2]string

+ TimelineLimit int64

+ type SliceRanges [][2]int64

+ func (r SliceRanges) Delta(next SliceRanges) (added SliceRanges, removed SliceRanges, same SliceRanges)

+ func (r SliceRanges) Inside(i int64) bool

+ func (r SliceRanges) LowerClamp(i int64) (clampIndex int64)

+ func (r SliceRanges) SliceInto(slice Subslicer) []Subslicer

+ func (r SliceRanges) UpperClamp(i int64) (clampIndex int64)

+ func (r SliceRanges) Valid() bool

+ type SortableRoomLists struct

+ func (s *SortableRoomLists) Counts() []int

+ func (s *SortableRoomLists) ForEach(fn func(index int, fsr *FilteredSortableRooms))

+ func (s *SortableRoomLists) List(index int) *FilteredSortableRooms

+ func (s *SortableRoomLists) ListExists(index int) bool

+ func (s *SortableRoomLists) Set(index int, val *FilteredSortableRooms)

+ type SortableRooms struct

+ func NewSortableRooms(rooms []RoomConnMetadata) *SortableRooms

+ func (s *SortableRooms) Add(r RoomConnMetadata) bool

+ func (s *SortableRooms) Get(index int) RoomConnMetadata

+ func (s *SortableRooms) IndexOf(roomID string) (int, bool)

+ func (s *SortableRooms) Len() int64

+ func (s *SortableRooms) Remove(roomID string) int

+ func (s *SortableRooms) RoomIDs() []string

+ func (s *SortableRooms) Sort(sortBy []string) error

+ func (s *SortableRooms) Subslice(i, j int64) Subslicer

+ func (s *SortableRooms) UpdateGlobalRoomMetadata(roomMeta *internal.RoomMetadata) int

+ func (s *SortableRooms) UpdateUserRoomMetadata(roomID string, userEvent *caches.UserRoomData) int

+ type Subslicer interface

+ Len func() int64

+ Subslice func(i, j int64) Subslicer