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 NewSqliteIgnoresTable(db *sql.DB) (tables.Ignores, error)
• func NewSqliteInvitesTable(db *sql.DB, streamID *StreamIDStatements) (tables.Invites, error)
• func NewSqliteMembershipsTable(db *sql.DB) (tables.Memberships, error)
• func NewSqliteNotificationDataTable(db *sql.DB, streamID *StreamIDStatements) (tables.NotificationData, error)
• func NewSqlitePeeksTable(db *sql.DB, streamID *StreamIDStatements) (tables.Peeks, error)
• func NewSqlitePresenceTable(db *sql.DB, streamID *StreamIDStatements) (*presenceStatements, error)
• func NewSqliteReceiptsTable(db *sql.DB, streamID *StreamIDStatements) (tables.Receipts, error)
• func NewSqliteRelationsTable(db *sql.DB, streamID *StreamIDStatements) (tables.Relations, error)
• func NewSqliteSendToDeviceTable(db *sql.DB) (tables.SendToDevice, error)
• func NewSqliteTopologyTable(db *sql.DB) (tables.Topology, error)
• type FilterOrder
• type StreamIDStatements
  • func (s *StreamIDStatements) Prepare(db *sql.DB) (err error)
• type SyncServerDatasource
  • func NewDatabase(ctx context.Context, conMan *sqlutil.Connections, ...) (*SyncServerDatasource, error)
  • func (d *SyncServerDatasource) NewDatabaseSnapshot(ctx context.Context) (*shared.DatabaseTransaction, error)
  • func (d *SyncServerDatasource) NewDatabaseTransaction(ctx context.Context) (*shared.DatabaseTransaction, error)

Constants

const (
	FilterOrderNone = iota
	FilterOrderAsc
	FilterOrderDesc
)

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 NewSqliteIgnoresTable

func NewSqliteIgnoresTable(db *sql.DB) (tables.Ignores, error)

func NewSqliteInvitesTable

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

func NewSqliteMembershipsTable

func NewSqliteMembershipsTable(db *sql.DB) (tables.Memberships, error)

func NewSqliteNotificationDataTable

func NewSqliteNotificationDataTable(db *sql.DB, streamID *StreamIDStatements) (tables.NotificationData, error)

func NewSqlitePeeksTable

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

func NewSqlitePresenceTable

func NewSqlitePresenceTable(db *sql.DB, streamID *StreamIDStatements) (*presenceStatements, error)

func NewSqliteReceiptsTable

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

func NewSqliteRelationsTable

func NewSqliteRelationsTable(db *sql.DB, streamID *StreamIDStatements) (tables.Relations, error)

func NewSqliteSendToDeviceTable

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

func NewSqliteTopologyTable

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

Types

type FilterOrder

type FilterOrder int

type StreamIDStatements

type StreamIDStatements struct {
	// contains filtered or unexported fields
}

func (*StreamIDStatements) Prepare

func (s *StreamIDStatements) Prepare(db *sql.DB) (err error)

type SyncServerDatasource

type SyncServerDatasource struct {
	shared.Database
	// 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(ctx context.Context, conMan *sqlutil.Connections, dbProperties *config.DatabaseOptions) (*SyncServerDatasource, error)

NewDatabase creates a new sync server database nolint: gocyclo

func (*SyncServerDatasource) NewDatabaseSnapshot

func (d *SyncServerDatasource) NewDatabaseSnapshot(ctx context.Context) (*shared.DatabaseTransaction, error)

func (*SyncServerDatasource) NewDatabaseTransaction

func (d *SyncServerDatasource) NewDatabaseTransaction(ctx context.Context) (*shared.DatabaseTransaction, error)