postgres

Documentation

Index

• func NewPostgresRelayQueueJSONTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.RelayQueueJSON, error)
• func NewPostgresRelayQueueTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.RelayQueue, error)
• type Database
  • func NewDatabase(ctx context.Context, cm sqlutil.ConnectionManager, ...) (*Database, error)

Functions

func NewPostgresRelayQueueJSONTable

func NewPostgresRelayQueueJSONTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.RelayQueueJSON, error)

NewPostgresRelayQueueJSONTable creates a new relay queue JSON table

func NewPostgresRelayQueueTable

func NewPostgresRelayQueueTable(
	ctx context.Context, cm sqlutil.ConnectionManager,
) (tables.RelayQueue, error)

NewPostgresRelayQueueTable creates a new relay queue table

Types

type Database

type Database struct {
	shared.Database
}

Database stores information needed by the relayapi

func NewDatabase

func NewDatabase(
	ctx context.Context,
	cm sqlutil.ConnectionManager,
	cache cacheutil.FederationCache,
	isLocalServerName func(spec.ServerName) bool,
) (*Database, error)

NewDatabase opens a new database