state

package

Go to main page

Versions in this module

v0

v0.7.4

Dec 6, 2022

v0.7.3

Nov 29, 2022

Changes in this version

+ func PackReceiptsIntoEDU(receipts []internal.Receipt) (json.RawMessage, error)

+ type ReceiptChunker []internal.Receipt

+ func (c ReceiptChunker) Len() int

+ func (c ReceiptChunker) Subslice(i, j int) sqlutil.Chunker

+ type ReceiptTable struct

+ func NewReceiptTable(db *sqlx.DB) *ReceiptTable

+ func (t *ReceiptTable) Insert(roomID string, ephEvent json.RawMessage) (receipts []internal.Receipt, err error)

+ func (t *ReceiptTable) SelectReceiptsForEvents(roomID string, eventIDs []string) (receipts []internal.Receipt, err error)

+ func (t *ReceiptTable) SelectReceiptsForUser(roomID, userID string) (receipts []internal.Receipt, err error)

type Storage

+ ReceiptTable *ReceiptTable

v0.7.2

Nov 22, 2022

v0.7.1

Nov 15, 2022

v0.7.0

Oct 31, 2022

v0.6.0

Oct 24, 2022

v0.5.2

Oct 18, 2022

v0.5.1

Oct 12, 2022

v0.5.0

Oct 4, 2022

Changes in this version

+ type DeviceDataRow struct

+ Data []byte

+ DeviceID string

+ ID int64

+ UserID string

+ type DeviceDataTable struct

+ func NewDeviceDataTable(db *sqlx.DB) *DeviceDataTable

+ func (t *DeviceDataTable) Select(userID, deviceID string, swap bool) (dd *internal.DeviceData, err error)

+ func (t *DeviceDataTable) SelectFrom(pos int64) (results []internal.DeviceData, nextPos int64, err error)

+ func (t *DeviceDataTable) Upsert(dd *internal.DeviceData) (pos int64, err error)

type InvitesTable

+ func (t *InvitesTable) SelectInviteState(userID, roomID string) (inviteState []json.RawMessage, err error)

type RoomInfo

+ PredecessorRoomID *string

+ UpgradedRoomID *string

+ type StartupSnapshot struct

+ AllJoinedMembers map[string][]string

+ GlobalMetadata map[string]internal.RoomMetadata

+ PayloadStartID int64

type Storage

+ DB *sqlx.DB

+ DeviceDataTable *DeviceDataTable

+ PayloadTable *notify.PayloadTable

+ TransactionsTable *TransactionsTable

+ func (s *Storage) Cleaner(n time.Duration)

+ func (s *Storage) EventNIDs(eventNIDs []int64) ([]json.RawMessage, error)

+ func (s *Storage) GlobalSnapshot(chanName string) (ss StartupSnapshot, err error)

+ func (s *Storage) MaxPayloadIDForChannel(chanName string) (id int64, err error)

+ func (s *Storage) StateSnapshot(snapID int64) (state []json.RawMessage, err error)

+ type TransactionsTable struct

+ func NewTransactionsTable(db *sqlx.DB) *TransactionsTable

+ func (t *TransactionsTable) Clean(boundaryTime time.Time) error

+ func (t *TransactionsTable) Insert(userID string, eventIDToTxnID map[string]string) error

+ func (t *TransactionsTable) Select(userID string, eventIDs []string) (map[string]string, error)

v0.4.1

Sep 5, 2022

v0.4.0

Aug 23, 2022

Changes in this version

type AccountDataTable

+ func (t *AccountDataTable) SelectWithType(txn *sqlx.Tx, userID, evType string) (datas []AccountData, err error)

type Storage

+ func (s *Storage) RoomAccountDatasWithType(userID, eventType string) (data []AccountData, err error)

v0.3.3

Aug 19, 2022

v0.3.2

Aug 16, 2022

v0.3.1

Aug 16, 2022

v0.3.0

Aug 5, 2022

v0.2.1

Aug 1, 2022

Changes in this version

+ const RelationMSpaceChild

+ const RelationMSpaceParent

+ type RoomInfo struct

+ ID string

+ IsEncrypted bool

+ IsTombstoned bool

+ Type *string

type RoomsTable

+ func (t *RoomsTable) SelectRoomInfos(txn *sqlx.Tx) (infos []RoomInfo, err error)

+ func (t *RoomsTable) Upsert(txn *sqlx.Tx, info RoomInfo, snapshotID, latestNID int64) (err error)

+ type SpaceRelation struct

+ Child string

+ IsSuggested bool

+ Ordering string

+ Parent string

+ Relation int

+ func NewSpaceRelationFromEvent(ev Event) (sr *SpaceRelation, isDeleted bool)

+ func (sr *SpaceRelation) Key() string

+ type SpaceRelationChunker []SpaceRelation

+ func (c SpaceRelationChunker) Len() int

+ func (c SpaceRelationChunker) Subslice(i, j int) sqlutil.Chunker

+ type SpacesTable struct

+ func NewSpacesTable(db *sqlx.DB) *SpacesTable

+ func (t *SpacesTable) BulkDelete(txn *sqlx.Tx, relations []SpaceRelation) error

+ func (t *SpacesTable) BulkInsert(txn *sqlx.Tx, relations []SpaceRelation) error

+ func (t *SpacesTable) HandleSpaceUpdates(txn *sqlx.Tx, events []Event) error

+ func (t *SpacesTable) SelectChildren(txn *sqlx.Tx, spaces []string) (map[string][]SpaceRelation, error)

v0.2.0

Jul 21, 2022

Changes in this version

type Event

+ IsState bool

v0.1.4

Apr 26, 2022

v0.1.3

Apr 26, 2022

Changes in this version

type Event

+ ReplacesNID int64

type EventTable

+ func (t *EventTable) LatestEventInRooms(txn *sqlx.Tx, roomIDs []string, highestNID int64) (events []Event, err error)

type RoomsTable

+ func (t *RoomsTable) LatestNIDs(txn *sqlx.Tx, roomIDs []string) (nids map[string]int64, err error)

v0.1.2

Apr 22, 2022

v0.1.1

Apr 13, 2022

Changes in this version

type Storage

+ func (s *Storage) Teardown()

v0.1.0

Apr 1, 2022

Changes in this version

+ const AccountDataGlobalRoom

+ const EventsEnd

+ const EventsStart

+ const MaxPostgresParameters

+ type AccountData struct

+ Data []byte

+ RoomID string

+ Type string

+ UserID string

+ type AccountDataChunker []AccountData

+ func (c AccountDataChunker) Len() int

+ func (c AccountDataChunker) Subslice(i, j int) sqlutil.Chunker

+ type AccountDataTable struct

+ func NewAccountDataTable(db *sqlx.DB) *AccountDataTable

+ func (t *AccountDataTable) Insert(txn *sqlx.Tx, accDatas []AccountData) ([]AccountData, error)

+ func (t *AccountDataTable) Select(txn *sqlx.Tx, userID, eventType, roomID string) (*AccountData, error)

+ func (t *AccountDataTable) SelectMany(txn *sqlx.Tx, userID string, roomIDs ...string) (datas []AccountData, err error)

+ type Accumulator struct

+ func NewAccumulator(db *sqlx.DB) *Accumulator

+ func (a *Accumulator) Accumulate(roomID string, prevBatch string, timeline []json.RawMessage) (numNew int, latestNID int64, err error)

+ func (a *Accumulator) Delta(roomID string, lastEventNID int64, limit int) (eventsJSON []json.RawMessage, latest int64, err error)

+ func (a *Accumulator) Initialise(roomID string, state []json.RawMessage) (bool, error)

+ type Event struct

+ BeforeStateSnapshotID int

+ ID string

+ JSON []byte

+ Membership string

+ NID int64

+ PrevBatch sql.NullString

+ RoomID string

+ StateKey string

+ Type string

+ type EventChunker []Event

+ func (c EventChunker) Len() int

+ func (c EventChunker) Subslice(i, j int) sqlutil.Chunker

+ type EventTable struct

+ func NewEventTable(db *sqlx.DB) *EventTable

+ func (t *EventTable) BeforeStateSnapshotIDForEventNID(txn *sqlx.Tx, roomID string, eventNID int64) (lastEventNID, replacesNID, snapID int64, err error)

+ func (t *EventTable) Insert(txn *sqlx.Tx, events []Event, checkFields bool) (int, error)

+ func (t *EventTable) SelectByIDs(txn *sqlx.Tx, verifyAll bool, ids []string) (events []Event, err error)

+ func (t *EventTable) SelectByNIDs(txn *sqlx.Tx, verifyAll bool, nids []int64) (events []Event, err error)

+ func (t *EventTable) SelectClosestPrevBatch(roomID string, eventNID int64) (prevBatch string, err error)

+ func (t *EventTable) SelectClosestPrevBatchByID(roomID string, eventID string) (prevBatch string, err error)

+ func (t *EventTable) SelectEventNIDsWithTypeInRoom(txn *sqlx.Tx, eventType string, limit int, targetRoom string, ...) (eventNIDs []int64, err error)

+ func (t *EventTable) SelectEventsBetween(txn *sqlx.Tx, roomID string, lowerExclusive, upperInclusive int64, limit int) ([]Event, error)

+ func (t *EventTable) SelectEventsWithTypeStateKey(eventType, stateKey string, lowerExclusive, upperInclusive int64) ([]Event, error)

+ func (t *EventTable) SelectEventsWithTypeStateKeyInRooms(roomIDs []string, eventType, stateKey string, ...) ([]Event, error)

+ func (t *EventTable) SelectHighestNID() (highest int64, err error)

+ func (t *EventTable) SelectLatestEventsBetween(txn *sqlx.Tx, roomID string, lowerExclusive, upperInclusive int64, limit int) ([]Event, error)

+ func (t *EventTable) SelectNIDsByIDs(txn *sqlx.Tx, ids []string) (nids []int64, err error)

+ func (t *EventTable) SelectStrippedEventsByIDs(txn *sqlx.Tx, verifyAll bool, ids []string) (StrippedEvents, error)

+ func (t *EventTable) SelectStrippedEventsByNIDs(txn *sqlx.Tx, verifyAll bool, nids []int64) (StrippedEvents, error)

+ func (t *EventTable) UpdateBeforeSnapshotID(txn *sqlx.Tx, eventNID, snapID, replacesNID int64) error

+ type InvitesTable struct

+ func NewInvitesTable(db *sqlx.DB) *InvitesTable

+ func (t *InvitesTable) InsertInvite(userID, roomID string, inviteRoomState []json.RawMessage) error

+ func (t *InvitesTable) RemoveInvite(userID, roomID string) error

+ func (t *InvitesTable) SelectAllInvitesForUser(userID string) (map[string][]json.RawMessage, error)

+ type RoomsTable struct

+ func NewRoomsTable(db *sqlx.DB) *RoomsTable

+ func (t *RoomsTable) CurrentAfterSnapshotID(txn *sqlx.Tx, roomID string) (snapshotID int64, err error)

+ func (t *RoomsTable) SelectEncryptedRooms(txn *sqlx.Tx) (encrypted []string, err error)

+ func (t *RoomsTable) SelectTombstonedRooms(txn *sqlx.Tx) (tombstones []string, err error)

+ func (t *RoomsTable) UpdateCurrentAfterSnapshotID(txn *sqlx.Tx, roomID string, snapshotID int64, isEncrypted, isTombstoned bool) (err error)

+ type SnapshotRow struct

+ Events pq.Int64Array

+ RoomID string

+ SnapshotID int64

+ type SnapshotTable struct

+ func NewSnapshotsTable(db *sqlx.DB) *SnapshotTable

+ func (s *SnapshotTable) Delete(txn *sqlx.Tx, snapshotIDs []int64) error

+ func (s *SnapshotTable) Insert(txn *sqlx.Tx, row *SnapshotRow) error

+ func (s *SnapshotTable) Select(txn *sqlx.Tx, snapshotID int64) (row SnapshotRow, err error)

+ func (t *SnapshotTable) CurrentSnapshots() (map[string][]int64, error)

+ type Storage struct

+ AccountDataTable *AccountDataTable

+ EventsTable *EventTable

+ InvitesTable *InvitesTable

+ ToDeviceTable *ToDeviceTable

+ TypingTable *TypingTable

+ UnreadTable *UnreadTable

+ func NewStorage(postgresURI string) *Storage

+ func (s *Storage) AccountData(userID, roomID, eventType string) (data *AccountData, err error)

+ func (s *Storage) AccountDatas(userID string, roomIDs ...string) (datas []AccountData, err error)

+ func (s *Storage) Accumulate(roomID, prevBatch string, timeline []json.RawMessage) (numNew int, latestNID int64, err error)

+ func (s *Storage) AllJoinedMembers() (map[string][]string, error)

+ func (s *Storage) Initialise(roomID string, state []json.RawMessage) (bool, error)

+ func (s *Storage) InsertAccountData(userID, roomID string, events []json.RawMessage) (data []AccountData, err error)

+ func (s *Storage) JoinedRoomsAfterPosition(userID string, pos int64) ([]string, error)

+ func (s *Storage) LatestEventNID() (int64, error)

+ func (s *Storage) LatestEventsInRooms(userID string, roomIDs []string, to int64, limit int) (map[string][]json.RawMessage, map[string]string, error)

+ func (s *Storage) LatestTypingID() (int64, error)

+ func (s *Storage) MetadataForAllRooms() (map[string]internal.RoomMetadata, error)

+ func (s *Storage) RoomMembershipDelta(roomID string, from, to int64, limit int) (eventJSON []json.RawMessage, upTo int64, err error)

+ func (s *Storage) RoomStateAfterEventPosition(roomID string, pos int64, eventTypes ...string) (events []Event, err error)

+ func (s *Storage) RoomStateBeforeEventPosition(roomID string, pos int64) (events []Event, err error)

+ func (s *Storage) VisibleEventNIDsBetween(userID string, from, to int64) (map[string][][2]int64, error)

+ type StrippedEvents []Event

+ func (se StrippedEvents) NIDs() (result []int64)

+ type ToDeviceRow struct

+ DeviceID string

+ Message string

+ Position int64

+ Sender string

+ Type string

+ type ToDeviceRowChunker []ToDeviceRow

+ func (c ToDeviceRowChunker) Len() int

+ func (c ToDeviceRowChunker) Subslice(i, j int) sqlutil.Chunker

+ type ToDeviceTable struct

+ func NewToDeviceTable(db *sqlx.DB) *ToDeviceTable

+ func (t *ToDeviceTable) DeleteMessagesUpToAndIncluding(deviceID string, toIncl int64) error

+ func (t *ToDeviceTable) InsertMessages(deviceID string, msgs []json.RawMessage) (pos int64, err error)

+ func (t *ToDeviceTable) Messages(deviceID string, from, to, limit int64) (msgs []json.RawMessage, upTo int64, err error)

+ type TypingTable struct

+ func NewTypingTable(db *sqlx.DB) *TypingTable

+ func (t *TypingTable) SelectHighestID() (id int64, err error)

+ func (t *TypingTable) SetTyping(roomID string, userIDs []string) (position int64, err error)

+ func (t *TypingTable) Typing(roomID string, fromStreamIDExcl, toStreamIDIncl int64) (userIDs []string, latest int64, err error)

+ type UnreadTable struct

+ func NewUnreadTable(db *sqlx.DB) *UnreadTable

+ func (t *UnreadTable) SelectAllNonZeroCountsForUser(userID string, ...) error

+ func (t *UnreadTable) SelectUnreadCounters(userID, roomID string) (highlightCount, notificationCount int, err error)

+ func (t *UnreadTable) UpdateUnreadCounters(userID, roomID string, highlightCount, notificationCount *int) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL