sqlite3

package
Version: v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 24, 2021 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const (
	FilterOrderNone = iota
	FilterOrderAsc
	FilterOrderDesc
)
View Source
const DeleteRoomStateForRoomSQL = "" +
	"DELETE FROM syncapi_current_room_state WHERE event_id = $1"

Variables

This section is empty.

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 NewSqliteMembershipsTable added in v0.3.7

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

func NewSqlitePeeksTable

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

func NewSqliteReceiptsTable added in v0.3.0

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 FilterOrder added in v0.3.7

type FilterOrder int

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL