immudb

Documentation

Index

• Constants
• func KeyFediAccountLoginCount(accountID int64) []byte
• func KeyFediAccountLoginLast(accountID int64) []byte
• type Client
  • func New(ctx context.Context, m metrics.Collector) (*Client, error)
  • func (c *Client) Close(ctx context.Context) db.Error
  • func (c *Client) CountFediAccounts(ctx context.Context) (int64, db.Error)
  • func (c *Client) CountFediAccountsForInstance(ctx context.Context, instanceID int64) (int64, db.Error)
  • func (*Client) CountFediAccountsWithCouncil(_ context.Context) (count int64, err db.Error)
  • func (c *Client) CountFediInstances(ctx context.Context) (int64, db.Error)
  • func (c *Client) CountTransactions(ctx context.Context) (count int64, err db.Error)
  • func (c *Client) CreateFediAccount(ctx context.Context, account *models.FediAccount) db.Error
  • func (c *Client) CreateFediInstance(ctx context.Context, instance *models.FediInstance) db.Error
  • func (c *Client) CreateTransaction(ctx context.Context, transaction *models.Transaction) (err db.Error)
  • func (c *Client) CreateTransactionTX(ctx context.Context, txID db.TxID, transaction *models.Transaction) (err db.Error)
  • func (c *Client) DoMigration(ctx context.Context) db.Error
  • func (c *Client) IncFediAccountLoginCount(ctx context.Context, account *models.FediAccount) db.Error
  • func (c *Client) LoadTestData(_ context.Context) db.Error
  • func (c *Client) PageHelper(ctx context.Context, tableName string, index, count int) (int64, error)
  • func (*Client) ProcessError(err error) db.Error
  • func (c *Client) ReadFediAccount(ctx context.Context, id int64) (*models.FediAccount, db.Error)
  • func (c *Client) ReadFediAccountByUsername(ctx context.Context, instanceID int64, username string) (*models.FediAccount, db.Error)
  • func (c *Client) ReadFediAccountsPage(ctx context.Context, index, count int) ([]*models.FediAccount, db.Error)
  • func (c *Client) ReadFediInstance(ctx context.Context, id int64) (*models.FediInstance, db.Error)
  • func (c *Client) ReadFediInstanceByDomain(ctx context.Context, domain string) (*models.FediInstance, db.Error)
  • func (c *Client) ReadFediInstancesPage(ctx context.Context, index, count int) ([]*models.FediInstance, db.Error)
  • func (c *Client) ReadTransaction(ctx context.Context, id int64) (transaction *models.Transaction, err db.Error)
  • func (c *Client) ReadTransactionsPage(ctx context.Context, index, count int) (transactions []*models.Transaction, err db.Error)
  • func (c *Client) ResetCache(_ context.Context) db.Error
  • func (*Client) TxCommit(ctx context.Context, id db.TxID) db.Error
  • func (*Client) TxNew(ctx context.Context) (db.TxID, db.Error)
  • func (*Client) TxRollback(ctx context.Context, id db.TxID) db.Error
  • func (c *Client) UpdateFediAccount(ctx context.Context, account *models.FediAccount) db.Error
  • func (c *Client) UpdateFediInstance(ctx context.Context, instance *models.FediInstance) db.Error

Constants

const (
	KeyNotFoundError = "rpc error: code = Unknown desc = key not found"
)

Functions

func KeyFediAccountLoginCount

func KeyFediAccountLoginCount(accountID int64) []byte

func KeyFediAccountLoginLast

func KeyFediAccountLoginLast(accountID int64) []byte

Types

type Client

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

Client is a DB interface compatible client for ImmuDB.

func New

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

New creates a new immudb database client.

func (*Client) Close

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

func (*Client) CountFediAccounts

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

func (*Client) CountFediAccountsForInstance

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

func (*Client) CountFediAccountsWithCouncil

func (*Client) CountFediAccountsWithCouncil(_ context.Context) (count int64, err db.Error)

func (*Client) CountFediInstances

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

func (*Client) CountTransactions

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

func (*Client) CreateFediAccount

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

func (*Client) CreateFediInstance

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

func (*Client) CreateTransaction

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

func (*Client) CreateTransactionTX

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

func (*Client) DoMigration

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

func (*Client) IncFediAccountLoginCount

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

func (*Client) LoadTestData

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

func (*Client) PageHelper

func (c *Client) PageHelper(ctx context.Context, tableName string, index, count int) (int64, error)

func (*Client) ProcessError

func (*Client) ProcessError(err error) db.Error

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

func (*Client) ReadFediAccount

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

func (*Client) ReadFediAccountByUsername

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

func (*Client) ReadFediAccountsPage

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

func (*Client) ReadFediInstance

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

func (*Client) ReadFediInstanceByDomain

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

func (*Client) ReadFediInstancesPage

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

func (*Client) ReadTransaction

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

func (*Client) ReadTransactionsPage

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

func (*Client) ResetCache

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

func (*Client) TxCommit

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

func (*Client) TxNew

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

func (*Client) TxRollback

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

func (*Client) UpdateFediAccount

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

func (*Client) UpdateFediInstance

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