shared

Jan 17, 2023

Changes in this version

type Database

+ func (d *Database) GetPresences(ctx context.Context, userIDs []string) ([]*types.PresenceInternal, error)

type DatabaseTransaction

+ func (d *DatabaseTransaction) GetPresences(ctx context.Context, userIDs []string) ([]*types.PresenceInternal, error)

+ func (d *DatabaseTransaction) GetRoomSummary(ctx context.Context, roomID, userID string) (*types.Summary, error)

Oct 31, 2022

Changes in this version

type Database

+ func (d *Database) SelectMemberships(ctx context.Context, roomID string, pos types.TopologyToken, ...) (eventIDs []string, err error)

Oct 14, 2022

Changes in this version

type Database

+ Relations tables.Relations

+ func (d *Database) RedactRelations(ctx context.Context, roomID, redactedEventID string) error

+ func (d *Database) UpdateRelations(ctx context.Context, event *gomatrixserverlib.HeaderedEvent) error

type DatabaseTransaction

+ func (d *DatabaseTransaction) MaxStreamPositionForRelations(ctx context.Context) (types.StreamPosition, error)

+ func (d *DatabaseTransaction) RelationsFor(ctx context.Context, roomID, eventID, relType, eventType string, ...) (events []types.StreamEvent, prevBatch, nextBatch string, err error)

Sep 30, 2022

Changes in this version

type DatabaseTransaction

+ func (d *DatabaseTransaction) Reset() (err error)

Sep 30, 2022

Changes in this version

type Database

+ func (d *Database) NewDatabaseSnapshot(ctx context.Context) (*DatabaseTransaction, error)

+ func (d *Database) NewDatabaseTransaction(ctx context.Context) (*DatabaseTransaction, error)

+ func (s *Database) ReIndex(ctx context.Context, limit, afterID int64) (map[int64]gomatrixserverlib.HeaderedEvent, error)

+ type DatabaseTransaction struct

+ func (d *DatabaseTransaction) AllJoinedUsersInRoom(ctx context.Context, roomIDs []string) (map[string][]string, error)

+ func (d *DatabaseTransaction) AllJoinedUsersInRooms(ctx context.Context) (map[string][]string, error)

+ func (d *DatabaseTransaction) AllPeekingDevicesInRooms(ctx context.Context) (map[string][]types.PeekingDevice, error)

+ func (d *DatabaseTransaction) BackwardExtremitiesForRoom(ctx context.Context, roomID string) (backwardExtremities map[string][]string, err error)

+ func (d *DatabaseTransaction) Commit() error

+ func (d *DatabaseTransaction) CurrentState(ctx context.Context, roomID string, ...) ([]*gomatrixserverlib.HeaderedEvent, error)

+ func (d *DatabaseTransaction) EventPositionInTopology(ctx context.Context, eventID string) (types.TopologyToken, error)

+ func (d *DatabaseTransaction) Events(ctx context.Context, eventIDs []string) ([]*gomatrixserverlib.HeaderedEvent, error)

+ func (d *DatabaseTransaction) GetAccountDataInRange(ctx context.Context, userID string, r types.Range, ...) (map[string][]string, types.StreamPosition, error)

+ func (d *DatabaseTransaction) GetBackwardTopologyPos(ctx context.Context, events []types.StreamEvent) (types.TopologyToken, error)

+ func (d *DatabaseTransaction) GetEventsInTopologicalRange(ctx context.Context, from, to *types.TopologyToken, roomID string, ...) (events []types.StreamEvent, err error)

+ func (d *DatabaseTransaction) GetPresence(ctx context.Context, userID string) (*types.PresenceInternal, error)

+ func (d *DatabaseTransaction) GetRoomHeroes(ctx context.Context, roomID, userID string, memberships []string) ([]string, error)

+ func (d *DatabaseTransaction) GetRoomReceipts(ctx context.Context, roomIDs []string, streamPos types.StreamPosition) ([]types.OutputReceiptEvent, error)

+ func (d *DatabaseTransaction) GetStateDeltas(ctx context.Context, device *userapi.Device, r types.Range, userID string, ...) (deltas []types.StateDelta, joinedRoomsIDs []string, err error)

+ func (d *DatabaseTransaction) GetStateDeltasForFullStateSync(ctx context.Context, device *userapi.Device, r types.Range, userID string, ...) ([]types.StateDelta, []string, error)

+ func (d *DatabaseTransaction) GetStateEvent(ctx context.Context, roomID, evType, stateKey string) (*gomatrixserverlib.HeaderedEvent, error)

+ func (d *DatabaseTransaction) GetStateEventsForRoom(ctx context.Context, roomID string, stateFilter *gomatrixserverlib.StateFilter) (stateEvents []*gomatrixserverlib.HeaderedEvent, err error)

+ func (d *DatabaseTransaction) GetUserUnreadNotificationCountsForRooms(ctx context.Context, userID string, rooms map[string]string) (map[string]*eventutil.NotificationData, error)

+ func (d *DatabaseTransaction) InviteEventsInRange(ctx context.Context, targetUserID string, r types.Range) (map[string]*gomatrixserverlib.HeaderedEvent, ...)

+ func (d *DatabaseTransaction) MaxStreamPositionForAccountData(ctx context.Context) (types.StreamPosition, error)

+ func (d *DatabaseTransaction) MaxStreamPositionForInvites(ctx context.Context) (types.StreamPosition, error)

+ func (d *DatabaseTransaction) MaxStreamPositionForNotificationData(ctx context.Context) (types.StreamPosition, error)

+ func (d *DatabaseTransaction) MaxStreamPositionForPDUs(ctx context.Context) (types.StreamPosition, error)

+ func (d *DatabaseTransaction) MaxStreamPositionForPresence(ctx context.Context) (types.StreamPosition, error)

+ func (d *DatabaseTransaction) MaxStreamPositionForReceipts(ctx context.Context) (types.StreamPosition, error)

+ func (d *DatabaseTransaction) MaxStreamPositionForSendToDeviceMessages(ctx context.Context) (types.StreamPosition, error)

+ func (d *DatabaseTransaction) MaxTopologicalPosition(ctx context.Context, roomID string) (types.TopologyToken, error)

+ func (d *DatabaseTransaction) MembershipCount(ctx context.Context, roomID, membership string, pos types.StreamPosition) (int, error)

+ func (d *DatabaseTransaction) PeeksInRange(ctx context.Context, userID, deviceID string, r types.Range) (peeks []types.Peek, err error)

+ func (d *DatabaseTransaction) PositionInTopology(ctx context.Context, eventID string) (pos types.StreamPosition, spos types.StreamPosition, err error)

+ func (d *DatabaseTransaction) PresenceAfter(ctx context.Context, after types.StreamPosition, ...) (map[string]*types.PresenceInternal, error)

+ func (d *DatabaseTransaction) RecentEvents(ctx context.Context, roomID string, r types.Range, ...) ([]types.StreamEvent, bool, error)

+ func (d *DatabaseTransaction) Rollback() error

+ func (d *DatabaseTransaction) RoomIDsWithMembership(ctx context.Context, userID string, membership string) ([]string, error)

+ func (d *DatabaseTransaction) RoomReceiptsAfter(ctx context.Context, roomIDs []string, streamPos types.StreamPosition) (types.StreamPosition, []types.OutputReceiptEvent, error)

+ func (d *DatabaseTransaction) SendToDeviceUpdatesForSync(ctx context.Context, userID, deviceID string, from, to types.StreamPosition) (types.StreamPosition, []types.SendToDeviceEvent, error)

+ func (d *DatabaseTransaction) SharedUsers(ctx context.Context, userID string, otherUserIDs []string) ([]string, error)

+ func (d *DatabaseTransaction) StreamToTopologicalPosition(ctx context.Context, roomID string, streamPos types.StreamPosition, ...) (types.TopologyToken, error)

Aug 12, 2022

Changes in this version

type Database

+ func (d *Database) SelectMembershipForUser(ctx context.Context, roomID, userID string, pos int64) (membership string, topologicalPos int, err error)

Aug 1, 2022

Changes in this version

type Database

+ func (d *Database) SharedUsers(ctx context.Context, userID string, otherUserIDs []string) ([]string, error)

May 9, 2022

Changes in this version

type Database

+ func (d *Database) AllJoinedUsersInRoom(ctx context.Context, roomIDs []string) (map[string][]string, error)

Apr 27, 2022

Changes in this version

type Database

+ func (d *Database) GetRoomHeroes(ctx context.Context, roomID, userID string, memberships []string) ([]string, error)

Apr 7, 2022

Changes in this version

type Database

+ Ignores tables.Ignores

+ Presence tables.Presence

+ func (d *Database) MembershipCount(ctx context.Context, roomID, membership string, pos types.StreamPosition) (int, error)

+ func (s *Database) GetPresence(ctx context.Context, userID string) (*types.PresenceInternal, error)

+ func (s *Database) IgnoresForUser(ctx context.Context, userID string) (*types.IgnoredUsers, error)

+ func (s *Database) MaxStreamPositionForPresence(ctx context.Context) (types.StreamPosition, error)

+ func (s *Database) PresenceAfter(ctx context.Context, after types.StreamPosition) (map[string]*types.PresenceInternal, error)

+ func (s *Database) UpdateIgnoresForUser(ctx context.Context, userID string, ignores *types.IgnoredUsers) error

+ func (s *Database) UpdatePresence(ctx context.Context, userID string, presence types.Presence, statusMsg *string, ...) (types.StreamPosition, error)

Mar 25, 2022

Changes in this version

type Database

+ func (d *Database) StreamToTopologicalPosition(ctx context.Context, roomID string, streamPos types.StreamPosition, ...) (types.TopologyToken, error)

Mar 4, 2022

Changes in this version

type Database

+ NotificationData tables.NotificationData

+ func (d *Database) GetUserUnreadNotificationCounts(ctx context.Context, userID string, from, to types.StreamPosition) (map[string]*eventutil.NotificationData, error)

+ func (d *Database) MaxStreamPositionForNotificationData(ctx context.Context) (types.StreamPosition, error)

+ func (d *Database) UpsertRoomUnreadNotificationCounts(ctx context.Context, userID, roomID string, ...) (pos types.StreamPosition, err error)

Feb 22, 2022

Changes in this version

type Database

+ func (s *Database) SelectContextAfterEvent(ctx context.Context, id int, roomID string, ...) (int, []*gomatrixserverlib.HeaderedEvent, error)

+ func (s *Database) SelectContextBeforeEvent(ctx context.Context, id int, roomID string, ...) ([]*gomatrixserverlib.HeaderedEvent, error)

+ func (s *Database) SelectContextEvent(ctx context.Context, roomID, eventID string) (int, gomatrixserverlib.HeaderedEvent, error)

Jan 26, 2021

Changes in this version

type Database

+ Memberships tables.Memberships

Jan 18, 2021

Changes in this version

type Database

+ func (d *Database) MaxStreamPositionForSendToDeviceMessages(ctx context.Context) (types.StreamPosition, error)

Jan 11, 2021

Changes in this version

type Database

+ func (d *Database) CurrentState(ctx context.Context, roomID string, ...) ([]*gomatrixserverlib.HeaderedEvent, error)

+ func (d *Database) GetBackwardTopologyPos(ctx context.Context, events []types.StreamEvent) (types.TopologyToken, error)

+ func (d *Database) GetStateDeltas(ctx context.Context, device *userapi.Device, r types.Range, userID string, ...) ([]types.StateDelta, []string, error)

+ func (d *Database) GetStateDeltasForFullStateSync(ctx context.Context, device *userapi.Device, r types.Range, userID string, ...) ([]types.StateDelta, []string, error)

+ func (d *Database) InviteEventsInRange(ctx context.Context, targetUserID string, r types.Range) (map[string]*gomatrixserverlib.HeaderedEvent, ...)

+ func (d *Database) MaxStreamPositionForAccountData(ctx context.Context) (types.StreamPosition, error)

+ func (d *Database) MaxStreamPositionForInvites(ctx context.Context) (types.StreamPosition, error)

+ func (d *Database) MaxStreamPositionForPDUs(ctx context.Context) (types.StreamPosition, error)

+ func (d *Database) MaxStreamPositionForReceipts(ctx context.Context) (types.StreamPosition, error)

+ func (d *Database) PeeksInRange(ctx context.Context, userID, deviceID string, r types.Range) (peeks []types.Peek, err error)

+ func (d *Database) PositionInTopology(ctx context.Context, eventID string) (pos types.StreamPosition, spos types.StreamPosition, err error)

+ func (d *Database) RecentEvents(ctx context.Context, roomID string, r types.Range, limit int, ...) ([]types.StreamEvent, bool, error)

+ func (d *Database) RoomIDsWithMembership(ctx context.Context, userID string, membership string) ([]string, error)

+ func (d *Database) RoomReceiptsAfter(ctx context.Context, roomIDs []string, streamPos types.StreamPosition) (types.StreamPosition, []eduAPI.OutputReceiptEvent, error)

Dec 9, 2020

Changes in this version

type Database

+ func (d *Database) DeletePeek(ctx context.Context, roomID, userID, deviceID string) (sp types.StreamPosition, err error)

Nov 16, 2020

Changes in this version

type Database

+ Receipts tables.Receipts

+ func (d *Database) GetRoomReceipts(ctx context.Context, roomIDs []string, streamPos types.StreamPosition) ([]eduAPI.OutputReceiptEvent, error)

+ func (d *Database) StoreReceipt(ctx context.Context, roomId, receiptType, userId, eventId string, ...) (pos types.StreamPosition, err error)

Oct 22, 2020

Changes in this version

type Database

+ func (d *Database) PurgeRoomState(ctx context.Context, roomID string) error

Oct 8, 2020

Changes in this version

+ type Database struct

+ AccountData tables.AccountData

+ BackwardExtremities tables.BackwardsExtremities

+ CurrentRoomState tables.CurrentRoomState

+ DB *sql.DB

+ EDUCache *cache.EDUCache

+ Filter tables.Filter

+ Invites tables.Invites

+ OutputEvents tables.Events

+ Peeks tables.Peeks

+ SendToDevice tables.SendToDevice

+ Topology tables.Topology

+ Writer sqlutil.Writer

+ func (d *Database) AddInviteEvent(ctx context.Context, inviteEvent gomatrixserverlib.HeaderedEvent) (sp types.StreamPosition, err error)

+ func (d *Database) AddPeek(ctx context.Context, roomID, userID, deviceID string) (sp types.StreamPosition, err error)

+ func (d *Database) AddSendToDevice() types.StreamPosition

+ func (d *Database) AddTypingUser(userID, roomID string, expireTime *time.Time) types.StreamPosition

+ func (d *Database) AllJoinedUsersInRooms(ctx context.Context) (map[string][]string, error)

+ func (d *Database) AllPeekingDevicesInRooms(ctx context.Context) (map[string][]types.PeekingDevice, error)

+ func (d *Database) BackwardExtremitiesForRoom(ctx context.Context, roomID string) (backwardExtremities map[string][]string, err error)

+ func (d *Database) CleanSendToDeviceUpdates(ctx context.Context, toUpdate, toDelete []types.SendToDeviceNID, ...) (err error)

+ func (d *Database) CompleteSync(ctx context.Context, res *types.Response, device userapi.Device, ...) (*types.Response, error)

+ func (d *Database) DeletePeeks(ctx context.Context, roomID, userID string) (sp types.StreamPosition, err error)

+ func (d *Database) EventPositionInTopology(ctx context.Context, eventID string) (types.TopologyToken, error)

+ func (d *Database) Events(ctx context.Context, eventIDs []string) ([]gomatrixserverlib.HeaderedEvent, error)

+ func (d *Database) GetAccountDataInRange(ctx context.Context, userID string, r types.Range, ...) (map[string][]string, error)

+ func (d *Database) GetEventsInStreamingRange(ctx context.Context, from, to *types.StreamingToken, roomID string, limit int, ...) (events []types.StreamEvent, err error)

+ func (d *Database) GetEventsInTopologicalRange(ctx context.Context, from, to *types.TopologyToken, roomID string, limit int, ...) (events []types.StreamEvent, err error)

+ func (d *Database) GetFilter(ctx context.Context, localpart string, filterID string) (*gomatrixserverlib.Filter, error)

+ func (d *Database) GetStateEvent(ctx context.Context, roomID, evType, stateKey string) (*gomatrixserverlib.HeaderedEvent, error)

+ func (d *Database) GetStateEventsForRoom(ctx context.Context, roomID string, stateFilter *gomatrixserverlib.StateFilter) (stateEvents []gomatrixserverlib.HeaderedEvent, err error)

+ func (d *Database) IncrementalSync(ctx context.Context, res *types.Response, device userapi.Device, ...) (*types.Response, error)

+ func (d *Database) MaxTopologicalPosition(ctx context.Context, roomID string) (types.TopologyToken, error)

+ func (d *Database) PurgeRoom(ctx context.Context, roomID string) error

+ func (d *Database) PutFilter(ctx context.Context, localpart string, filter *gomatrixserverlib.Filter) (string, error)

+ func (d *Database) RedactEvent(ctx context.Context, redactedEventID string, ...) error

+ func (d *Database) RemoveTypingUser(userID, roomID string) types.StreamPosition

+ func (d *Database) RetireInviteEvent(ctx context.Context, inviteEventID string) (sp types.StreamPosition, err error)

+ func (d *Database) SendToDeviceUpdatesForSync(ctx context.Context, userID, deviceID string, token types.StreamingToken) ([]types.SendToDeviceEvent, []types.SendToDeviceNID, []types.SendToDeviceNID, ...)

+ func (d *Database) SendToDeviceUpdatesWaiting(ctx context.Context, userID, deviceID string) (bool, error)

+ func (d *Database) SetTypingTimeoutCallback(fn cache.TimeoutCallbackFn)

+ func (d *Database) StoreNewSendForDeviceMessage(ctx context.Context, streamPos types.StreamPosition, userID, deviceID string, ...) (types.StreamPosition, error)

+ func (d *Database) StreamEventsToEvents(device *userapi.Device, in []types.StreamEvent) []gomatrixserverlib.HeaderedEvent

+ func (d *Database) SyncPosition(ctx context.Context) (tok types.StreamingToken, err error)

+ func (d *Database) UpsertAccountData(ctx context.Context, userID, roomID, dataType string) (sp types.StreamPosition, err error)

+ func (d *Database) WriteEvent(ctx context.Context, ev *gomatrixserverlib.HeaderedEvent, ...) (pduPosition types.StreamPosition, returnErr error)