com.mozilla.secops

Class IprepdIO.Write

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<String>,org.apache.beam.sdk.values.PDone>

com.mozilla.secops.IprepdIO.Write

All Implemented Interfaces:

Serializable, org.apache.beam.sdk.transforms.display.HasDisplayData

Enclosing class:

IprepdIO

public static class IprepdIO.Write
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<String>,org.apache.beam.sdk.values.PDone>

Write violation messages to iprepd based on submitted Alert JSON strings

For each JSON string processed, an attempt will be made to convert the Alert into a Violation, for any successful conversion the resulting violation will be submitted to iprepd as a violation message for the source address. Any input data that is not an Alert that can be converted into a violation will be ignored.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Write(String[] iprepdSpecs, String project) Create new iprepd write transform

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.values.PDone	expand(org.apache.beam.sdk.values.PCollection<String> input)
String[]	getIprepdSpecs() Get iprepd specs
String	getProject() Get project

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

compose, compose, getAdditionalInputs, getDefaultOutputCoder, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate

Methods inherited from class java.lang.Object

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

Constructor Detail

Write

public Write(String[] iprepdSpecs,
             String project)

Create new iprepd write transform

Parameters:

iprepdSpecs - String[] of iprepd input specifications

project - GCP project name, can be null if no cloudkms is required for secrets

Method Detail

getIprepdSpecs

public String[] getIprepdSpecs()

Get iprepd specs

Returns:

iprepd specs

getProject

public String getProject()

Get project

Returns:

Project string

expand

public org.apache.beam.sdk.values.PDone expand(org.apache.beam.sdk.values.PCollection<String> input)

Specified by:

expand in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<String>,org.apache.beam.sdk.values.PDone>