database

Documentation

Index

• type Instance
  • func InitDB(connType, connStr string) (*Instance, error)
  • func (db *Instance) CheckUserIdentityExists(userid string) bool
  • func (db *Instance) Close() error
  • func (db *Instance) ConfirmEmailByUserID(userID string) error
  • func (db *Instance) CreateClient(ci *models.Client) error
  • func (db *Instance) CreateUser(user *models.User) error
  • func (db *Instance) CreateUserIdentity(identity *models.UserIdentity) error
  • func (db *Instance) DeleteClient(id string) error
  • func (db *Instance) EnqueueDirectWrite(job WriteJob) error
  • func (db *Instance) EnqueueWrite(job WriteJob) error
  • func (db *Instance) GetClientByID(id string) (*models.Client, error)
  • func (db *Instance) GetClientByUserID(userID string) (*models.Client, error)
  • func (db *Instance) GetCorrespondingUser(identity_id string) (*models.User, error)
  • func (db *Instance) GetOrCreateUser(pbuser *pb.User, provider string) (*pb.User, error)
  • func (db *Instance) GetUserByEmail(email string) (*models.User, error)
  • func (db *Instance) GetUserByID(id string) (*models.User, error)
  • func (db *Instance) GetUserByName(name string) (*models.User, error)
  • func (db *Instance) UpdateClient(ci *models.Client) error
• type WriteJob

Types

type Instance

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

func InitDB

func InitDB(connType, connStr string) (*Instance, error)

func (*Instance) CheckUserIdentityExists

func (db *Instance) CheckUserIdentityExists(userid string) bool

func (*Instance) Close

func (db *Instance) Close() error

func (*Instance) ConfirmEmailByUserID

func (db *Instance) ConfirmEmailByUserID(userID string) error

func (*Instance) CreateClient

func (db *Instance) CreateClient(ci *models.Client) error

func (*Instance) CreateUser

func (db *Instance) CreateUser(user *models.User) error

func (*Instance) CreateUserIdentity

func (db *Instance) CreateUserIdentity(identity *models.UserIdentity) error

func (*Instance) DeleteClient

func (db *Instance) DeleteClient(id string) error

func (*Instance) EnqueueDirectWrite

func (db *Instance) EnqueueDirectWrite(job WriteJob) error

func (*Instance) EnqueueWrite

func (db *Instance) EnqueueWrite(job WriteJob) error

func (*Instance) GetClientByID

func (db *Instance) GetClientByID(id string) (*models.Client, error)

func (*Instance) GetClientByUserID

func (db *Instance) GetClientByUserID(userID string) (*models.Client, error)

func (*Instance) GetCorrespondingUser

func (db *Instance) GetCorrespondingUser(identity_id string) (*models.User, error)

func (*Instance) GetOrCreateUser

func (db *Instance) GetOrCreateUser(pbuser *pb.User, provider string) (*pb.User, error)

func (*Instance) GetUserByEmail

func (db *Instance) GetUserByEmail(email string) (*models.User, error)

func (*Instance) GetUserByID

func (db *Instance) GetUserByID(id string) (*models.User, error)

func (*Instance) GetUserByName

func (db *Instance) GetUserByName(name string) (*models.User, error)

func (*Instance) UpdateClient

func (db *Instance) UpdateClient(ci *models.Client) error

type WriteJob

type WriteJob func(bun.Tx) error