postgres

Documentation

Index

• func NewPostgresAssumedOfflineTable(ctx context.Context, db *sql.DB) (s *assumedOfflineStatements, err error)
• func NewPostgresBlacklistTable(ctx context.Context, db *sql.DB) (s *blacklistStatements, err error)
• func NewPostgresInboundPeeksTable(ctx context.Context, db *sql.DB) (s *inboundPeeksStatements, err error)
• func NewPostgresJoinedHostsTable(ctx context.Context, db *sql.DB) (s *joinedHostsStatements, err error)
• func NewPostgresNotaryServerKeysMetadataTable(ctx context.Context, db *sql.DB) (s *notaryServerKeysMetadataStatements, err error)
• func NewPostgresNotaryServerKeysTable(ctx context.Context, db *sql.DB) (s *notaryServerKeysStatements, err error)
• func NewPostgresOutboundPeeksTable(ctx context.Context, db *sql.DB) (s *outboundPeeksStatements, err error)
• func NewPostgresQueueEDUsTable(ctx context.Context, db *sql.DB) (s *queueEDUsStatements, err error)
• func NewPostgresQueueJSONTable(ctx context.Context, db *sql.DB) (s *queueJSONStatements, err error)
• func NewPostgresQueuePDUsTable(ctx context.Context, db *sql.DB) (s *queuePDUsStatements, err error)
• func NewPostgresRelayServersTable(ctx context.Context, db *sql.DB) (s *relayServersStatements, err error)
• func NewPostgresServerSigningKeysTable(ctx context.Context, db *sql.DB) (s *serverSigningKeyStatements, err error)
• type Database
  • func NewDatabase(ctx context.Context, conMan *sqlutil.Connections, ...) (*Database, error)

Functions

func NewPostgresAssumedOfflineTable

func NewPostgresAssumedOfflineTable(ctx context.Context, db *sql.DB) (s *assumedOfflineStatements, err error)

func NewPostgresBlacklistTable

func NewPostgresBlacklistTable(ctx context.Context, db *sql.DB) (s *blacklistStatements, err error)

func NewPostgresInboundPeeksTable

func NewPostgresInboundPeeksTable(ctx context.Context, db *sql.DB) (s *inboundPeeksStatements, err error)

func NewPostgresJoinedHostsTable

func NewPostgresJoinedHostsTable(ctx context.Context, db *sql.DB) (s *joinedHostsStatements, err error)

func NewPostgresNotaryServerKeysMetadataTable

func NewPostgresNotaryServerKeysMetadataTable(ctx context.Context, db *sql.DB) (s *notaryServerKeysMetadataStatements, err error)

func NewPostgresNotaryServerKeysTable

func NewPostgresNotaryServerKeysTable(ctx context.Context, db *sql.DB) (s *notaryServerKeysStatements, err error)

func NewPostgresOutboundPeeksTable

func NewPostgresOutboundPeeksTable(ctx context.Context, db *sql.DB) (s *outboundPeeksStatements, err error)

func NewPostgresQueueEDUsTable

func NewPostgresQueueEDUsTable(ctx context.Context, db *sql.DB) (s *queueEDUsStatements, err error)

func NewPostgresQueueJSONTable

func NewPostgresQueueJSONTable(ctx context.Context, db *sql.DB) (s *queueJSONStatements, err error)

func NewPostgresQueuePDUsTable

func NewPostgresQueuePDUsTable(ctx context.Context, db *sql.DB) (s *queuePDUsStatements, err error)

func NewPostgresRelayServersTable

func NewPostgresRelayServersTable(ctx context.Context, db *sql.DB) (s *relayServersStatements, err error)

func NewPostgresServerSigningKeysTable

func NewPostgresServerSigningKeysTable(ctx context.Context, db *sql.DB) (s *serverSigningKeyStatements, err error)

Types

type Database

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

Database stores information needed by the federation sender

func NewDatabase

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

NewDatabase opens a new database