user_objects

Documentation

Index

• type DB
  • func NewDB(conn *pgxpool.Pool, commonDB database.CommonDB) *DB
  • func (db *DB) CheckIsIndirectAdminByID(ctx context.Context, userObjectID entry.UserObjectID) (bool, error)
  • func (db *DB) GetObjectIndirectAdmins(ctx context.Context, objectID umid.UMID) ([]*umid.UMID, error)
  • func (db *DB) GetUserObjectByID(ctx context.Context, userObjectID entry.UserObjectID) (*entry.UserObject, error)
  • func (db *DB) GetUserObjectValueByID(ctx context.Context, userObjectID entry.UserObjectID) (*entry.UserObjectValue, error)
  • func (db *DB) GetUserObjects(ctx context.Context) ([]*entry.UserObject, error)
  • func (db *DB) GetUserObjectsByObjectID(ctx context.Context, objectID umid.UMID) ([]*entry.UserObject, error)
  • func (db *DB) GetUserObjectsByUserID(ctx context.Context, userID umid.UMID) ([]*entry.UserObject, error)
  • func (db *DB) RemoveUserObjectByID(ctx context.Context, userObjectID entry.UserObjectID) error
  • func (db *DB) RemoveUserObjectsByIDs(ctx context.Context, userObjectIDs []entry.UserObjectID) error
  • func (db *DB) UpdateUserObjectValue(ctx context.Context, userObjectID entry.UserObjectID, ...) (*entry.UserObjectValue, error)
  • func (db *DB) UpsertUserObject(ctx context.Context, userObjectID entry.UserObjectID, ...) (*entry.UserObjectValue, error)

Types

type DB

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

func NewDB

func NewDB(conn *pgxpool.Pool, commonDB database.CommonDB) *DB

func (*DB) CheckIsIndirectAdminByID

func (db *DB) CheckIsIndirectAdminByID(ctx context.Context, userObjectID entry.UserObjectID) (bool, error)

func (*DB) GetObjectIndirectAdmins

func (db *DB) GetObjectIndirectAdmins(ctx context.Context, objectID umid.UMID) ([]*umid.UMID, error)

func (*DB) GetUserObjectByID

func (db *DB) GetUserObjectByID(ctx context.Context, userObjectID entry.UserObjectID) (*entry.UserObject, error)

func (*DB) GetUserObjectValueByID

func (db *DB) GetUserObjectValueByID(
	ctx context.Context, userObjectID entry.UserObjectID,
) (*entry.UserObjectValue, error)

func (*DB) GetUserObjects

func (db *DB) GetUserObjects(ctx context.Context) ([]*entry.UserObject, error)

func (*DB) GetUserObjectsByObjectID

func (db *DB) GetUserObjectsByObjectID(ctx context.Context, objectID umid.UMID) ([]*entry.UserObject, error)

func (*DB) GetUserObjectsByUserID

func (db *DB) GetUserObjectsByUserID(ctx context.Context, userID umid.UMID) ([]*entry.UserObject, error)

func (*DB) RemoveUserObjectByID

func (db *DB) RemoveUserObjectByID(ctx context.Context, userObjectID entry.UserObjectID) error

func (*DB) RemoveUserObjectsByIDs

func (db *DB) RemoveUserObjectsByIDs(ctx context.Context, userObjectIDs []entry.UserObjectID) error

func (*DB) UpdateUserObjectValue

func (db *DB) UpdateUserObjectValue(
	ctx context.Context, userObjectID entry.UserObjectID, modifyFn modify.Fn[entry.UserObjectValue],
) (*entry.UserObjectValue, error)

func (*DB) UpsertUserObject

func (db *DB) UpsertUserObject(
	ctx context.Context, userObjectID entry.UserObjectID, modifyFn modify.Fn[entry.UserObjectValue],
) (*entry.UserObjectValue, error)