runner

type Factory interface {
	// MakeRunner creates a new Runner, representing a particular invoker session on a machine, and outputting to ldir.
	// It takes the plan p in case the factory is waiting to get machine configuration from it.
	MakeRunner(ldir string, p *plan.Plan, obs ...copier.Observer) (Runner, error)

	// Closer captures that Runner spawners can be closed once no more runners are needed.
	// For SSH runner spawners, this will close the SSH connection.
	io.Closer
}

type FromPlanFactory struct {
	// The global remoting config used for any remote connections initiated by this factory.
	Config *remote.Config
	// contains filtered or unexported fields
}

type InvocationGetter interface {
	// MachBin retrieves the default binary name for the node.
	MachBin() string
	// MachArgs computes the argument set for invoking the node binary.
	MachArgs(dir string) []string
}

type LocalFactory struct{}

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

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

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

type Runner interface {
	// Send performs any copying and transformation needed for p to run.
	// It returns a pointer to the plan to send to the machine node, which may or may not be p.
	Send(ctx context.Context, p *plan.Plan) (*plan.Plan, error)

	// Start starts the machine binary, returning a set of pipe readers and writers to use for communication with it.
	Start(ctx context.Context, qs quantity.MachNodeSet) (*remote.Pipeset, error)

	// Wait blocks waiting for the command to finish (or the context passed into Start to cancel).
	Wait() error

	// Recv merges the post-run plan runp into the original plan origp, copying back any files needed.
	// It returns a pointer to the final 'merged', which may or may not be origp and runp.
	// It may modify origp in place.
	Recv(ctx context.Context, origp, runp *plan.Plan) (*plan.Plan, error)
}