Versions in this module Expand all Collapse all v0 v0.14.0 Dec 18, 2024 Changes in this version + type Database interface + AddInboundPeek func(ctx context.Context, serverName spec.ServerName, roomID, peekID string, ...) error + AddOutboundPeek func(ctx context.Context, serverName spec.ServerName, roomID, peekID string, ...) error + AddServerToBlacklist func(serverName spec.ServerName) error + AssociateEDUWithDestinations func(ctx context.Context, destinations map[spec.ServerName]struct{}, ...) error + AssociatePDUWithDestinations func(ctx context.Context, destinations map[spec.ServerName]struct{}, ...) error + CleanEDUs func(ctx context.Context, serverName spec.ServerName, receipts []*receipt.Receipt) error + CleanPDUs func(ctx context.Context, serverName spec.ServerName, receipts []*receipt.Receipt) error + DeleteExpiredEDUs func(ctx context.Context) error + GetAllJoinedHosts func(ctx context.Context) ([]spec.ServerName, error) + GetInboundPeek func(ctx context.Context, serverName spec.ServerName, roomID, peekID string) (*types.InboundPeek, error) + GetInboundPeeks func(ctx context.Context, roomID string) ([]types.InboundPeek, error) + GetJoinedHosts func(ctx context.Context, roomID string) ([]types.JoinedHost, error) + GetJoinedHostsForRooms func(ctx context.Context, roomIDs []string, excludeSelf, excludeBlacklisted bool) ([]spec.ServerName, error) + GetNotaryKeys func(ctx context.Context, serverName spec.ServerName, ...) ([]gomatrixserverlib.ServerKeys, error) + GetOutboundPeek func(ctx context.Context, serverName spec.ServerName, roomID, peekID string) (*types.OutboundPeek, error) + GetOutboundPeeks func(ctx context.Context, roomID string) ([]types.OutboundPeek, error) + GetPendingEDUServerNames func(ctx context.Context) ([]spec.ServerName, error) + GetPendingEDUs func(ctx context.Context, serverName spec.ServerName, limit int) (edus map[*receipt.Receipt]*gomatrixserverlib.EDU, err error) + GetPendingPDUServerNames func(ctx context.Context) ([]spec.ServerName, error) + GetPendingPDUs func(ctx context.Context, serverName spec.ServerName, limit int) (pdus map[*receipt.Receipt]*rstypes.HeaderedEvent, err error) + IsServerAssumedOffline func(ctx context.Context, serverName spec.ServerName) (bool, error) + IsServerBlacklisted func(serverName spec.ServerName) (bool, error) + PurgeRoom func(ctx context.Context, roomID string) error + RemoveAllServersAssumedOffline func(ctx context.Context) error + RemoveAllServersFromBlacklist func() error + RemoveServerAssumedOffline func(ctx context.Context, serverName spec.ServerName) error + RemoveServerFromBlacklist func(serverName spec.ServerName) error + RenewInboundPeek func(ctx context.Context, serverName spec.ServerName, roomID, peekID string, ...) error + RenewOutboundPeek func(ctx context.Context, serverName spec.ServerName, roomID, peekID string, ...) error + SetServerAssumedOffline func(ctx context.Context, serverName spec.ServerName) error + StoreJSON func(ctx context.Context, js string) (*receipt.Receipt, error) + UpdateNotaryKeys func(ctx context.Context, serverName spec.ServerName, ...) error + UpdateRoom func(ctx context.Context, roomID string, addHosts []types.JoinedHost, ...) (joinedHosts []types.JoinedHost, err error) + func NewDatabase(ctx context.Context, conMan *sqlutil.Connections, ...) (Database, error) + func NewDatabase(ctx context.Context, conMan sqlutil.Connections, ...) (Database, error) + type P2PDatabase interface + P2PAddRelayServersForServer func(ctx context.Context, serverName spec.ServerName, ...) error + P2PGetRelayServersForServer func(ctx context.Context, serverName spec.ServerName) ([]spec.ServerName, error) + P2PRemoveAllRelayServersForServer func(ctx context.Context, serverName spec.ServerName) error + P2PRemoveRelayServersForServer func(ctx context.Context, serverName spec.ServerName, ...) error
Go to main page