clients

package

v0.0.0-...-9575221 Latest Latest Go to latest Published: Jan 18, 2016 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Otter struct {
	Hostname string
	// contains filtered or unexported fields
}

func NewOtterClient(servers []string) (*Otter, error)

func (otter *Otter) CollectResults(results chan *state.ResultMap, count int) *state.ResultMap

Collect results from a channel and append them to a ResultMap when they are received

func (otter *Otter) ListHosts() ([]string, error)

List all registered remote hosts.

func (otter *Otter) RetrieveStateMap() (*state.StateMap, error)

func (otter *Otter) SaveResultMap(id string, resultMap *state.ResultMap) error

func (otter *Otter) SubmitCommand(host, command string, resultChan chan *state.ResultMap)

Run a command against remote hosts

func (otter *Otter) SubmitCommands(hostString, command string) (*state.ResultMap, error)

Submit a single command against all hosts who's name matches the given hostString.

func (otter *Otter) SubmitState(state string) error

func (otter *Otter) UpdateHost(hostname, previous string) (string, error)

Update the list of remote hosts with the specified hostname.

func (otter *Otter) WaitForChange(key string, recurse bool, timeout time.Duration) (string, string, error)

Wait for a key to be added or modified in etcd

func (otter *Otter) WaitForCommand(hostname string) (string, string, error)

Wait for a command and then return it.

func (otter *Otter) WaitForResults(id string) (*state.ResultMap, error)

Wait for a new ResultMap to be updated in the /result/<id> keyspace.