sqlite3

package

v0.0.0-...-811715e Latest Latest Go to latest Published: Nov 29, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

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/RickJou/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(base *base.BaseDendrite, dbProperties *config.DatabaseOptions) (*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 ¶

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(base *base.BaseDendrite, 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)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
deltas

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