com.mozilla.secops.pioneer

Class Pioneer

java.lang.Object

com.mozilla.secops.pioneer.Pioneer

All Implemented Interfaces:

Serializable

public class Pioneer
extends Object
implements Serializable

Pioneer analysis pipeline

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Pioneer.PioneerExfiltration Generate alerts if flow logs indicate a certain volume of data has been transferred within a specified period of time.
static interface	Pioneer.PioneerOptions Runtime options for Pioneer pipeline.

Constructor Summary

Constructors

Constructor and Description
Pioneer()

Method Summary

Modifier and Type	Method and Description
static String	buildConfigurationTick(Pioneer.PioneerOptions options) Build a configuration tick for Pioneer given pipeline options
static org.apache.beam.sdk.values.PCollection<Alert>	executePipeline(org.apache.beam.sdk.Pipeline p, org.apache.beam.sdk.values.PCollection<String> input, Pioneer.PioneerOptions options) Execute Pioneer pipeline
static void	main(String[] args) Entry point for Beam pipeline.

Methods inherited from class java.lang.Object

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

Constructor Detail

Pioneer

public Pioneer()

Method Detail

executePipeline

public static org.apache.beam.sdk.values.PCollection<Alert> executePipeline(org.apache.beam.sdk.Pipeline p,
                                                                            org.apache.beam.sdk.values.PCollection<String> input,
                                                                            Pioneer.PioneerOptions options)
                                                                     throws IOException

Execute Pioneer pipeline

Parameters:

p - Pipeline

input - Input collection

options - PioneerOptions

Returns:

Collection of Alert objects

Throws:

IOException - IOException

buildConfigurationTick

public static String buildConfigurationTick(Pioneer.PioneerOptions options)
                                     throws IOException

Build a configuration tick for Pioneer given pipeline options

Parameters:

options - Pipeline options

Returns:

String

Throws:

IOException - IOException

main

public static void main(String[] args)
                 throws IOException

Entry point for Beam pipeline.

Parameters:

args - Runtime arguments.

Throws:

IOException - IOException