org.gcube.dataanalysis.dataminer.poolmanager.ansible

Class AnsibleWorker

java.lang.Object

org.gcube.dataanalysis.dataminer.poolmanager.ansible.AnsibleWorker

public class AnsibleWorker
extends Object

This class is responsible for the interface with ansible, retrieving log, etc. etc. It's not supposed to access templates and static stuff files. It does not know the service datamodel.

Author:

paolo

Constructor Summary

Constructors

Constructor and Description
AnsibleWorker(File root)

Method Summary

Modifier and Type	Method and Description
void	addRole(Role r)
void	apply(AlgorithmSet as, PrintStream ps, boolean updateSVN)
List<String>	checkMatch(String[] lines, List<String> ls)
void	destroy() Destroy the worker: - remove the working dir
void	ensureWorkStructure()
File	getInventoryFile()
File	getPlaybookFile()
File	getRolesDir()
File	getWorkdir()
String	getWorkerId()
static String	md5(byte[] contents)
void	removeWorkStructure()
void	setInventory(Inventory inventory)
void	setPlaybook(Playbook playbook)
List<String>	updateSVN(String file, List<String> ldep)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AnsibleWorker

public AnsibleWorker(File root)

Method Detail

getWorkdir

public File getWorkdir()

getRolesDir

public File getRolesDir()

getWorkerId

public String getWorkerId()

ensureWorkStructure

public void ensureWorkStructure()

removeWorkStructure

public void removeWorkStructure()

getPlaybookFile

public File getPlaybookFile()

getInventoryFile

public File getInventoryFile()

setInventory

public void setInventory(Inventory inventory)
                  throws IOException

Throws:

IOException

setPlaybook

public void setPlaybook(Playbook playbook)
                 throws IOException

Throws:

IOException

addRole

public void addRole(Role r)
             throws IOException

Throws:

IOException

apply

public void apply(AlgorithmSet as,
                  PrintStream ps,
                  boolean updateSVN)
           throws IOException,
                  InterruptedException,
                  org.tmatesoft.svn.core.SVNException

Throws:

IOException

InterruptedException

org.tmatesoft.svn.core.SVNException

updateSVN

public List<String> updateSVN(String file,
                              List<String> ldep)
                       throws org.tmatesoft.svn.core.SVNException,
                              IOException

Throws:

org.tmatesoft.svn.core.SVNException

IOException

md5

public static String md5(byte[] contents)

checkMatch

public List<String> checkMatch(String[] lines,
                               List<String> ls)

destroy

public void destroy()

Destroy the worker: - remove the working dir