accountInfra

Documentation

Index

• type AccountCmdRepo
  • func NewAccountCmdRepo(persistentDbSvc *internalDbInfra.PersistentDatabaseService) *AccountCmdRepo
  • func (repo *AccountCmdRepo) Create(createDto dto.CreateAccount) (accountId valueObject.AccountId, err error)
  • func (repo *AccountCmdRepo) Delete(accountId valueObject.AccountId) error
  • func (repo *AccountCmdRepo) UpdateApiKey(accountId valueObject.AccountId) (tokenValue valueObject.AccessTokenStr, err error)
  • func (repo *AccountCmdRepo) UpdatePassword(accountId valueObject.AccountId, password valueObject.Password) error
• type AccountQueryRepo
  • func NewAccountQueryRepo(persistentDbSvc *internalDbInfra.PersistentDatabaseService) *AccountQueryRepo
  • func (repo *AccountQueryRepo) Read() ([]entity.Account, error)
  • func (repo *AccountQueryRepo) ReadById(accountId valueObject.AccountId) (accountEntity entity.Account, err error)
  • func (repo *AccountQueryRepo) ReadByUsername(accountUsername valueObject.Username) (accountEntity entity.Account, err error)

Types

type AccountCmdRepo

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

func NewAccountCmdRepo

func NewAccountCmdRepo(
	persistentDbSvc *internalDbInfra.PersistentDatabaseService,
) *AccountCmdRepo

func (*AccountCmdRepo) Create

func (repo *AccountCmdRepo) Create(
	createDto dto.CreateAccount,
) (accountId valueObject.AccountId, err error)

func (*AccountCmdRepo) Delete

func (repo *AccountCmdRepo) Delete(accountId valueObject.AccountId) error

func (*AccountCmdRepo) UpdateApiKey

func (repo *AccountCmdRepo) UpdateApiKey(
	accountId valueObject.AccountId,
) (tokenValue valueObject.AccessTokenStr, err error)

func (*AccountCmdRepo) UpdatePassword

func (repo *AccountCmdRepo) UpdatePassword(
	accountId valueObject.AccountId, password valueObject.Password,
) error

type AccountQueryRepo

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

func NewAccountQueryRepo

func NewAccountQueryRepo(
	persistentDbSvc *internalDbInfra.PersistentDatabaseService,
) *AccountQueryRepo

func (*AccountQueryRepo) Read

func (repo *AccountQueryRepo) Read() ([]entity.Account, error)

func (*AccountQueryRepo) ReadById

func (repo *AccountQueryRepo) ReadById(
	accountId valueObject.AccountId,
) (accountEntity entity.Account, err error)

func (*AccountQueryRepo) ReadByUsername

func (repo *AccountQueryRepo) ReadByUsername(
	accountUsername valueObject.Username,
) (accountEntity entity.Account, err error)