Documentation
¶
Index ¶
- Constants
- func InitSchema(ctx context.Context, db *sql.DB) error
- type Client
- func (h *Client) DoHongbaoTasks(ctx context.Context, db *sql.DB, hongbaoNum, sleep int) error
- func (h *Client) DoUsersTask(ctx context.Context, db *sql.DB, ...) error
- func (h *Client) DoValidate(ctx context.Context, db *sql.DB) error
- func (h *Client) Execute(ctx context.Context, db *sql.DB) error
- func (h *Client) Initialize(ctx context.Context, db *sql.DB) error
- func (h *Client) String() string
- type ClientConfig
- type Session
- func (s *Session) BeginTxn(ctx context.Context) error
- func (s *Session) CommitTxn(ctx context.Context) error
- func (s *Session) CreateFriends(ctx context.Context, userID int64, count int) error
- func (s *Session) CreateGroup(ctx context.Context, userID int64, members int) (groupID int64, err error)
- func (s *Session) CreateHongbao(ctx context.Context, userID int64, amount int64) error
- func (s *Session) CreateUser(ctx context.Context, balance int) (userID int64, err error)
- func (s *Session) CreateUsers(ctx context.Context, userNum, friendNum, groupNum, groupMemberNum, sleep int) error
- func (s *Session) DoHongbaoTask(ctx context.Context, wg *sync.WaitGroup)
- func (s *Session) RollbackTxn(ctx context.Context) error
- func (s *Session) UserAddBalance(ctx context.Context, userID int64, amount int64) error
- func (s *Session) UserBankAddBalance(ctx context.Context, txn *sql.Tx, userID int64, amount int64) error
Constants ¶
View Source
const CaseName = "HongBao"
CaseName ...
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is for hongbao transaction test
func (*Client) DoHongbaoTasks ¶
DoHongbaoTasks ...
func (*Client) DoUsersTask ¶
func (h *Client) DoUsersTask(ctx context.Context, db *sql.DB, userNum, friendNum, groupNum, groupMemberNum, sleep int) error
DoUsersTask ...
func (*Client) DoValidate ¶
DoValidate ...
func (*Client) Initialize ¶
Initialize ...
type ClientConfig ¶
type ClientConfig struct {
DBName string
Concurrency int
UserNum int
FriendNum int
GroupNum int
GroupMemberNum int
HongbaoNum int
IgnoreCodesO []int
IgnoreCodesP []int
TxnMode string
}
ClientConfig ...
type Session ¶
type Session struct {
// contains filtered or unexported fields
}
Session ...
func NewSession ¶
func NewSession( hongbaoClient *Client, conn *sql.Conn, beginUserID int64, endUserID int64, hongbaoNum, sleep int) (*Session, error)
NewSession ...
func (*Session) CreateFriends ¶
CreateFriends ...
func (*Session) CreateGroup ¶
func (s *Session) CreateGroup(ctx context.Context, userID int64, members int) (groupID int64, err error)
CreateGroup ...
func (*Session) CreateHongbao ¶
CreateHongbao ...
func (*Session) CreateUser ¶
CreateUser ...
func (*Session) CreateUsers ¶
func (s *Session) CreateUsers(ctx context.Context, userNum, friendNum, groupNum, groupMemberNum, sleep int) error
CreateUsers ...
func (*Session) DoHongbaoTask ¶
DoHongbaoTask ...
func (*Session) RollbackTxn ¶
RollbackTxn ...
func (*Session) UserAddBalance ¶
UserAddBalance ...
Source Files
Click to show internal directories.
Click to hide internal directories.