Documentation ¶ Index ¶ type Client func (c *Client) Publish() func (c *Client) Subscribe() type Profiler func (p *Profiler) Add(d time.Duration) func (p *Profiler) Profile(f func()) func (p *Profiler) Start() func (p *Profiler) Stop() type Runner func (r *Runner) Run() Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Client ¶ type Client struct { sync.Mutex // contains filtered or unexported fields } func (*Client) Publish ¶ func (c *Client) Publish() func (*Client) Subscribe ¶ func (c *Client) Subscribe() type Profiler ¶ type Profiler struct { sync.Mutex // contains filtered or unexported fields } func (*Profiler) Add ¶ func (p *Profiler) Add(d time.Duration) func (*Profiler) Profile ¶ func (p *Profiler) Profile(f func()) func (*Profiler) Start ¶ func (p *Profiler) Start() func (*Profiler) Stop ¶ func (p *Profiler) Stop() type Runner ¶ type Runner struct { Url string NumClients int NumSubjects int NumMessages int ShutdownDuration time.Duration Rate int sync.WaitGroup // contains filtered or unexported fields } func (*Runner) Run ¶ func (r *Runner) Run() Source Files ¶ View all Source files client.go profiler.go runner.go Click to show internal directories. Click to hide internal directories.