Documentation
¶
Index ¶
- func NewBenchCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command
- func NewPgBenchCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command
- func NewSysBenchCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command
- func NewTpccCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command
- func NewTpchCmd(f cmdutil.Factory, streams genericclioptions.IOStreams) *cobra.Command
- func NewYcsbCmd(f cmdutil.Factory, streams genericclioptions.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 ¶ added in v0.6.0
func NewSysBenchCmd ¶ added in v0.6.0
func NewTpccCmd ¶
func NewTpchCmd ¶
func NewYcsbCmd ¶
Types ¶
type BenchBaseOptions ¶ added in v0.6.0
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
genericclioptions.IOStreams
// contains filtered or unexported fields
}
func (*BenchBaseOptions) AddFlags ¶ added in v0.6.0
func (o *BenchBaseOptions) AddFlags(cmd *cobra.Command)
func (*BenchBaseOptions) BaseComplete ¶
func (o *BenchBaseOptions) BaseComplete() error
func (*BenchBaseOptions) BaseValidate ¶ added in v0.6.0
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 ¶ added in v0.6.0
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 ¶ added in v0.6.0
func (o *PgBenchOptions) Complete(args []string) error
func (*PgBenchOptions) Run ¶ added in v0.6.0
func (o *PgBenchOptions) Run() error
func (*PgBenchOptions) Validate ¶ added in v0.6.0
func (o *PgBenchOptions) Validate() error
type SysBenchOptions ¶ added in v0.6.0
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 ¶ added in v0.6.0
func (o *SysBenchOptions) Complete(args []string) error
func (*SysBenchOptions) Run ¶ added in v0.6.0
func (o *SysBenchOptions) Run() error
func (*SysBenchOptions) Validate ¶ added in v0.6.0
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.