Documentation
¶
Index ¶
- func NewDatabase(driver, createAddr, address, underlying, topic string, useAsync bool) (interface{}, error)
- type Database
- func (d *Database) AddState(ctx context.Context, roomNID int64, StateBlockNIDs []int64) (int64, error)
- func (d *Database) AliaseDeleteRaw(ctx context.Context, aliase string) error
- func (d *Database) AliaseInsertRaw(ctx context.Context, aliase, roomID string) error
- func (d *Database) AssignRoomNID(ctx context.Context, roomID string) (int64, error)
- func (d *Database) BackFillNids(ctx context.Context, roomNID int64, domain string, eventNid int64, limit int, ...) ([]int64, error)
- func (d *Database) EventCountAll(ctx context.Context) (count int, err error)
- func (d *Database) EventCountForRoom(ctx context.Context, roomId string) (count int, err error)
- func (d *Database) EventNID(ctx context.Context, eventID string) (int64, error)
- func (d *Database) EventNIDs(ctx context.Context, eventIDs []string) (map[string]int64, error)
- func (d *Database) Events(ctx context.Context, eventNIDs []int64) ([]*gomatrixserverlib.Event, []int64, error)
- func (d *Database) EventsCount(ctx context.Context) (count int, err error)
- func (d *Database) FixCorruptRooms()
- func (d *Database) GetAliasesFromRoomID(ctx context.Context, roomID string) ([]string, error)
- func (d *Database) GetAllRooms(ctx context.Context, limit, offset int) ([]roomservertypes.RoomNIDs, error)
- func (d *Database) GetDB() *sql.DB
- func (d *Database) GetMsgEventsMigration(ctx context.Context, limit, offset int64) ([]int64, [][]byte, error)
- func (d *Database) GetMsgEventsTotalMigration(ctx context.Context) (int, int64, error)
- func (d *Database) GetRoomDomainsOffset(ctx context.Context, room_nid int64) ([]string, []int64, error)
- func (d *Database) GetRoomEventByNID(ctx context.Context, eventNID int64) ([]byte, error)
- func (d *Database) GetRoomEvents(ctx context.Context, roomNID int64) ([][]byte, error)
- func (d *Database) GetRoomEventsWithLimit(ctx context.Context, roomNID int64, limit, offset int) ([]int64, [][]byte, error)
- func (d *Database) GetRoomIDFromAlias(ctx context.Context, alias string) (string, error)
- func (d *Database) GetRoomStates(ctx context.Context, roomID string) ([]*gomatrixserverlib.Event, []int64, error)
- func (d *Database) GetUserRooms(ctx context.Context, uid string) ([]string, []string, []string, error)
- func (d *Database) InsertEvent(ctx context.Context, eventNID int64, roomNID int64, eventType string, ...) error
- func (d *Database) InsertEventJSON(ctx context.Context, eventNID int64, eventJSON []byte, eventType string) error
- func (d *Database) InsertInvite(ctx context.Context, eventId string, roomNid int64, target, sender string, ...) error
- func (d *Database) InsertRoomNID(ctx context.Context, roomNID int64, roomID string) error
- func (d *Database) InsertStateRaw(ctx context.Context, stateNID int64, roomNID int64, nids []int64) (err error)
- func (d *Database) InviteUpdate(ctx context.Context, roomNid int64, target string) error
- func (d *Database) LatestRoomEvent(ctx context.Context, roomId string) (eventId string, err error)
- func (d *Database) LoadFilterData(ctx context.Context, key string, f *filter.Filter) bool
- func (d *Database) MembershipForgetUpdate(ctx context.Context, roomNid int64, target string, forgetNid int64) error
- func (d *Database) MembershipInsert(ctx context.Context, roomNid int64, target, roomID string, ...) error
- func (d *Database) MembershipUpdate(ctx context.Context, roomNid int64, target, sender string, ...) error
- func (d *Database) OnUpdateRoomDepth(ctx context.Context, depth, roomNid int64) error
- func (d *Database) OnUpdateRoomEvent(ctx context.Context, eventNID, roomNID, depth, domainOffset int64, ...) error
- func (d *Database) RecoverCache()
- func (d *Database) RemoveRoomAlias(ctx context.Context, alias string) error
- func (d *Database) RoomDomainsInsertRaw(ctx context.Context, room_nid int64, domain string, offset int64) error
- func (d *Database) RoomExists(ctx context.Context, roomId string) (exists bool, err error)
- func (d *Database) RoomInfo(ctx context.Context, roomID string) (int64, int64, int64, error)
- func (d *Database) RoomNID(ctx context.Context, roomID string) (roomservertypes.RoomNID, error)
- func (d *Database) SaveRoomDomainsOffset(ctx context.Context, room_nid int64, domain string, offset int64) error
- func (d *Database) SaveSettings(ctx context.Context, settingKey string, val string) error
- func (d *Database) SelectEventNidForBackfill(ctx context.Context, roomNID int64, domain string) (int64, error)
- func (d *Database) SelectEventStateSnapshotNID(ctx context.Context, eventID string) (int64, error)
- func (d Database) SelectRoomEventsByDomainOffset(ctx context.Context, roomNID int64, domain string, domainOffset int64, ...) ([]int64, error)
- func (d *Database) SelectRoomMaxDomainOffsets(ctx context.Context, roomNID int64) (domains, eventIDs []string, offsets []int64, err error)
- func (d *Database) SelectRoomStateNIDByStateBlockNID(ctx context.Context, roomNID int64, stateBlockNID int64) ([]int64, []string, []string, []string, error)
- func (d *Database) SelectSettingKey(ctx context.Context, settingKey string) (string, error)
- func (d *Database) SelectState(ctx context.Context, snapshotNID int64) (int64, []int64, error)
- func (d *Database) SetGauge(qryDBGauge mon.LabeledGauge)
- func (d *Database) SetIDGenerator(idg *uid.UidGenerator)
- func (d *Database) SetLatestEvents(ctx context.Context, roomNID int64, ...) error
- func (d *Database) SetRoomAlias(ctx context.Context, alias string, roomID string) error
- func (d *Database) SetToForget(ctx context.Context, roomNID int64, targetUser string, eventNID int64, ...) error
- func (d *Database) SetToInvite(ctx context.Context, roomNID int64, targetUser, senderUserID, eventID string, ...) error
- func (d *Database) SetToJoin(ctx context.Context, roomNID int64, targetUser, senderUserID string, ...) error
- func (d *Database) SetToLeave(ctx context.Context, roomNID int64, targetUser, senderUserID string, ...) error
- func (d *Database) SettingsInsertRaw(ctx context.Context, settingKey string, val string) error
- func (d *Database) StoreEvent(ctx context.Context, event *gomatrixserverlib.Event, roomNID, stateNID int64, ...) error
- func (d *Database) UpdateLatestEventNIDs(ctx context.Context, roomNID int64, eventNIDs []int64, lastEventSentNID int64, ...) error
- func (d *Database) UpdateMsgEventMigration(ctx context.Context, id int64, EncryptedEventBytes []byte) error
- func (d *Database) UpdateRoomDepth(ctx context.Context, depth, roomNid int64) error
- func (d *Database) UpdateRoomEvent(ctx context.Context, eventNID, roomNID, depth, domainOffset int64, ...) error
- func (d *Database) WriteDBEvent(ctx context.Context, update *dbtypes.DBEvent) error
- func (d *Database) WriteDBEventWithTbl(ctx context.Context, update *dbtypes.DBEvent, tbl string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDatabase ¶
func NewDatabase(driver, createAddr, address, underlying, topic string, useAsync bool) (interface{}, error)
Open a postgres database.
Types ¶
type Database ¶
type Database struct { AsyncSave bool // contains filtered or unexported fields }
A Database is used to store room events and stream offsets.
func (*Database) AddState ¶
func (d *Database) AddState( ctx context.Context, roomNID int64, StateBlockNIDs []int64, ) (int64, error)
AddState implements input.EventDatabase
func (*Database) AliaseDeleteRaw ¶
func (*Database) AliaseInsertRaw ¶
func (*Database) AssignRoomNID ¶
func (*Database) BackFillNids ¶
func (*Database) EventCountAll ¶
func (*Database) EventCountForRoom ¶
func (*Database) Events ¶
func (d *Database) Events( ctx context.Context, eventNIDs []int64, ) ([]*gomatrixserverlib.Event, []int64, error)
Events implements input.EventDatabase
func (*Database) EventsCount ¶
func (*Database) FixCorruptRooms ¶
func (d *Database) FixCorruptRooms()
func (*Database) GetAliasesFromRoomID ¶
GetAliasesFromRoomID implements alias.RoomserverAliasAPIDB
func (*Database) GetAllRooms ¶
func (*Database) GetMsgEventsMigration ¶
func (*Database) GetMsgEventsTotalMigration ¶
func (*Database) GetRoomDomainsOffset ¶
func (*Database) GetRoomEventByNID ¶
func (*Database) GetRoomEvents ¶
func (*Database) GetRoomEventsWithLimit ¶
func (*Database) GetRoomIDFromAlias ¶
GetRoomIDFromAlias implements alias.RoomserverAliasAPIDB
func (*Database) GetRoomStates ¶
func (*Database) GetUserRooms ¶
func (*Database) InsertEvent ¶
func (*Database) InsertEventJSON ¶
func (*Database) InsertInvite ¶
func (*Database) InsertRoomNID ¶
func (*Database) InsertStateRaw ¶
func (*Database) InviteUpdate ¶
func (*Database) LatestRoomEvent ¶
func (*Database) LoadFilterData ¶
func (*Database) MembershipForgetUpdate ¶
func (*Database) MembershipInsert ¶
func (*Database) MembershipUpdate ¶
func (*Database) OnUpdateRoomDepth ¶
func (*Database) OnUpdateRoomEvent ¶
func (*Database) RecoverCache ¶
func (d *Database) RecoverCache()
func (*Database) RemoveRoomAlias ¶
RemoveRoomAlias implements alias.RoomserverAliasAPIDB
func (*Database) RoomDomainsInsertRaw ¶
func (*Database) RoomExists ¶
func (*Database) SaveRoomDomainsOffset ¶
func (*Database) SaveSettings ¶
func (*Database) SelectEventNidForBackfill ¶
func (*Database) SelectEventStateSnapshotNID ¶
func (Database) SelectRoomEventsByDomainOffset ¶
func (*Database) SelectRoomMaxDomainOffsets ¶
func (*Database) SelectRoomStateNIDByStateBlockNID ¶
func (*Database) SelectSettingKey ¶
func (*Database) SelectState ¶
func (*Database) SetGauge ¶
func (d *Database) SetGauge(qryDBGauge mon.LabeledGauge)
func (*Database) SetIDGenerator ¶
func (d *Database) SetIDGenerator(idg *uid.UidGenerator)
func (*Database) SetLatestEvents ¶
func (*Database) SetRoomAlias ¶
SetRoomAlias implements alias.RoomserverAliasAPIDB
func (*Database) SetToForget ¶
func (*Database) SetToInvite ¶
func (*Database) SetToLeave ¶
func (*Database) SettingsInsertRaw ¶
func (*Database) StoreEvent ¶
func (d *Database) StoreEvent( ctx context.Context, event *gomatrixserverlib.Event, roomNID, stateNID int64, refId string, refHash []byte, ) error
StoreEvent implements input.EventDatabase
func (*Database) UpdateLatestEventNIDs ¶
func (*Database) UpdateMsgEventMigration ¶
func (*Database) UpdateRoomDepth ¶
func (*Database) UpdateRoomEvent ¶
func (*Database) WriteDBEvent ¶
WriteOutputEvents implements OutputRoomEventWriter
Click to show internal directories.
Click to hide internal directories.