bun

Documentation

Index

• type Bun
  • func (conn *Bun) ProcessError(err error) db.Error
• type Client
  • func New(ctx context.Context) (*Client, error)
  • func (c *Client) Close(ctx context.Context) db.Error
  • func (c *Client) CountAccounts(ctx context.Context) (int64, db.Error)
  • func (c *Client) CountAccountsForInstance(ctx context.Context, instanceID int64) (int64, db.Error)
  • func (c *Client) CountInstances(ctx context.Context) (int64, db.Error)
  • func (c *Client) CreateAccount(ctx context.Context, account *models.Account) db.Error
  • func (c *Client) CreateGroupMembershipTX(ctx context.Context, txID db.TxID, groupMemberships ...*models.GroupMembership) db.Error
  • func (c *Client) CreateInstance(ctx context.Context, instance *models.Instance) db.Error
  • func (c *Client) CreateInstanceTeamMember(ctx context.Context, instanceTeamMembers ...*models.InstanceTeamMember) db.Error
  • func (c *Client) DeleteGroupMembershipTX(ctx context.Context, txID db.TxID, groupMemberships ...*models.GroupMembership) db.Error
  • func (c *Client) DeleteInstanceTeamMember(ctx context.Context, instanceTeamMembers ...*models.InstanceTeamMember) db.Error
  • func (c *Client) DoMigration(ctx context.Context) db.Error
  • func (c *Client) IncAccountLoginCount(ctx context.Context, account *models.Account) db.Error
  • func (c *Client) ReadAccount(ctx context.Context, id int64) (*models.Account, db.Error)
  • func (c *Client) ReadAccountByUsername(ctx context.Context, instanceID int64, username string) (*models.Account, db.Error)
  • func (c *Client) ReadAccountsByUsernameInstancesStartingWith(ctx context.Context, prefix string, username string) ([]*models.Account, db.Error)
  • func (c *Client) ReadAccountsByUsernamesStartingWith(ctx context.Context, prefix string) ([]*models.Account, db.Error)
  • func (c *Client) ReadAccountsPage(ctx context.Context, index, count int) ([]*models.Account, db.Error)
  • func (c *Client) ReadInstance(ctx context.Context, id int64) (*models.Instance, db.Error)
  • func (c *Client) ReadInstanceByActorIRI(ctx context.Context, actorIRI string) (*models.Instance, db.Error)
  • func (c *Client) ReadInstanceByDomain(ctx context.Context, domain string) (*models.Instance, db.Error)
  • func (c *Client) ReadInstanceByServerHostname(ctx context.Context, serverHostname string) (*models.Instance, db.Error)
  • func (c *Client) ReadInstanceTeamMembersForInstance(ctx context.Context, instanceID int64) (models.InstanceTeam, db.Error)
  • func (c *Client) ReadInstances(ctx context.Context, ids ...int64) ([]*models.Instance, db.Error)
  • func (c *Client) ReadInstancesPage(ctx context.Context, index, count int) ([]*models.Instance, db.Error)
  • func (c *Client) ReadInstancesWithDomainSuffix(ctx context.Context, domainSuffix string) ([]*models.Instance, db.Error)
  • func (c *Client) TxCommit(_ context.Context, id db.TxID) db.Error
  • func (c *Client) TxNew(ctx context.Context) (db.TxID, db.Error)
  • func (c *Client) TxRollback(_ context.Context, id db.TxID) db.Error
  • func (c *Client) UpdateAccount(ctx context.Context, account *models.Account) db.Error
  • func (c *Client) UpdateInstance(ctx context.Context, instance *models.Instance) db.Error
  • func (c *Client) UpdateInstanceTX(ctx context.Context, txID db.TxID, instance *models.Instance) db.Error
  • func (c *Client) UpdateInstanceTeamMember(ctx context.Context, instanceTeamMembers ...*models.InstanceTeamMember) db.Error

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) (*Client, error)

New creates a new bun database client

func (*Client) Close

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

Close closes the bun db connection

func (*Client) CountAccounts

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

CountAccounts returns the number of federated social account.

func (*Client) CountAccountsForInstance

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

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

func (*Client) CountInstances

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

CountInstances returns the number of federated instances.

func (*Client) CreateAccount

func (c *Client) CreateAccount(ctx context.Context, account *models.Account) db.Error

CreateAccount stores the federated social account.

func (*Client) CreateGroupMembershipTX

func (c *Client) CreateGroupMembershipTX(ctx context.Context, txID db.TxID, groupMemberships ...*models.GroupMembership) db.Error

func (*Client) CreateInstance

func (c *Client) CreateInstance(ctx context.Context, instance *models.Instance) db.Error

CreateInstance stores the federated instance

func (*Client) CreateInstanceTeamMember

func (c *Client) CreateInstanceTeamMember(ctx context.Context, instanceTeamMembers ...*models.InstanceTeamMember) db.Error

CreateInstanceTeamMember stores the team memberships.

func (*Client) DeleteGroupMembershipTX

func (c *Client) DeleteGroupMembershipTX(ctx context.Context, txID db.TxID, groupMemberships ...*models.GroupMembership) db.Error

func (*Client) DeleteInstanceTeamMember

func (c *Client) DeleteInstanceTeamMember(ctx context.Context, instanceTeamMembers ...*models.InstanceTeamMember) db.Error

DeleteInstanceTeamMember deletes the team memberships.

func (*Client) DoMigration

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

DoMigration runs schema migrations on the database

func (*Client) IncAccountLoginCount

func (c *Client) IncAccountLoginCount(ctx context.Context, account *models.Account) db.Error

IncAccountLoginCount updates the login count of a stored federated instance.

func (*Client) ReadAccount

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

ReadAccount returns one federated social account.

func (*Client) ReadAccountByUsername

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

ReadAccountByUsername returns one federated social account.

func (*Client) ReadAccountsByUsernameInstancesStartingWith

func (c *Client) ReadAccountsByUsernameInstancesStartingWith(ctx context.Context, prefix string, username string) ([]*models.Account, db.Error)

func (*Client) ReadAccountsByUsernamesStartingWith

func (c *Client) ReadAccountsByUsernamesStartingWith(ctx context.Context, prefix string) ([]*models.Account, db.Error)

func (*Client) ReadAccountsPage

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

ReadAccountsPage returns a page of federated social accounts.

func (*Client) ReadInstance

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

ReadInstance returns one federated social instance

func (*Client) ReadInstanceByActorIRI

func (c *Client) ReadInstanceByActorIRI(ctx context.Context, actorIRI string) (*models.Instance, db.Error)

ReadInstanceByActorIRI returns one federated social instance

func (*Client) ReadInstanceByDomain

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

ReadInstanceByDomain returns one federated social instance

func (*Client) ReadInstanceByServerHostname

func (c *Client) ReadInstanceByServerHostname(ctx context.Context, serverHostname string) (*models.Instance, db.Error)

ReadInstanceByServerHostname returns one federated social instance

func (*Client) ReadInstanceTeamMembersForInstance

func (c *Client) ReadInstanceTeamMembersForInstance(ctx context.Context, instanceID int64) (models.InstanceTeam, db.Error)

func (*Client) ReadInstances

func (c *Client) ReadInstances(ctx context.Context, ids ...int64) ([]*models.Instance, db.Error)

ReadInstances returns a page of domain blocks.

func (*Client) ReadInstancesPage

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

ReadInstancesPage returns a page of domain blocks.

func (*Client) ReadInstancesWithDomainSuffix

func (c *Client) ReadInstancesWithDomainSuffix(ctx context.Context, domainSuffix string) ([]*models.Instance, db.Error)

ReadInstancesWithDomainSuffix returns all instances with domain suffix

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

func (c *Client) UpdateAccount(ctx context.Context, account *models.Account) db.Error

UpdateAccount updates the stored federated social account.

func (*Client) UpdateInstance

func (c *Client) UpdateInstance(ctx context.Context, instance *models.Instance) db.Error

UpdateInstance updates the stored federated instance

func (*Client) UpdateInstanceTX

func (c *Client) UpdateInstanceTX(ctx context.Context, txID db.TxID, instance *models.Instance) db.Error

UpdateInstanceTX updates the stored federated instance in a transaction.

func (*Client) UpdateInstanceTeamMember

func (c *Client) UpdateInstanceTeamMember(ctx context.Context, instanceTeamMembers ...*models.InstanceTeamMember) db.Error

UpdateInstanceTeamMember updates configs using a transaction.