sqlstore

Documentation

Index

• Constants
• type AccountStore
  • func (r *AccountStore) Create(u *model.Account) error
  • func (r *AccountStore) Delete(id string) error
  • func (r *AccountStore) Find(id string) (*model.Account, error)
  • func (r *AccountStore) GetBalance(id string) (float64, error)
  • func (r *AccountStore) SetBalance(id string, balance float64) error
  • func (r *AccountStore) UpdateBalance(id string, balance float64) error
• type JobStore
  • func (j *JobStore) CancelTransactionAndCorrectBalance(jobRunInterval time.Duration, accountId int) (err error)
• type Store
  • func CreateNewAndConnect(cfg config.Config) *Store
  • func (s *Store) Account() store.AccountStore
  • func (s *Store) Close()
  • func (s *Store) Job() store.JobStore
  • func (s *Store) Transaction() store.TransactionStore
• type TransactionStore
  • func (t *TransactionStore) Fetch(count int) ([]model.Transaction, error)
  • func (t *TransactionStore) Save(request *model.IncomingRequest, status string) error
  • func (t *TransactionStore) Update(id int) error

Constants

const (
	DBPingAttempts    = 18
	DBPingTimeoutSecs = 10
	ExitDBOpen        = 101
	ExitPing          = 102
)

Types

type AccountStore

type AccountStore struct {
	Store *Store
}

AccountStore ...

func (*AccountStore) Create

func (r *AccountStore) Create(u *model.Account) error

Create Account with balance = 0

func (*AccountStore) Delete

func (r *AccountStore) Delete(id string) error

Delete account by id

func (*AccountStore) Find

func (r *AccountStore) Find(id string) (*model.Account, error)

Find Return account by id

func (*AccountStore) GetBalance

func (r *AccountStore) GetBalance(id string) (float64, error)

GetBalance Get the account balance

func (*AccountStore) SetBalance

func (r *AccountStore) SetBalance(id string, balance float64) error

SetBalance account balance by id

func (*AccountStore) UpdateBalance

func (r *AccountStore) UpdateBalance(id string, balance float64) error

UpdateBalance Increase the account balance

type JobStore

type JobStore struct {
	Store *Store
}

func (*JobStore) CancelTransactionAndCorrectBalance

func (j *JobStore) CancelTransactionAndCorrectBalance(jobRunInterval time.Duration, accountId int) (err error)

type Store

type Store struct {
	Db *sql.DB
	// contains filtered or unexported fields
}

Store ...

func CreateNewAndConnect

func CreateNewAndConnect(cfg config.Config) *Store

CreateNewAndConnect ...

func (*Store) Account

func (s *Store) Account() store.AccountStore

Account sql store

func (*Store) Close

func (s *Store) Close()

Close db connection

func (*Store) Job

func (s *Store) Job() store.JobStore

Job sql store

func (*Store) Transaction

func (s *Store) Transaction() store.TransactionStore

Transaction sql store

type TransactionStore

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

func (*TransactionStore) Fetch

func (t *TransactionStore) Fetch(count int) ([]model.Transaction, error)

Fetch list of transaction

func (*TransactionStore) Save

func (t *TransactionStore) Save(request *model.IncomingRequest, status string) error

Save the transaction

func (*TransactionStore) Update

func (t *TransactionStore) Update(id int) error

Update the transaction record to CANCELLED