sqlite3

package

v0.13.6 Latest Latest Go to latest Published: Jan 26, 2024 License: Apache-2.0 Imports: 22 Imported by: 4

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/matrix-org/dendrite

Links

Open Source Insights

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 ¶

View Source

const (
	FilterOrderNone = iota
	FilterOrderAsc
	FilterOrderDesc
)

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 NewSqliteIgnoresTable ¶ added in v0.8.0

func NewSqliteIgnoresTable(db *sql.DB) (tables.Ignores, 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 NewSqliteNotificationDataTable ¶ added in v0.6.5

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

func NewSqlitePeeksTable ¶

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

func NewSqlitePresenceTable ¶ added in v0.8.0

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

func NewSqliteReceiptsTable ¶ added in v0.3.0

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

func NewSqliteRelationsTable ¶ added in v0.10.3

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

type FilterOrder int

type StreamIDStatements ¶ added in v0.8.2

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

func (*StreamIDStatements) Prepare ¶ added in v0.8.2

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 ¶ added in v0.10.0

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

func (*SyncServerDatasource) NewDatabaseTransaction ¶ added in v0.10.0

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
deltas

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL