postgres

Documentation

Index

• func NewPostgresAccountDataTable(db *sql.DB) (tables.AccountData, error)
• func NewPostgresBackwardsExtremitiesTable(db *sql.DB) (tables.BackwardsExtremities, error)
• func NewPostgresCurrentRoomStateTable(db *sql.DB) (tables.CurrentRoomState, error)
• func NewPostgresEventsTable(db *sql.DB) (tables.Events, error)
• func NewPostgresFilterTable(db *sql.DB) (tables.Filter, error)
• func NewPostgresIgnoresTable(db *sql.DB) (tables.Ignores, error)
• func NewPostgresInvitesTable(db *sql.DB) (tables.Invites, error)
• func NewPostgresMembershipsTable(db *sql.DB) (tables.Memberships, error)
• func NewPostgresNotificationDataTable(db *sql.DB) (tables.NotificationData, error)
• func NewPostgresPeeksTable(db *sql.DB) (tables.Peeks, error)
• func NewPostgresPresenceTable(db *sql.DB) (*presenceStatements, error)
• func NewPostgresReceiptsTable(db *sql.DB) (tables.Receipts, error)
• func NewPostgresSendToDeviceTable(db *sql.DB) (tables.SendToDevice, error)
• func NewPostgresTopologyTable(db *sql.DB) (tables.Topology, error)
• type SyncServerDatasource
  • func NewDatabase(base *base.BaseDendrite, dbProperties *config.DatabaseOptions) (*SyncServerDatasource, error)

Functions

func NewPostgresAccountDataTable

func NewPostgresAccountDataTable(db *sql.DB) (tables.AccountData, error)

func NewPostgresBackwardsExtremitiesTable

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

func NewPostgresCurrentRoomStateTable

func NewPostgresCurrentRoomStateTable(db *sql.DB) (tables.CurrentRoomState, error)

func NewPostgresEventsTable

func NewPostgresEventsTable(db *sql.DB) (tables.Events, error)

func NewPostgresFilterTable

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

func NewPostgresIgnoresTable

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

func NewPostgresInvitesTable

func NewPostgresInvitesTable(db *sql.DB) (tables.Invites, error)

func NewPostgresMembershipsTable

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

func NewPostgresNotificationDataTable

func NewPostgresNotificationDataTable(db *sql.DB) (tables.NotificationData, error)

func NewPostgresPeeksTable

func NewPostgresPeeksTable(db *sql.DB) (tables.Peeks, error)

func NewPostgresPresenceTable

func NewPostgresPresenceTable(db *sql.DB) (*presenceStatements, error)

func NewPostgresReceiptsTable

func NewPostgresReceiptsTable(db *sql.DB) (tables.Receipts, error)

func NewPostgresSendToDeviceTable

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

func NewPostgresTopologyTable

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

Types

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