storage

package

Go to main page

Versions in this module

v0

v0.0.4

Mar 12, 2025

v0.0.3

Mar 12, 2025

Changes in this version

+ type Database interface — darwin/amd64, linux/amd64, windows/amd64

+ 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)

+ type P2PDatabase interface — darwin/amd64, linux/amd64, windows/amd64

+ 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

v0.0.2

Mar 12, 2025

v0.0.1

Mar 12, 2025

Changes in this version

+ type Database interface — js/wasm

+ 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)

+ type P2PDatabase interface — js/wasm

+ 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL