Versions in this module Expand all Collapse all v1 v1.0.2 Jun 30, 2023 v1.0.1 Jun 30, 2023 Changes in this version + type Broker struct + func Mk_broker(user string, keys []string) (broker *Broker) + func (b *Broker) Add_rsync(src *string, dest_dir *string) + func (b *Broker) Close() + func (b *Broker) Close_session(name *string) (err error) + func (b *Broker) NBRun_cmd(host string, cmd string, uid int, uch chan *Broker_msg) (err error) + func (b *Broker) NBRun_on_host(host string, script string, parms string, uid int, uch chan *Broker_msg) (err error) + func (b *Broker) Reset() + func (b *Broker) Rm_rsync() + func (b *Broker) Run_cmd(host string, cmd string) (stdout *bytes.Buffer, stderr *bytes.Buffer, err error) + func (b *Broker) Run_on_host(host string, script string, parms string, env_file string) (stdout *bytes.Buffer, stderr *bytes.Buffer, err error) + func (b *Broker) Set_verbose(value bool) + func (b *Broker) Start_initiators(n int) + type Broker_msg struct + func (m *Broker_msg) Get_info() (host string, sname string, id int) + func (m *Broker_msg) Get_results() (stdout bytes.Buffer, stderr bytes.Buffer, elapsed int64, err error)