Versions in this module Expand all Collapse all v1 v1.0.1 Apr 3, 2023 Changes in this version type Measurer + GenerateExtendedOutputs func() v1.0.0 Oct 24, 2022 Changes in this version + func RegisterDBCreator(name string, creator DBCreator) + func RegisterWorkloadCreator(name string, creator WorkloadCreator) + type AnalyzeDB interface + Analyze func(ctx context.Context, table string) error + type BatchDB interface + BatchDelete func(ctx context.Context, table string, keys []string) error + BatchInsert func(ctx context.Context, table string, keys []string, values []map[string][]byte) error + BatchRead func(ctx context.Context, table string, keys []string, fields []string) ([]map[string][]byte, error) + BatchUpdate func(ctx context.Context, table string, keys []string, values []map[string][]byte) error + type DB interface + CleanupThread func(ctx context.Context) + Close func() error + Delete func(ctx context.Context, table string, key string) error + InitThread func(ctx context.Context, threadID int, threadCount int) context.Context + Insert func(ctx context.Context, table string, key string, values map[string][]byte) error + Read func(ctx context.Context, table string, key string, fields []string) (map[string][]byte, error) + Scan func(ctx context.Context, table string, startKey string, count int, fields []string) ([]map[string][]byte, error) + Update func(ctx context.Context, table string, key string, values map[string][]byte) error + type DBCreator interface + Create func(p *properties.Properties) (DB, error) + func GetDBCreator(name string) DBCreator + type Generator interface + Last func() int64 + Next func(r *rand.Rand) int64 + type Measurer interface + Measure func(op string, start time.Time, latency time.Duration) + Output func(w io.Writer) error + Summary func() + type Workload interface + CleanupThread func(ctx context.Context) + Close func() error + DoBatchInsert func(ctx context.Context, batchSize int, db DB) error + DoBatchTransaction func(ctx context.Context, batchSize int, db DB) error + DoInsert func(ctx context.Context, db DB) error + DoTransaction func(ctx context.Context, db DB) error + InitThread func(ctx context.Context, threadID int, threadCount int) context.Context + Load func(ctx context.Context, db DB, totalCount int64) error + type WorkloadCreator interface + Create func(p *properties.Properties) (Workload, error) + func GetWorkloadCreator(name string) WorkloadCreator v1.0.0-SNAPSHOT Oct 8, 2022
Go to main page