sqlite3

Documentation

Index

• func NewSqliteEventJSONTable(db *sql.DB) (tables.EventJSON, error)
• func NewSqliteEventStateKeysTable(db *sql.DB) (tables.EventStateKeys, error)
• func NewSqliteEventTypesTable(db *sql.DB) (tables.EventTypes, error)
• func NewSqliteEventsTable(db *sql.DB) (tables.Events, error)
• func NewSqliteInvitesTable(db *sql.DB) (tables.Invites, error)
• func NewSqliteMembershipTable(db *sql.DB) (tables.Membership, error)
• func NewSqlitePrevEventsTable(db *sql.DB) (tables.PreviousEvents, error)
• func NewSqlitePublishedTable(db *sql.DB) (tables.Published, error)
• func NewSqliteRedactionsTable(db *sql.DB) (tables.Redactions, error)
• func NewSqliteRoomAliasesTable(db *sql.DB) (tables.RoomAliases, error)
• func NewSqliteRoomsTable(db *sql.DB) (tables.Rooms, error)
• func NewSqliteStateBlockTable(db *sql.DB) (tables.StateBlock, error)
• func NewSqliteStateSnapshotTable(db *sql.DB) (tables.StateSnapshot, error)
• func NewSqliteTransactionsTable(db *sql.DB) (tables.Transactions, error)
• type Database
  • func Open(dbProperties *config.DatabaseOptions, cache caching.RoomServerCaches) (*Database, error)
  • func (d *Database) GetLatestEventsForUpdate(ctx context.Context, roomInfo types.RoomInfo) (*shared.LatestEventsUpdater, error)
  • func (d *Database) MembershipUpdater(ctx context.Context, roomID, targetUserID string, targetLocal bool, ...) (*shared.MembershipUpdater, error)
  • func (d *Database) SupportsConcurrentRoomInputs() bool

Functions

func NewSqliteEventJSONTable

func NewSqliteEventJSONTable(db *sql.DB) (tables.EventJSON, error)

func NewSqliteEventStateKeysTable

func NewSqliteEventStateKeysTable(db *sql.DB) (tables.EventStateKeys, error)

func NewSqliteEventTypesTable

func NewSqliteEventTypesTable(db *sql.DB) (tables.EventTypes, error)

func NewSqliteEventsTable

func NewSqliteEventsTable(db *sql.DB) (tables.Events, error)

func NewSqliteInvitesTable

func NewSqliteInvitesTable(db *sql.DB) (tables.Invites, error)

func NewSqliteMembershipTable

func NewSqliteMembershipTable(db *sql.DB) (tables.Membership, error)

func NewSqlitePrevEventsTable

func NewSqlitePrevEventsTable(db *sql.DB) (tables.PreviousEvents, error)

func NewSqlitePublishedTable

func NewSqlitePublishedTable(db *sql.DB) (tables.Published, error)

func NewSqliteRedactionsTable

func NewSqliteRedactionsTable(db *sql.DB) (tables.Redactions, error)

func NewSqliteRoomAliasesTable

func NewSqliteRoomAliasesTable(db *sql.DB) (tables.RoomAliases, error)

func NewSqliteRoomsTable

func NewSqliteRoomsTable(db *sql.DB) (tables.Rooms, error)

func NewSqliteStateBlockTable

func NewSqliteStateBlockTable(db *sql.DB) (tables.StateBlock, error)

func NewSqliteStateSnapshotTable

func NewSqliteStateSnapshotTable(db *sql.DB) (tables.StateSnapshot, error)

func NewSqliteTransactionsTable

func NewSqliteTransactionsTable(db *sql.DB) (tables.Transactions, error)

Types

type Database

type Database struct {
	shared.Database
	// contains filtered or unexported fields
}

A Database is used to store room events and stream offsets.

func Open

func Open(dbProperties *config.DatabaseOptions, cache caching.RoomServerCaches) (*Database, error)

Open a sqlite database. nolint: gocyclo

func (*Database) GetLatestEventsForUpdate

func (d *Database) GetLatestEventsForUpdate(
	ctx context.Context, roomInfo types.RoomInfo,
) (*shared.LatestEventsUpdater, error)

func (*Database) MembershipUpdater

func (d *Database) MembershipUpdater(
	ctx context.Context, roomID, targetUserID string,
	targetLocal bool, roomVersion gomatrixserverlib.RoomVersion,
) (*shared.MembershipUpdater, error)

func (*Database) SupportsConcurrentRoomInputs

func (d *Database) SupportsConcurrentRoomInputs() bool