How to use the turbinia.jobs.manager.JobsManager.RegisterJob function in turbinia

To help you get started, we’ve selected a few turbinia examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

github google / turbinia / turbinia / jobs / grep.py View on Github external
NAME = 'GrepJob'

  def create_tasks(self, evidence):
    """Create task.

    Args:
      evidence: List of evidence objects to process

    Returns:
        A list of tasks to schedule.
    """
    tasks = [GrepTask() for _ in evidence]
    return tasks


manager.JobsManager.RegisterJob(GrepJob)
github google / turbinia / turbinia / jobs / psort.py View on Github external
NAME = 'PsortJob'

  def create_tasks(self, evidence):
    """Create task for Psort.

    Args:
      evidence: List of evidence objects to process

    Returns:
        A list of PsortTasks.
    """
    return [PsortTask() for _ in evidence]


manager.JobsManager.RegisterJob(PsortJob)
github google / turbinia / turbinia / jobs / worker_stat.py View on Github external
NAME = 'StatJob'

  def create_tasks(self, evidence):
    """Create task for Stat.

    Args:
      evidence: List of evidence objects to process

    Returns:
        A list of StatTasks.
    """
    return [StatTask() for _ in evidence]


manager.JobsManager.RegisterJob(StatJob)
github google / turbinia / turbinia / jobs / jenkins.py View on Github external
NAME = 'JenkinsAnalysisJob'

  def create_tasks(self, evidence):
    """Create task for Jenkins analysis job.

    Args:
      evidence: List of evidence objects to process

    Returns:
        A list of tasks to schedule.
    """
    tasks = [JenkinsAnalysisTask() for _ in evidence]
    return tasks


manager.JobsManager.RegisterJob(JenkinsAnalysisJob)
github google / turbinia / turbinia / jobs / hadoop.py View on Github external
NAME = 'HadoopAnalysisJob'

  def create_tasks(self, evidence):
    """Create task.

    Args:
      evidence: List of evidence objects to process

    Returns:
        A list of tasks to schedule.
    """
    tasks = [HadoopAnalysisTask() for _ in evidence]
    return tasks


manager.JobsManager.RegisterJob(HadoopAnalysisJob)
github google / turbinia / turbinia / jobs / plaso.py View on Github external
NAME = 'PlasoJob'

  def create_tasks(self, evidence):
    """Create task for Plaso.

    Args:
      evidence: List of evidence objects to process

    Returns:
        A list of PlasoTasks.
    """
    return [PlasoTask() for _ in evidence]


manager.JobsManager.RegisterJob(PlasoJob)
github google / turbinia / turbinia / jobs / strings.py View on Github external
def create_tasks(self, evidence):
    """Create task for Strings.

    Args:
      evidence: List of evidence objects to process

    Returns:
        A list of tasks to schedule.
    """
    # Generate tasks for both types of Strings jobs
    tasks = [StringsAsciiTask() for _ in evidence]
    tasks.extend([StringsUnicodeTask() for _ in evidence])
    return tasks


manager.JobsManager.RegisterJob(StringsJob)