postgres

package
v0.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 16, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewPostgresAssumedOfflineTable 

func NewPostgresAssumedOfflineTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.FederationAssumedOffline, error)

NewPostgresAssumedOfflineTable creates a new postgres assumed offline table

func NewPostgresBlacklistTable 

func NewPostgresBlacklistTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.FederationBlacklist, error)

NewPostgresBlacklistTable creates a new postgres blacklist table

func NewPostgresInboundPeeksTable 

func NewPostgresInboundPeeksTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.FederationInboundPeeks, error)

NewPostgresInboundPeeksTable creates a new postgres inbound peeks table

func NewPostgresJoinedHostsTable 

func NewPostgresJoinedHostsTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.FederationJoinedHosts, error)

NewPostgresJoinedHostsTable creates a new postgres joined hosts table

func NewPostgresNotaryServerKeysMetadataTable 

func NewPostgresNotaryServerKeysMetadataTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.FederationNotaryServerKeysMetadata, error)

NewPostgresNotaryServerKeysMetadataTable creates a new postgres notary server keys metadata table

func NewPostgresNotaryServerKeysTable 

func NewPostgresNotaryServerKeysTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.FederationNotaryServerKeysJSON, error)

NewPostgresNotaryServerKeysTable creates a new postgres notary server keys table

func NewPostgresOutboundPeeksTable 

func NewPostgresOutboundPeeksTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.FederationOutboundPeeks, error)

NewPostgresOutboundPeeksTable creates a new postgres outbound peeks table

func NewPostgresQueueEDUsTable 

func NewPostgresQueueEDUsTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.FederationQueueEDUs, error)

NewPostgresQueueEDUsTable creates a new postgres queue EDUs table

func NewPostgresQueueJSONTable 

func NewPostgresQueueJSONTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.FederationQueueJSON, error)

NewPostgresQueueJSONTable creates a new postgres queue JSON table

func NewPostgresQueuePDUsTable 

func NewPostgresQueuePDUsTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.FederationQueuePDUs, error)

NewPostgresQueuePDUsTable creates a new postgres queue PDUs table

func NewPostgresRelayServersTable 

func NewPostgresRelayServersTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.FederationRelayServers, error)

NewPostgresRelayServersTable creates a new postgres relay servers table

func NewPostgresServerSigningKeysTable 

func NewPostgresServerSigningKeysTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.FederationServerSigningKeys, error)

NewPostgresServerSigningKeysTable creates a new postgres server signing keys table

Types

type Database 

type Database struct {
	shared.Database
}

Database stores information needed by the federation sender

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.