postgres

Documentation

Index

• func NewPostgresEventJSONTable(db *sql.DB) (tables.EventJSON, error)
• func NewPostgresEventStateKeysTable(db *sql.DB) (tables.EventStateKeys, error)
• func NewPostgresEventTypesTable(db *sql.DB) (tables.EventTypes, error)
• func NewPostgresEventsTable(db *sql.DB) (tables.Events, error)
• func NewPostgresInvitesTable(db *sql.DB) (tables.Invites, error)
• func NewPostgresMembershipTable(db *sql.DB) (tables.Membership, error)
• func NewPostgresPreviousEventsTable(db *sql.DB) (tables.PreviousEvents, error)
• func NewPostgresPublishedTable(db *sql.DB) (tables.Published, error)
• func NewPostgresRedactionsTable(db *sql.DB) (tables.Redactions, error)
• func NewPostgresRoomAliasesTable(db *sql.DB) (tables.RoomAliases, error)
• func NewPostgresRoomsTable(db *sql.DB) (tables.Rooms, error)
• func NewPostgresStateBlockTable(db *sql.DB) (tables.StateBlock, error)
• func NewPostgresStateSnapshotTable(db *sql.DB) (tables.StateSnapshot, error)
• func NewPostgresTransactionsTable(db *sql.DB) (tables.Transactions, error)
• type Database
  • func Open(dbProperties *config.DatabaseOptions, cache caching.RoomServerCaches) (*Database, error)

Functions

func NewPostgresEventJSONTable

func NewPostgresEventJSONTable(db *sql.DB) (tables.EventJSON, error)

func NewPostgresEventStateKeysTable

func NewPostgresEventStateKeysTable(db *sql.DB) (tables.EventStateKeys, error)

func NewPostgresEventTypesTable

func NewPostgresEventTypesTable(db *sql.DB) (tables.EventTypes, error)

func NewPostgresEventsTable

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

func NewPostgresInvitesTable

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

func NewPostgresMembershipTable

func NewPostgresMembershipTable(db *sql.DB) (tables.Membership, error)

func NewPostgresPreviousEventsTable

func NewPostgresPreviousEventsTable(db *sql.DB) (tables.PreviousEvents, error)

func NewPostgresPublishedTable

func NewPostgresPublishedTable(db *sql.DB) (tables.Published, error)

func NewPostgresRedactionsTable

func NewPostgresRedactionsTable(db *sql.DB) (tables.Redactions, error)

func NewPostgresRoomAliasesTable

func NewPostgresRoomAliasesTable(db *sql.DB) (tables.RoomAliases, error)

func NewPostgresRoomsTable

func NewPostgresRoomsTable(db *sql.DB) (tables.Rooms, error)

func NewPostgresStateBlockTable

func NewPostgresStateBlockTable(db *sql.DB) (tables.StateBlock, error)

func NewPostgresStateSnapshotTable

func NewPostgresStateSnapshotTable(db *sql.DB) (tables.StateSnapshot, error)

func NewPostgresTransactionsTable

func NewPostgresTransactionsTable(db *sql.DB) (tables.Transactions, error)

Types

type Database

type Database struct {
	shared.Database
}

A Database is used to store room events and stream offsets.

func Open

func Open(dbProperties *config.DatabaseOptions, cache caching.RoomServerCaches) (*Database, error)

Open a postgres database. nolint: gocyclo