postgres

Documentation

Index

• func NewPostgresRelayQueueJSONTable(db *sql.DB) (s *relayQueueJSONStatements, err error)
• func NewPostgresRelayQueueTable(db *sql.DB) (s *relayQueueStatements, err error)
• type Database
  • func NewDatabase(conMan *sqlutil.Connections, dbProperties *config.DatabaseOptions, ...) (*Database, error)

Functions

func NewPostgresRelayQueueJSONTable

func NewPostgresRelayQueueJSONTable(db *sql.DB) (s *relayQueueJSONStatements, err error)

func NewPostgresRelayQueueTable

func NewPostgresRelayQueueTable(
	db *sql.DB,
) (s *relayQueueStatements, err error)

Types

type Database

type Database struct {
	shared.Database
	// contains filtered or unexported fields
}

Database stores information needed by the relayapi

func NewDatabase

func NewDatabase(
	conMan *sqlutil.Connections,
	dbProperties *config.DatabaseOptions,
	cache caching.FederationCache,
	isLocalServerName func(spec.ServerName) bool,
) (*Database, error)

NewDatabase opens a new database