com.mozilla.secops.gatekeeper

Class GatekeeperPipeline

java.lang.Object

com.mozilla.secops.gatekeeper.GatekeeperPipeline

All Implemented Interfaces:

Serializable

public class GatekeeperPipeline
extends Object
implements Serializable

GatekeeperPipeline describes and implements a Beam pipeline for analysis of AWS GuardDuty and GCP Event Threat Detection Findings

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	GatekeeperPipeline.GatekeeperOptions Runtime options for GatekeeperPipeline .

Constructor Summary

Constructors

Constructor and Description
GatekeeperPipeline()

Method Summary

Modifier and Type	Method and Description
static String	buildConfigurationTick(GatekeeperPipeline.GatekeeperOptions options) Build a configuration tick for Gatekeeper 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, GatekeeperPipeline.GatekeeperOptions options) Execute Gatekeeper 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

GatekeeperPipeline

public GatekeeperPipeline()

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,
                                                                            GatekeeperPipeline.GatekeeperOptions options)

Execute Gatekeeper pipeline

Parameters:

p - Pipeline

input - Input collection

options - GatekeeperOptions

Returns:

Collection of Alert objects

buildConfigurationTick

public static String buildConfigurationTick(GatekeeperPipeline.GatekeeperOptions options)
                                     throws IOException

Build a configuration tick for Gatekeeper given pipeline options

Parameters:

options - Pipeline options

Returns:

String

Throws:

IOException - IOException

main

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

Entry point for Beam pipeline.

Parameters:

args - Runtime arguments.

Throws:

Exception - Exception