postgres

Documentation

Index

• Constants
• 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 NewPostgresInvitesTable(db *sql.DB) (tables.Invites, error)
• func NewPostgresPeeksTable(db *sql.DB) (tables.Peeks, 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(dbProperties *config.DatabaseOptions) (*SyncServerDatasource, error)

Constants

const DeleteRoomStateForRoomSQL = "" +
	"DELETE FROM syncapi_current_room_state WHERE event_id = $1"

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 NewPostgresInvitesTable

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

func NewPostgresPeeksTable

func NewPostgresPeeksTable(db *sql.DB) (tables.Peeks, 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

	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