com.mozilla.secops.httprequest.heuristics

Class PerEndpointErrorRateAnalysis

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,ArrayList<String>>>,org.apache.beam.sdk.values.PCollection<Alert>>

com.mozilla.secops.httprequest.heuristics.PerEndpointErrorRateAnalysis

All Implemented Interfaces:

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

public class PerEndpointErrorRateAnalysis
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,ArrayList<String>>>,org.apache.beam.sdk.values.PCollection<Alert>>
implements DocumentingTransform

Transform for detection of a single source generating errors at a given path pattern. The path is specified using a regex and an alert is generated if there are more than the threshold amount of requests matching the path with a status in the 400's.

Generates alerts where the request profile violates path thresholds specified in the perEndpointErrorRate pipeline option configuration.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PerEndpointErrorRateAnalysis.EndpointErrorInfo Internal class for configured endpoints in PEERA
static class	PerEndpointErrorRateAnalysis.EndpointErrorState Internal class to keep track of current state for a given endpoint rule for this key

Constructor Summary

Constructors

Constructor and Description
PerEndpointErrorRateAnalysis(HTTPRequestToggles toggles, Boolean enableIprepdDatastoreExemptions, String iprepdDatastoreExemptionsProject) Initializer for PerEndpointErrorRateAnalysis

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.values.PCollection<Alert>	expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<String,ArrayList<String>>> input)
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

PerEndpointErrorRateAnalysis

public PerEndpointErrorRateAnalysis(HTTPRequestToggles toggles,
                                    Boolean enableIprepdDatastoreExemptions,
                                    String iprepdDatastoreExemptionsProject)

Initializer for PerEndpointErrorRateAnalysis

Parameters:

toggles - HTTPRequestToggles

enableIprepdDatastoreExemptions - True to enable datastore exemptions

iprepdDatastoreExemptionsProject - Project to look for datastore entities in

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<org.apache.beam.sdk.values.KV<String,ArrayList<String>>> input)

Specified by:

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