sqlite3

Documentation

Index

• Constants
• func NewSqliteAccountDataTable(db *sql.DB, streamID *streamIDStatements) (tables.AccountData, error)
• func NewSqliteBackwardsExtremitiesTable(db *sql.DB) (tables.BackwardsExtremities, error)
• func NewSqliteCurrentRoomStateTable(db *sql.DB, streamID *streamIDStatements) (tables.CurrentRoomState, error)
• func NewSqliteEventsTable(db *sql.DB, streamID *streamIDStatements) (tables.Events, error)
• func NewSqliteFilterTable(db *sql.DB) (tables.Filter, error)
• func NewSqliteInvitesTable(db *sql.DB, streamID *streamIDStatements) (tables.Invites, error)
• func NewSqlitePeeksTable(db *sql.DB, streamID *streamIDStatements) (tables.Peeks, error)
• func NewSqliteReceiptsTable(db *sql.DB, streamID *streamIDStatements) (tables.Receipts, error)
• func NewSqliteSendToDeviceTable(db *sql.DB) (tables.SendToDevice, error)
• func NewSqliteTopologyTable(db *sql.DB) (tables.Topology, error)
• type SyncServerDatasource
  • func NewDatabase(dbProperties *config.DatabaseOptions) (*SyncServerDatasource, error)

Constants

const DeleteRoomStateForRoomSQL = "" +
	"DELETE FROM syncapi_current_room_state WHERE event_id = $1"

Functions

func NewSqliteAccountDataTable

func NewSqliteAccountDataTable(db *sql.DB, streamID *streamIDStatements) (tables.AccountData, error)

func NewSqliteBackwardsExtremitiesTable

func NewSqliteBackwardsExtremitiesTable(db *sql.DB) (tables.BackwardsExtremities, error)

func NewSqliteCurrentRoomStateTable

func NewSqliteCurrentRoomStateTable(db *sql.DB, streamID *streamIDStatements) (tables.CurrentRoomState, error)

func NewSqliteEventsTable

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

func NewSqliteFilterTable

func NewSqliteFilterTable(db *sql.DB) (tables.Filter, error)

func NewSqliteInvitesTable

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

func NewSqlitePeeksTable

func NewSqlitePeeksTable(db *sql.DB, streamID *streamIDStatements) (tables.Peeks, error)

func NewSqliteReceiptsTable

func NewSqliteReceiptsTable(db *sql.DB, streamID *streamIDStatements) (tables.Receipts, error)

func NewSqliteSendToDeviceTable

func NewSqliteSendToDeviceTable(db *sql.DB) (tables.SendToDevice, error)

func NewSqliteTopologyTable

func NewSqliteTopologyTable(db *sql.DB) (tables.Topology, error)

Types

type SyncServerDatasource

type SyncServerDatasource struct {
	shared.Database

	sqlutil.PartitionOffsetStatements
	// contains filtered or unexported fields
}

SyncServerDatasource represents a sync server datasource which manages both the database for PDUs and caches for EDUs.

func NewDatabase

func NewDatabase(dbProperties *config.DatabaseOptions) (*SyncServerDatasource, error)

NewDatabase creates a new sync server database nolint: gocyclo