sqlite3

Documentation

Index

• func CreateEventJSONTable(db *sql.DB) error
• func CreateEventStateKeysTable(db *sql.DB) error
• func CreateEventTypesTable(db *sql.DB) error
• func CreateEventsTable(db *sql.DB) error
• func CreateInvitesTable(db *sql.DB) error
• func CreateMembershipTable(db *sql.DB) error
• func CreatePrevEventsTable(db *sql.DB) error
• func CreatePublishedTable(db *sql.DB) error
• func CreateRedactionsTable(db *sql.DB) error
• func CreateReportedEventsTable(db *sql.DB) error
• func CreateRoomAliasesTable(db *sql.DB) error
• func CreateRoomsTable(db *sql.DB) error
• func CreateStateBlockTable(db *sql.DB) error
• func CreateStateSnapshotTable(db *sql.DB) error
• func CreateUserRoomKeysTable(db *sql.DB) error
• func PrepareEventJSONTable(db *sql.DB) (tables.EventJSON, error)
• func PrepareEventStateKeysTable(db *sql.DB) (tables.EventStateKeys, error)
• func PrepareEventTypesTable(db *sql.DB) (tables.EventTypes, error)
• func PrepareEventsTable(db *sql.DB) (tables.Events, error)
• func PrepareInvitesTable(db *sql.DB) (tables.Invites, error)
• func PrepareMembershipTable(db *sql.DB) (tables.Membership, error)
• func PreparePrevEventsTable(db *sql.DB) (tables.PreviousEvents, error)
• func PreparePublishedTable(db *sql.DB) (tables.Published, error)
• func PreparePurgeStatements(db *sql.DB, stateSnapshot *stateSnapshotStatements) (*purgeStatements, error)
• func PrepareRedactionsTable(db *sql.DB) (tables.Redactions, error)
• func PrepareReportedEventsTable(db *sql.DB) (tables.ReportedEvents, error)
• func PrepareRoomAliasesTable(db *sql.DB) (tables.RoomAliases, error)
• func PrepareRoomsTable(db *sql.DB) (tables.Rooms, error)
• func PrepareStateBlockTable(db *sql.DB) (*stateBlockStatements, error)
• func PrepareStateSnapshotTable(db *sql.DB) (*stateSnapshotStatements, error)
• func PrepareUserRoomKeysTable(db *sql.DB) (tables.UserRoomKeys, error)
• type Database
  • func Open(ctx context.Context, conMan *sqlutil.Connections, ...) (*Database, error)
  • func (d *Database) GetRoomUpdater(ctx context.Context, roomInfo *types.RoomInfo) (*shared.RoomUpdater, error)
  • func (d *Database) MembershipUpdater(ctx context.Context, roomID, targetUserID string, targetLocal bool, ...) (*shared.MembershipUpdater, error)
  • func (d *Database) SupportsConcurrentRoomInputs() bool

Functions

func CreateEventJSONTable

func CreateEventJSONTable(db *sql.DB) error

func CreateEventStateKeysTable

func CreateEventStateKeysTable(db *sql.DB) error

func CreateEventTypesTable

func CreateEventTypesTable(db *sql.DB) error

func CreateEventsTable

func CreateEventsTable(db *sql.DB) error

func CreateInvitesTable

func CreateInvitesTable(db *sql.DB) error

func CreateMembershipTable

func CreateMembershipTable(db *sql.DB) error

func CreatePrevEventsTable

func CreatePrevEventsTable(db *sql.DB) error

func CreatePublishedTable

func CreatePublishedTable(db *sql.DB) error

func CreateRedactionsTable

func CreateRedactionsTable(db *sql.DB) error

func CreateReportedEventsTable

func CreateReportedEventsTable(db *sql.DB) error

func CreateRoomAliasesTable

func CreateRoomAliasesTable(db *sql.DB) error

func CreateRoomsTable

func CreateRoomsTable(db *sql.DB) error

func CreateStateBlockTable

func CreateStateBlockTable(db *sql.DB) error

func CreateStateSnapshotTable

func CreateStateSnapshotTable(db *sql.DB) error

func CreateUserRoomKeysTable

func CreateUserRoomKeysTable(db *sql.DB) error

func PrepareEventJSONTable

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

func PrepareEventStateKeysTable

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

func PrepareEventTypesTable

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

func PrepareEventsTable

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

func PrepareInvitesTable

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

func PrepareMembershipTable

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

func PreparePrevEventsTable

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

func PreparePublishedTable

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

func PreparePurgeStatements

func PreparePurgeStatements(db *sql.DB, stateSnapshot *stateSnapshotStatements) (*purgeStatements, error)

func PrepareRedactionsTable

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

func PrepareReportedEventsTable

func PrepareReportedEventsTable(db *sql.DB) (tables.ReportedEvents, error)

func PrepareRoomAliasesTable

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

func PrepareRoomsTable

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

func PrepareStateBlockTable

func PrepareStateBlockTable(db *sql.DB) (*stateBlockStatements, error)

func PrepareStateSnapshotTable

func PrepareStateSnapshotTable(db *sql.DB) (*stateSnapshotStatements, error)

func PrepareUserRoomKeysTable

func PrepareUserRoomKeysTable(db *sql.DB) (tables.UserRoomKeys, error)

Types

type Database

type Database struct {
	shared.Database
}

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

func Open

func Open(ctx context.Context, conMan *sqlutil.Connections, dbProperties *config.DatabaseOptions, cache caching.RoomServerCaches) (*Database, error)

Open a sqlite database.

func (*Database) GetRoomUpdater

func (d *Database) GetRoomUpdater(
	ctx context.Context, roomInfo *types.RoomInfo,
) (*shared.RoomUpdater, 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