Documentation
¶
Index ¶
- func NewBenchCmd(f cmdutil.Factory, streams genericiooptions.IOStreams) *cobra.Command
- func NewPgBenchCmd(f cmdutil.Factory, streams genericiooptions.IOStreams) *cobra.Command
- func NewSysBenchCmd(f cmdutil.Factory, streams genericiooptions.IOStreams) *cobra.Command
- func NewTpccCmd(f cmdutil.Factory, streams genericiooptions.IOStreams) *cobra.Command
- func NewTpchCmd(f cmdutil.Factory, streams genericiooptions.IOStreams) *cobra.Command
- func NewYcsbCmd(f cmdutil.Factory, streams genericiooptions.IOStreams) *cobra.Command
- type BenchBaseOptions
- type PgBenchOptions
- type SysBenchOptions
- type TpccOptions
- type TpchOptions
- type YcsbOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBenchCmd ¶
NewBenchCmd creates the bench command
func NewPgBenchCmd ¶
func NewSysBenchCmd ¶
func NewTpccCmd ¶
func NewTpchCmd ¶
func NewYcsbCmd ¶
Types ¶
type BenchBaseOptions ¶
type BenchBaseOptions struct {
// define the target database
Driver string
Database string
Host string
Port int
User string
Password string
ClusterName string
Step string // specify the benchmark step, exec all, cleanup, prepare or run
TolerationsRaw []string
Tolerations []corev1.Toleration
ExtraArgs []string // extra arguments for benchmark
*cluster.ClusterObjects
genericiooptions.IOStreams
// contains filtered or unexported fields
}
func (*BenchBaseOptions) AddFlags ¶
func (o *BenchBaseOptions) AddFlags(cmd *cobra.Command)
func (*BenchBaseOptions) BaseComplete ¶
func (o *BenchBaseOptions) BaseComplete() error
func (*BenchBaseOptions) BaseValidate ¶
func (o *BenchBaseOptions) BaseValidate() error
BaseValidate validates the base options In some cases, for example, in redis, the database is not required, the username is not required and password can be empty for many databases, so we don't validate them here
type PgBenchOptions ¶
type PgBenchOptions struct {
Scale int // specify the scale factor for the benchmark test
Clients []int // specify the number of clients to run
Threads int // specify the number of threads per client
Transactions int // specify the number of transactions per client
Duration int // specify the duration of benchmark test in seconds
Select bool // specify to run SELECT-only transactions
BenchBaseOptions
}
func (*PgBenchOptions) Complete ¶
func (o *PgBenchOptions) Complete(args []string) error
func (*PgBenchOptions) Run ¶
func (o *PgBenchOptions) Run() error
func (*PgBenchOptions) Validate ¶
func (o *PgBenchOptions) Validate() error
type SysBenchOptions ¶
type SysBenchOptions struct {
Threads []int // the number of threads
Tables int // the number of tables
Size int // the data size of per table
Duration int
Type []string
ReadPercent int
WritePercent int
BenchBaseOptions
}
func (*SysBenchOptions) Complete ¶
func (o *SysBenchOptions) Complete(args []string) error
func (*SysBenchOptions) Run ¶
func (o *SysBenchOptions) Run() error
func (*SysBenchOptions) Validate ¶
func (o *SysBenchOptions) Validate() error
type TpccOptions ¶
type TpccOptions struct {
WareHouses int // specify the overall database size scaling parameter
Threads []int // specify the number of threads to use
Transactions int // specify the number of transactions that each thread should run
Duration int // specify the number of minutes to run
LimitTxPerMin int // limit the number of transactions to run per minute, 0 means no limit
NewOrder int // specify the percentage of transactions that should be new orders
Payment int // specify the percentage of transactions that should be payments
OrderStatus int // specify the percentage of transactions that should be order status
Delivery int // specify the percentage of transactions that should be delivery
StockLevel int // specify the percentage of transactions that should be stock level
BenchBaseOptions
}
func (*TpccOptions) Complete ¶
func (o *TpccOptions) Complete(args []string) error
func (*TpccOptions) Run ¶
func (o *TpccOptions) Run() error
func (*TpccOptions) Validate ¶
func (o *TpccOptions) Validate() error
type TpchOptions ¶
type TpchOptions struct {
BenchBaseOptions
}
func (*TpchOptions) Complete ¶
func (o *TpchOptions) Complete(args []string) error
func (*TpchOptions) Run ¶
func (o *TpchOptions) Run() error
func (*TpchOptions) Validate ¶
func (o *TpchOptions) Validate() error
type YcsbOptions ¶
type YcsbOptions struct {
Threads []int // the number of threads to use
RecordCount int // the number of records to use
OperationCount int // the number of operations to use during the run phase
ReadProportion int // the proportion of operations that are reads
UpdateProportion int // the proportion of operations that are updates
InsertProportion int // the proportion of operations that are inserts
ScanProportion int // the proportion of operations that are scans
ReadModifyWriteProportion int // the proportion of operations that are read then modify a record
BenchBaseOptions
}
func (*YcsbOptions) Complete ¶
func (o *YcsbOptions) Complete(args []string) error
func (*YcsbOptions) Run ¶
func (o *YcsbOptions) Run() error
func (*YcsbOptions) Validate ¶
func (o *YcsbOptions) Validate() error
Click to show internal directories.
Click to hide internal directories.