Documentation
¶
Index ¶
- func NewPostgresAccountDataTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.AccountData, error)
- func NewPostgresBackwardsExtremitiesTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.BackwardsExtremities, error)
- func NewPostgresCurrentRoomStateTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.CurrentRoomState, error)
- func NewPostgresEventsTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Events, error)
- func NewPostgresFilterTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Filter, error)
- func NewPostgresIgnoresTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Ignores, error)
- func NewPostgresInvitesTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Invites, error)
- func NewPostgresMembershipsTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Memberships, error)
- func NewPostgresNotificationDataTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.NotificationData, error)
- func NewPostgresPeeksTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Peeks, error)
- func NewPostgresPresenceTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Presence, error)
- func NewPostgresReceiptsTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Receipts, error)
- func NewPostgresRelationsTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Relations, error)
- func NewPostgresSendToDeviceTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.SendToDevice, error)
- func NewPostgresTopologyTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.Topology, error)
- type SyncServerDatasource
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPostgresAccountDataTable ¶
func NewPostgresAccountDataTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.AccountData, error)
NewPostgresAccountDataTable creates a new postgres account data table
func NewPostgresBackwardsExtremitiesTable ¶
func NewPostgresBackwardsExtremitiesTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.BackwardsExtremities, error)
NewPostgresBackwardsExtremitiesTable creates a new backward extremities table
func NewPostgresCurrentRoomStateTable ¶
func NewPostgresCurrentRoomStateTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.CurrentRoomState, error)
NewPostgresCurrentRoomStateTable creates a new CurrentRoomState table
func NewPostgresEventsTable ¶
NewPostgresEventsTable creates a new events table
func NewPostgresFilterTable ¶
NewPostgresFilterTable creates a new filter table
func NewPostgresIgnoresTable ¶
func NewPostgresIgnoresTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Ignores, error)
NewPostgresIgnoresTable creates a new ignores table
func NewPostgresInvitesTable ¶
func NewPostgresInvitesTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Invites, error)
NewPostgresInvitesTable creates a new invites table
func NewPostgresMembershipsTable ¶
func NewPostgresMembershipsTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Memberships, error)
NewPostgresMembershipsTable creates a new memberships table
func NewPostgresNotificationDataTable ¶
func NewPostgresNotificationDataTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.NotificationData, error)
NewPostgresNotificationDataTable creates a new notification data table
func NewPostgresPeeksTable ¶
NewPostgresPeeksTable creates a new peeks table
func NewPostgresPresenceTable ¶
func NewPostgresPresenceTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Presence, error)
NewPostgresPresenceTable creates a new presence table
func NewPostgresReceiptsTable ¶
func NewPostgresReceiptsTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Receipts, error)
NewPostgresReceiptsTable creates a new receipts table
func NewPostgresRelationsTable ¶
func NewPostgresRelationsTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.Relations, error)
NewPostgresRelationsTable creates a new relations table
func NewPostgresSendToDeviceTable ¶
func NewPostgresSendToDeviceTable(_ context.Context, cm sqlutil.ConnectionManager) (tables.SendToDevice, error)
NewPostgresSendToDeviceTable creates a new send-to-device table
func NewPostgresTopologyTable ¶
func NewPostgresTopologyTable(ctx context.Context, cm sqlutil.ConnectionManager) (tables.Topology, error)
NewPostgresTopologyTable creates a new topology table
Types ¶
type SyncServerDatasource ¶
SyncServerDatasource represents a sync server datasource which manages both the database for PDUs and caches for EDUs.
func NewDatabase ¶
func NewDatabase(ctx context.Context, cm sqlutil.ConnectionManager) (*SyncServerDatasource, error)
NewDatabase creates a new sync server database
Source Files
¶
- account_data_table.go
- backwards_extremities_table.go
- current_room_state_table.go
- filter_table.go
- filtering.go
- ignores_table.go
- invites_table.go
- memberships_table.go
- notification_data_table.go
- output_room_events_table.go
- output_room_events_topology_table.go
- peeks_table.go
- presence_table.go
- receipt_table.go
- relations_table.go
- send_to_device_table.go
- storage.go