shared

Documentation

Index

• type Database
  • func (d *Database) AssociateTransactionWithDestinations(ctx context.Context, destinations map[gomatrixserverlib.UserID]struct{}, ...) error
  • func (d *Database) CleanTransactions(ctx context.Context, userID gomatrixserverlib.UserID, ...) error
  • func (d *Database) GetTransaction(ctx context.Context, userID gomatrixserverlib.UserID) (*gomatrixserverlib.Transaction, *receipt.Receipt, error)
  • func (d *Database) GetTransactionCount(ctx context.Context, userID gomatrixserverlib.UserID) (int64, error)
  • func (d *Database) StoreTransaction(ctx context.Context, transaction gomatrixserverlib.Transaction) (*receipt.Receipt, error)

Types

type Database

type Database struct {
	DB                *sql.DB
	IsLocalServerName func(gomatrixserverlib.ServerName) bool
	Cache             caching.FederationCache
	Writer            sqlutil.Writer
	RelayQueue        tables.RelayQueue
	RelayQueueJSON    tables.RelayQueueJSON
}

func (*Database) AssociateTransactionWithDestinations

func (d *Database) AssociateTransactionWithDestinations(
	ctx context.Context,
	destinations map[gomatrixserverlib.UserID]struct{},
	transactionID gomatrixserverlib.TransactionID,
	dbReceipt *receipt.Receipt,
) error

func (*Database) CleanTransactions

func (d *Database) CleanTransactions(
	ctx context.Context,
	userID gomatrixserverlib.UserID,
	receipts []*receipt.Receipt,
) error

func (*Database) GetTransaction

func (d *Database) GetTransaction(
	ctx context.Context,
	userID gomatrixserverlib.UserID,
) (*gomatrixserverlib.Transaction, *receipt.Receipt, error)

func (*Database) GetTransactionCount

func (d *Database) GetTransactionCount(
	ctx context.Context,
	userID gomatrixserverlib.UserID,
) (int64, error)

func (*Database) StoreTransaction

func (d *Database) StoreTransaction(
	ctx context.Context,
	transaction gomatrixserverlib.Transaction,
) (*receipt.Receipt, error)