repository

Documentation

Index

• type AccountSqlRepo
  • func NewAccountSqlRepo(db *sql.DB) *AccountSqlRepo
  • func (r *AccountSqlRepo) FindByIbanAndOwner(ctx context.Context, t trace.Tracer, opts account.FindByIbanAndOwnerOpts) (*account.Account, error)
  • func (r *AccountSqlRepo) FindById(ctx context.Context, t trace.Tracer, opts account.FindByIdOpts) (*account.Account, error)
  • func (r *AccountSqlRepo) FindByUserIdAndId(ctx context.Context, t trace.Tracer, opts account.FindByUserIdAndIdOpts) (*account.Account, error)
  • func (r *AccountSqlRepo) GetTxnAdapter() txn.Adapter
  • func (r *AccountSqlRepo) ListByUserId(ctx context.Context, t trace.Tracer, opts account.ListByUserIdOpts) (*list.PagiResponse[*account.Account], error)
  • func (r *AccountSqlRepo) Lock()
  • func (r *AccountSqlRepo) Save(ctx context.Context, t trace.Tracer, opts account.SaveOpts) error
  • func (r *AccountSqlRepo) Unlock()
• type SessionRedisRepo
  • func NewSessionRedisRepo(db *redis.Client) *SessionRedisRepo
  • func (s *SessionRedisRepo) Destroy(ctx context.Context, t trace.Tracer, opts auth.SessionDestroyOpts) error
  • func (s *SessionRedisRepo) Find(ctx context.Context, t trace.Tracer, opts auth.SessionFindOpts) (*auth.Session, bool, error)
  • func (s *SessionRedisRepo) FindAllByUser(ctx context.Context, t trace.Tracer, opts auth.FindAllByUserOpts) ([]*auth.Session, error)
  • func (r *SessionRedisRepo) Lock()
  • func (s *SessionRedisRepo) Save(ctx context.Context, t trace.Tracer, opts auth.SessionSaveOpts) error
  • func (r *SessionRedisRepo) Unlock()
• type TransactionSqlRepo
  • func NewTransactionSqlRepo(db *sql.DB) *TransactionSqlRepo
  • func (r *TransactionSqlRepo) Filter(ctx context.Context, trc trace.Tracer, opts account.TransactionFilterOpts) (*list.PagiResponse[*account.Transaction], error)
  • func (r *TransactionSqlRepo) GetTxnAdapter() txn.Adapter
  • func (r *TransactionSqlRepo) Lock()
  • func (r *TransactionSqlRepo) Save(ctx context.Context, trc trace.Tracer, opts account.TransactionSaveOpts) error
  • func (r *TransactionSqlRepo) Unlock()
• type UserSqlRepo
  • func NewUserSqlRepo(db *sql.DB) *UserSqlRepo
  • func (r *UserSqlRepo) FindByEmail(ctx context.Context, trc trace.Tracer, opts user.FindByEmailOpts) (*user.User, error)
  • func (r *UserSqlRepo) FindById(ctx context.Context, trc trace.Tracer, opts user.FindByIdOpts) (*user.User, error)
  • func (r *UserSqlRepo) FindByToken(ctx context.Context, trc trace.Tracer, opts user.FindByTokenOpts) (*user.User, error)
  • func (r *UserSqlRepo) GetTxnAdapter() txn.Adapter
  • func (r *UserSqlRepo) IsExistsByEmail(ctx context.Context, trc trace.Tracer, opts user.IsExistsByEmailOpts) (bool, error)
  • func (r *UserSqlRepo) Lock()
  • func (r *UserSqlRepo) Save(ctx context.Context, trc trace.Tracer, opts user.SaveOpts) error
  • func (r *UserSqlRepo) Unlock()
• type VerifyRedisRepo
  • func NewVerifyRedisRepo(db *redis.Client) *VerifyRedisRepo
  • func (r *VerifyRedisRepo) Delete(ctx context.Context, trc trace.Tracer, opts auth.VerifyDeleteOpts) error
  • func (r *VerifyRedisRepo) Find(ctx context.Context, trc trace.Tracer, opts auth.VerifyFindOpts) (*auth.Verify, error)
  • func (r *VerifyRedisRepo) IsExists(ctx context.Context, trc trace.Tracer, opts auth.VerifyIsExistsOpts) (bool, error)
  • func (r *VerifyRedisRepo) Lock()
  • func (r *VerifyRedisRepo) Save(ctx context.Context, trc trace.Tracer, opts auth.VerifySaveOpts) error
  • func (r *VerifyRedisRepo) Unlock()

Types

type AccountSqlRepo

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

func NewAccountSqlRepo

func NewAccountSqlRepo(db *sql.DB) *AccountSqlRepo

func (*AccountSqlRepo) FindByIbanAndOwner

func (r *AccountSqlRepo) FindByIbanAndOwner(ctx context.Context, t trace.Tracer, opts account.FindByIbanAndOwnerOpts) (*account.Account, error)

func (*AccountSqlRepo) FindById

func (r *AccountSqlRepo) FindById(ctx context.Context, t trace.Tracer, opts account.FindByIdOpts) (*account.Account, error)

func (*AccountSqlRepo) FindByUserIdAndId

func (r *AccountSqlRepo) FindByUserIdAndId(ctx context.Context, t trace.Tracer, opts account.FindByUserIdAndIdOpts) (*account.Account, error)

func (*AccountSqlRepo) GetTxnAdapter

func (r *AccountSqlRepo) GetTxnAdapter() txn.Adapter

func (*AccountSqlRepo) ListByUserId

func (r *AccountSqlRepo) ListByUserId(ctx context.Context, t trace.Tracer, opts account.ListByUserIdOpts) (*list.PagiResponse[*account.Account], error)

func (*AccountSqlRepo) Lock

func (r *AccountSqlRepo) Lock()

func (*AccountSqlRepo) Save

func (r *AccountSqlRepo) Save(ctx context.Context, t trace.Tracer, opts account.SaveOpts) error

func (*AccountSqlRepo) Unlock

func (r *AccountSqlRepo) Unlock()

type SessionRedisRepo

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

func NewSessionRedisRepo

func NewSessionRedisRepo(db *redis.Client) *SessionRedisRepo

func (*SessionRedisRepo) Destroy

func (s *SessionRedisRepo) Destroy(ctx context.Context, t trace.Tracer, opts auth.SessionDestroyOpts) error

func (*SessionRedisRepo) Find

func (s *SessionRedisRepo) Find(ctx context.Context, t trace.Tracer, opts auth.SessionFindOpts) (*auth.Session, bool, error)

func (*SessionRedisRepo) FindAllByUser

func (s *SessionRedisRepo) FindAllByUser(ctx context.Context, t trace.Tracer, opts auth.FindAllByUserOpts) ([]*auth.Session, error)

func (*SessionRedisRepo) Lock

func (r *SessionRedisRepo) Lock()

func (*SessionRedisRepo) Save

func (s *SessionRedisRepo) Save(ctx context.Context, t trace.Tracer, opts auth.SessionSaveOpts) error

func (*SessionRedisRepo) Unlock

func (r *SessionRedisRepo) Unlock()

type TransactionSqlRepo

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

func NewTransactionSqlRepo

func NewTransactionSqlRepo(db *sql.DB) *TransactionSqlRepo

func (*TransactionSqlRepo) Filter

func (r *TransactionSqlRepo) Filter(ctx context.Context, trc trace.Tracer, opts account.TransactionFilterOpts) (*list.PagiResponse[*account.Transaction], error)

func (*TransactionSqlRepo) GetTxnAdapter

func (r *TransactionSqlRepo) GetTxnAdapter() txn.Adapter

func (*TransactionSqlRepo) Lock

func (r *TransactionSqlRepo) Lock()

func (*TransactionSqlRepo) Save

func (r *TransactionSqlRepo) Save(ctx context.Context, trc trace.Tracer, opts account.TransactionSaveOpts) error

func (*TransactionSqlRepo) Unlock

func (r *TransactionSqlRepo) Unlock()

type UserSqlRepo

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

func NewUserSqlRepo

func NewUserSqlRepo(db *sql.DB) *UserSqlRepo

func (*UserSqlRepo) FindByEmail

func (r *UserSqlRepo) FindByEmail(ctx context.Context, trc trace.Tracer, opts user.FindByEmailOpts) (*user.User, error)

func (*UserSqlRepo) FindById

func (r *UserSqlRepo) FindById(ctx context.Context, trc trace.Tracer, opts user.FindByIdOpts) (*user.User, error)

func (*UserSqlRepo) FindByToken

func (r *UserSqlRepo) FindByToken(ctx context.Context, trc trace.Tracer, opts user.FindByTokenOpts) (*user.User, error)

func (*UserSqlRepo) GetTxnAdapter

func (r *UserSqlRepo) GetTxnAdapter() txn.Adapter

func (*UserSqlRepo) IsExistsByEmail

func (r *UserSqlRepo) IsExistsByEmail(ctx context.Context, trc trace.Tracer, opts user.IsExistsByEmailOpts) (bool, error)

func (*UserSqlRepo) Lock

func (r *UserSqlRepo) Lock()

func (*UserSqlRepo) Save

func (r *UserSqlRepo) Save(ctx context.Context, trc trace.Tracer, opts user.SaveOpts) error

func (*UserSqlRepo) Unlock

func (r *UserSqlRepo) Unlock()

type VerifyRedisRepo

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

func NewVerifyRedisRepo

func NewVerifyRedisRepo(db *redis.Client) *VerifyRedisRepo

func (*VerifyRedisRepo) Delete

func (r *VerifyRedisRepo) Delete(ctx context.Context, trc trace.Tracer, opts auth.VerifyDeleteOpts) error

func (*VerifyRedisRepo) Find

func (r *VerifyRedisRepo) Find(ctx context.Context, trc trace.Tracer, opts auth.VerifyFindOpts) (*auth.Verify, error)

func (*VerifyRedisRepo) IsExists

func (r *VerifyRedisRepo) IsExists(ctx context.Context, trc trace.Tracer, opts auth.VerifyIsExistsOpts) (bool, error)

func (*VerifyRedisRepo) Lock

func (r *VerifyRedisRepo) Lock()

func (*VerifyRedisRepo) Save

func (r *VerifyRedisRepo) Save(ctx context.Context, trc trace.Tracer, opts auth.VerifySaveOpts) error

func (*VerifyRedisRepo) Unlock

func (r *VerifyRedisRepo) Unlock()