Documentation
¶
Index ¶
- Variables
- type Executable
- type Executor
- func (perf *Executor) ChangeValues(items []*models.Entity)
- func (perf *Executor) Close()
- func (perf *Executor) Init()
- func (perf *Executor) PrepareData(count int) []*models.Entity
- func (perf *Executor) PrintTimes(functions []string)
- func (perf *Executor) PutAsync(items []*models.Entity)
- func (perf *Executor) PutBulk(items []*models.Entity)
- func (perf *Executor) Query100IdsBetween(min, max uint64)
- func (perf *Executor) QueryStringPrefix(prefix string, expectedCount int)
- func (perf *Executor) ReadAll(expectedCount int) []*models.Entity
- func (perf *Executor) RemoveAll()
- func (perf *Executor) RemoveBulk(items []*models.Entity)
- func (perf *Executor) Run(options Options)
- func (perf *Executor) UpdateBulk(items []*models.Entity)
- type Options
Constants ¶
This section is empty.
Variables ¶
View Source
var OptionsDefaults = Options{ "testdata", 10000, 10, false, false, }
Functions ¶
This section is empty.
Types ¶
type Executable ¶
type Executable interface {
Init() error
Close() error
Size() (uint64, error)
RemoveAll() error
RemoveBulk(items []*models.Entity) error
PutAsync(*models.Entity) error
AwaitAsyncCompletion() error
PutBulk(items []*models.Entity) error
ReadAll() ([]*models.Entity, error)
QueryIdBetween(min, max uint64) ([]*models.Entity, error)
QueryStringPrefix(prefix string) ([]*models.Entity, error)
}
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
func CreateExecutor ¶
func CreateExecutor(executable Executable) *Executor
func (*Executor) ChangeValues ¶
func (*Executor) PrintTimes ¶
func (*Executor) Query100IdsBetween ¶
func (*Executor) QueryStringPrefix ¶
func (*Executor) RemoveBulk ¶
func (*Executor) UpdateBulk ¶
Click to show internal directories.
Click to hide internal directories.