hammer

Documentation

Index

• Constants
• func ChangeRate(rps int)
• func Init(_num_of_workers int, _monitor_channel int64, _server string, _initdb bool, ...)
• func Pause()
• func Resume()
• func Start(rps int64)
• type MongoWorker
  • func (w *MongoWorker) GetMgoSession() *mgo.Session
  • func (w *MongoWorker) InitWorker(i int, _server string, _initdb bool, _profile string, _total int64, ...)
  • func (w *MongoWorker) Run(c <-chan int, t <-chan time.Time)

Constants

const MAXRPS = 0

const SizePerThread = 10000000

to reduce size of thread, speed up

Functions

func ChangeRate

func ChangeRate(rps int)

adjust speed of sending

func Init

func Init(
	_num_of_workers int,
	_monitor_channel int64,
	_server string,
	_initdb bool,
	_profile string,
	_total int64,
	_warmup int64,
	_total_time int64,
	_quiet bool,
	_run_id string,
	_ssl bool,
	_ssl_ca string,
	_ssl_key string)

init

func Pause

func Pause()

pause

func Resume

func Resume()

resume

func Start

func Start(rps int64)

to start traffic

Types

type MongoWorker

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

func (*MongoWorker) GetMgoSession

func (w *MongoWorker) GetMgoSession() *mgo.Session

func (*MongoWorker) InitWorker

func (w *MongoWorker) InitWorker(
	i int,
	_server string,
	_initdb bool,
	_profile string,
	_total int64,
	_dial_info mgo.DialInfo,
	masterMgoSession *mgo.Session)

func (*MongoWorker) Run

func (w *MongoWorker) Run(c <-chan int, t <-chan time.Time)