ycsb

Documentation

Index

• type Database
  • func SetupDatabase(dbURL string) (Database, error)
• type YCSBCase
  • func NewYCSBCase(s *YCSBSuite, dbURL, workload string) *YCSBCase
  • func (c *YCSBCase) Name() string
  • func (c *YCSBCase) Run(*sql.DB) (*CaseResult, error)
• type YCSBConfig
• type YCSBSuite
  • func NewYCSBSuite(cfg *YCSBConfig) *YCSBSuite
  • func (s *YCSBSuite) Name() string
  • func (s *YCSBSuite) Run(cluster Cluster) ([]*CaseResult, error)

Types

type Database

type Database interface {
	Close() error
	ReadRow(id uint64) (bool, error)
	InsertRow(id uint64, fields []string) error
}

func SetupDatabase

func SetupDatabase(dbURL string) (Database, error)

type YCSBCase

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

func NewYCSBCase

func NewYCSBCase(s *YCSBSuite, dbURL, workload string) *YCSBCase

func (*YCSBCase) Name

func (c *YCSBCase) Name() string

func (*YCSBCase) Run

func (c *YCSBCase) Run(*sql.DB) (*CaseResult, error)

type YCSBConfig

type YCSBConfig struct {
	Databases  []string `toml:"databases"`
	Workloads  []string `toml:"workloads"`
	Duration   Duration `toml:"duration"`
	NumThreads int      `toml:"num_threads"`
}

type YCSBSuite

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

func NewYCSBSuite

func NewYCSBSuite(cfg *YCSBConfig) *YCSBSuite

func (*YCSBSuite) Name

func (s *YCSBSuite) Name() string

func (*YCSBSuite) Run

func (s *YCSBSuite) Run(cluster Cluster) ([]*CaseResult, error)