bun

package
v0.0.0-...-5767ed4 Latest Latest
Warning

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

Go to latest
Published: Aug 2, 2022 License: GPL-3.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Bun

type Bun struct {
	*bun.DB
	// contains filtered or unexported fields
}

Bun represents a bun db connection and it's error handler.

func (*Bun) ProcessError

func (conn *Bun) ProcessError(err error) db.Error

ProcessError replaces any known values with our own db.Error types.

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client is a DB interface compatible client for Bun.

func New

func New(ctx context.Context, m metrics.Collector) (*Client, error)

New creates a new bun database client.

func (*Client) Close

func (c *Client) Close(_ context.Context) db.Error

Close closes the bun db connection.

func (*Client) CountFediAccounts

func (c *Client) CountFediAccounts(ctx context.Context) (int64, db.Error)

CountFediAccounts returns the number of federated social account.

func (*Client) CountFediAccountsForInstance

func (c *Client) CountFediAccountsForInstance(ctx context.Context, instanceID int64) (int64, db.Error)

CountFediAccountsForInstance returns the number of federated social account for an instance.

func (*Client) CountFediAccountsWithCouncil

func (c *Client) CountFediAccountsWithCouncil(ctx context.Context) (int64, db.Error)

CountFediAccountsWithCouncil returns the number of federated social accounts which are on the council.

func (*Client) CountFediInstances

func (c *Client) CountFediInstances(ctx context.Context) (int64, db.Error)

CountFediInstances returns the number of federated instance.

func (*Client) CountTransactions

func (c *Client) CountTransactions(ctx context.Context) (int64, db.Error)

func (*Client) CreateFediAccount

func (c *Client) CreateFediAccount(ctx context.Context, account *models.FediAccount) db.Error

CreateFediAccount stores the federated social account.

func (*Client) CreateFediInstance

func (c *Client) CreateFediInstance(ctx context.Context, instance *models.FediInstance) db.Error

CreateFediInstance stores the federated instance.

func (*Client) CreateTransaction

func (c *Client) CreateTransaction(ctx context.Context, transaction *models.Transaction) db.Error

func (*Client) CreateTransactionTX

func (c *Client) CreateTransactionTX(ctx context.Context, txID db.TxID, transaction *models.Transaction) db.Error

func (*Client) DoMigration

func (c *Client) DoMigration(ctx context.Context) db.Error

DoMigration runs schema migrations on the database.

func (*Client) IncFediAccountLoginCount

func (c *Client) IncFediAccountLoginCount(ctx context.Context, account *models.FediAccount) db.Error

IncFediAccountLoginCount updates the login count of a stored federated instance.

func (*Client) LoadTestData

func (c *Client) LoadTestData(ctx context.Context) db.Error

LoadTestData adds test data to the database.

func (*Client) ReadFediAccount

func (c *Client) ReadFediAccount(ctx context.Context, id int64) (*models.FediAccount, db.Error)

ReadFediAccount returns one federated social account.

func (*Client) ReadFediAccountByUsername

func (c *Client) ReadFediAccountByUsername(ctx context.Context, instanceID int64, username string) (*models.FediAccount, db.Error)

ReadFediAccountByUsername returns one federated social account.

func (*Client) ReadFediAccountsPage

func (c *Client) ReadFediAccountsPage(ctx context.Context, index, count int) ([]*models.FediAccount, db.Error)

ReadFediAccountsPage returns a page of federated social accounts.

func (*Client) ReadFediInstance

func (c *Client) ReadFediInstance(ctx context.Context, id int64) (*models.FediInstance, db.Error)

ReadFediInstance returns one federated social instance.

func (*Client) ReadFediInstanceByDomain

func (c *Client) ReadFediInstanceByDomain(ctx context.Context, domain string) (*models.FediInstance, db.Error)

ReadFediInstanceByDomain returns one federated social instance.

func (*Client) ReadFediInstancesPage

func (c *Client) ReadFediInstancesPage(ctx context.Context, index, count int) ([]*models.FediInstance, db.Error)

ReadFediInstancesPage returns a page of federated social instances.

func (*Client) ReadTransaction

func (c *Client) ReadTransaction(ctx context.Context, id int64) (*models.Transaction, db.Error)

func (*Client) ReadTransactionsPage

func (c *Client) ReadTransactionsPage(ctx context.Context, index, count int) ([]*models.Transaction, db.Error)

func (*Client) ResetCache

func (*Client) ResetCache(_ context.Context) db.Error

ResetCache does nothing. This module contains no cache.

func (*Client) TxCommit

func (c *Client) TxCommit(_ context.Context, id db.TxID) db.Error

func (*Client) TxNew

func (c *Client) TxNew(ctx context.Context) (db.TxID, db.Error)

func (*Client) TxRollback

func (c *Client) TxRollback(_ context.Context, id db.TxID) db.Error

func (*Client) UpdateFediAccount

func (c *Client) UpdateFediAccount(ctx context.Context, account *models.FediAccount) db.Error

UpdateFediAccount updates the stored federated social account.

func (*Client) UpdateFediAccountTX

func (c *Client) UpdateFediAccountTX(ctx context.Context, txID db.TxID, account *models.FediAccount) db.Error

UpdateFediAccountTX updates the stored federated social account inside a transaction.

func (*Client) UpdateFediInstance

func (c *Client) UpdateFediInstance(ctx context.Context, instance *models.FediInstance) db.Error

UpdateFediInstance updates the stored federated instance.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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