com.mozilla.secops.amo

Class FxaAccountAbuseNewVersion

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Event>,org.apache.beam.sdk.values.PCollection<Alert>>

com.mozilla.secops.amo.FxaAccountAbuseNewVersion

All Implemented Interfaces:

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

public class FxaAccountAbuseNewVersion
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Event>,org.apache.beam.sdk.values.PCollection<Alert>>
implements DocumentingTransform

Correlation of AMO addon submission with abusive FxA account creation alerts

This transform also applies login ban patterns.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FxaAccountAbuseNewVersion(String monitoredResource, String[] banAccounts, Integer banAccountsSuppress, String iprepdSpec, String project) Create new FxaAccountAbuseNewVersion

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.values.PCollection<Alert>	expand(org.apache.beam.sdk.values.PCollection<Event> col)
String	getTransformDoc() Get documentation string from transform based on it's current configuration

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

FxaAccountAbuseNewVersion

public FxaAccountAbuseNewVersion(String monitoredResource,
                                 String[] banAccounts,
                                 Integer banAccountsSuppress,
                                 String iprepdSpec,
                                 String project)

Create new FxaAccountAbuseNewVersion

Parameters:

monitoredResource - Monitored resource indicator

banAccounts - Blocked accounts regex

banAccountsSuppress - Optional recovery suppression for ban pattern alerts

iprepdSpec - iprepd spec for reputation lookups

project - Project for KMS secrets decryption of API key if required

Method Detail

getTransformDoc

public String getTransformDoc()

Get documentation string from transform based on it's current configuration

Specified by:

getTransformDoc in interface DocumentingTransform

Returns:

String

expand

public org.apache.beam.sdk.values.PCollection<Alert> expand(org.apache.beam.sdk.values.PCollection<Event> col)

Specified by:

expand in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<Event>,org.apache.beam.sdk.values.PCollection<Alert>>