com.mozilla.secops.httprequest

Interface HTTPRequest.HTTPRequestOptions

All Superinterfaces:

org.apache.beam.sdk.options.ApplicationNameOptions, org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions, org.apache.beam.sdk.transforms.display.HasDisplayData, InputOptions, IOOptions, OutputOptions, org.apache.beam.sdk.options.PipelineOptions, org.apache.beam.sdk.io.gcp.pubsub.PubsubOptions, org.apache.beam.sdk.options.StreamingOptions

Enclosing class:

HTTPRequest

public static interface HTTPRequest.HTTPRequestOptions
extends org.apache.beam.sdk.options.PipelineOptions, IOOptions

Runtime options for HTTPRequest pipeline.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

org.apache.beam.sdk.extensions.gcp.options.GcpOptions.DefaultProjectFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.EnableStreamingEngineFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpTempLocationFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpUserCredentialsFactory

Nested classes/interfaces inherited from interface org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions

org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions.GoogleApiTracer

Field Summary

Fields inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

STREAMING_ENGINE_EXPERIMENT, WINDMILL_SERVICE_EXPERIMENT

Method Summary

Modifier and Type	Method and Description
Long	getAlertSuppressionDurationSeconds()
Double	getAnalysisThresholdModifier()
String	getCidrExclusionList()
Double	getClampThresholdMaximum()
Boolean	getEnableEndpointAbuseAnalysis()
Boolean	getEnableEndpointSequenceAbuseAnalysis()
Boolean	getEnableErrorRateAnalysis()
Boolean	getEnableHardLimitAnalysis()
Boolean	getEnablePerEndpointErrorRateAnalysis()
Boolean	getEnableSessionLimitAnalysis()
Boolean	getEnableSourceCorrelator()
Boolean	getEnableStatusCodeRateAnalysis()
Boolean	getEnableThresholdAnalysis()
Boolean	getEnableUserAgentBlocklistAnalysis()
String[]	getEndpointAbuseCustomVarianceSubstrings()
Boolean	getEndpointAbuseExtendedVariance()
String[]	getEndpointAbusePath()
Integer	getEndpointAbuseSuppressRecovery()
String[]	getEndpointSequenceAbusePatterns()
Integer	getEndpointSequenceAbuseSuppressRecovery()
Long	getErrorSessionGapDurationMinutes()
String[]	getFilterRequestPath()
Long	getHardLimitRequestCount()
Boolean	getIgnoreCloudProviderRequests()
Boolean	getIgnoreInternalRequests()
String[]	getIncludeUrlHostRegex()
String	getKnownGatewaysPath()
Long	getMaxClientErrorRate()
Long	getMaxClientStatusCodeRate()
Boolean	getNatDetection()
Long	getPerEndpointErrorRateAlertSuppressionDurationSeconds()
Integer	getPerEndpointErrorRateAnalysisSuppressRecovery()
String[]	getPerEndpointErrorRatePaths()
String	getPipelineMultimodeConfiguration()
Double	getRequiredMinimumAverage()
Long	getRequiredMinimumClients()
Long	getRequiredMinimumRequestsPerClient()
Long	getSessionGapDurationMinutes()
String[]	getSessionLimitAnalysisPaths()
Integer	getSessionLimitAnalysisSuppressRecovery()
Double	getSourceCorrelatorAlertPercentage()
Integer	getSourceCorrelatorMinimumAddresses()
Integer	getStatusCodeRateAnalysisCode()
String	getUserAgentBlocklistPath()
void	setAlertSuppressionDurationSeconds(Long value)
void	setAnalysisThresholdModifier(Double value)
void	setCidrExclusionList(String value)
void	setClampThresholdMaximum(Double value)
void	setEnableEndpointAbuseAnalysis(Boolean value)
void	setEnableEndpointSequenceAbuseAnalysis(Boolean value)
void	setEnableErrorRateAnalysis(Boolean value)
void	setEnableHardLimitAnalysis(Boolean value)
void	setEnablePerEndpointErrorRateAnalysis(Boolean value)
void	setEnableSessionLimitAnalysis(Boolean value)
void	setEnableSourceCorrelator(Boolean value)
void	setEnableStatusCodeRateAnalysis(Boolean value)
void	setEnableThresholdAnalysis(Boolean value)
void	setEnableUserAgentBlocklistAnalysis(Boolean value)
void	setEndpointAbuseCustomVarianceSubstrings(String[] value)
void	setEndpointAbuseExtendedVariance(Boolean value)
void	setEndpointAbusePath(String[] value)
void	setEndpointAbuseSuppressRecovery(Integer value)
void	setEndpointSequenceAbusePatterns(String[] value)
void	setEndpointSequenceAbuseSuppressRecovery(Integer value)
void	setErrorSessionGapDurationMinutes(Long value)
void	setFilterRequestPath(String[] value)
void	setHardLimitRequestCount(Long value)
void	setIgnoreCloudProviderRequests(Boolean value)
void	setIgnoreInternalRequests(Boolean value)
void	setIncludeUrlHostRegex(String[] value)
void	setKnownGatewaysPath(String value)
void	setMaxClientErrorRate(Long value)
void	setMaxClientStatusCodeRate(Long value)
void	setNatDetection(Boolean value)
void	setPerEndpointErrorRateAlertSuppressionDurationSeconds(Long value)
void	setPerEndpointErrorRateAnalysisSuppressRecovery(Integer value)
void	setPerEndpointErrorRatePaths(String[] value)
void	setPipelineMultimodeConfiguration(String value)
void	setRequiredMinimumAverage(Double value)
void	setRequiredMinimumClients(Long value)
void	setRequiredMinimumRequestsPerClient(Long value)
void	setSessionGapDurationMinutes(Long value)
void	setSessionLimitAnalysisPaths(String[] value)
void	setSessionLimitAnalysisSuppressRecovery(Integer value)
void	setSourceCorrelatorAlertPercentage(Double value)
void	setSourceCorrelatorMinimumAddresses(Integer value)
void	setStatusCodeRateAnalysisCode(Integer value)
void	setUserAgentBlocklistPath(String value)

Methods inherited from interface com.mozilla.secops.OutputOptions

compositeOutput, getAlertStateDatastoreKind, getAlertStateDatastoreNamespace, getAlertStateMemcachedHost, getAlertStateMemcachedPort, getCriticalNotificationEmail, getMonitoredResourceIndicator, getOutputAlertEmailCatchall, getOutputAlertEmailFrom, getOutputAlertGcsTemplateBasePath, getOutputAlertSlackCatchall, getOutputAlertSlackToken, getOutputAlertSmtpCredentials, getOutputAlertSmtpRelay, getOutputAlertTemplates, getOutputBigQuery, getOutputFile, getOutputIprepd, getOutputIprepdDatastoreExemptionsProject, getOutputIprepdEnableDatastoreExemptions, getOutputPubsub, getOutputSqs, setAlertStateDatastoreKind, setAlertStateDatastoreNamespace, setAlertStateMemcachedHost, setAlertStateMemcachedPort, setCriticalNotificationEmail, setMonitoredResourceIndicator, setOutputAlertEmailCatchall, setOutputAlertEmailFrom, setOutputAlertGcsTemplateBasePath, setOutputAlertSlackCatchall, setOutputAlertSlackToken, setOutputAlertSmtpCredentials, setOutputAlertSmtpRelay, setOutputAlertTemplates, setOutputBigQuery, setOutputFile, setOutputIprepd, setOutputIprepdDatastoreExemptionsProject, setOutputIprepdEnableDatastoreExemptions, setOutputPubsub, setOutputSqs

Methods inherited from interface com.mozilla.secops.InputOptions

getDeferGeoIpResolution, getDisableCloudwatchStrip, getDisableMozlogStrip, getGenerateConfigurationTicksInterval, getGenerateConfigurationTicksMaximum, getIdentityManagerPath, getInputFile, getInputIprepd, getInputKinesis, getInputPubsub, getMaxAllowableTimestampDifference, getMaxmindAccountId, getMaxmindCityDbPath, getMaxmindIspDbPath, getMaxmindLicenseKey, getParserFastMatcher, getPipelineVersion, getStackdriverLabelFilters, getStackdriverProjectFilter, getUseEventTimestamp, getUseProxyXff, getUseXffAsRemote, getXffAddressSelector, setDeferGeoIpResolution, setDisableCloudwatchStrip, setDisableMozlogStrip, setGenerateConfigurationTicksInterval, setGenerateConfigurationTicksMaximum, setIdentityManagerPath, setInputFile, setInputIprepd, setInputKinesis, setInputPubsub, setMaxAllowableTimestampDifference, setMaxmindAccountId, setMaxmindCityDbPath, setMaxmindIspDbPath, setMaxmindLicenseKey, setParserFastMatcher, setPipelineVersion, setStackdriverLabelFilters, setStackdriverProjectFilter, setUseEventTimestamp, setUseProxyXff, setUseXffAsRemote, setXffAddressSelector

Methods inherited from interface org.apache.beam.sdk.io.gcp.pubsub.PubsubOptions

getPubsubRootUrl, setPubsubRootUrl, targetForRootUrl

Methods inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

getCredentialFactoryClass, getDataflowKmsKey, getGcpCredential, getGcpTempLocation, getProject, getWorkerRegion, getWorkerZone, getZone, isEnableStreamingEngine, setCredentialFactoryClass, setDataflowKmsKey, setEnableStreamingEngine, setGcpCredential, setGcpTempLocation, setProject, setWorkerRegion, setWorkerZone, setZone

Methods inherited from interface org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions

getGoogleApiTrace, setGoogleApiTrace

Methods inherited from interface org.apache.beam.sdk.options.StreamingOptions

isStreaming, setStreaming

Methods inherited from interface org.apache.beam.sdk.options.ApplicationNameOptions

getAppName, setAppName

Method Detail

getEnableThresholdAnalysis

@Default.Boolean(value=false)
Boolean getEnableThresholdAnalysis()

setEnableThresholdAnalysis

void setEnableThresholdAnalysis(Boolean value)

getEnableErrorRateAnalysis

@Default.Boolean(value=false)
Boolean getEnableErrorRateAnalysis()

setEnableErrorRateAnalysis

void setEnableErrorRateAnalysis(Boolean value)

getEnableEndpointAbuseAnalysis

@Default.Boolean(value=false)
Boolean getEnableEndpointAbuseAnalysis()

setEnableEndpointAbuseAnalysis

void setEnableEndpointAbuseAnalysis(Boolean value)

getEnableEndpointSequenceAbuseAnalysis

@Default.Boolean(value=false)
Boolean getEnableEndpointSequenceAbuseAnalysis()

setEnableEndpointSequenceAbuseAnalysis

void setEnableEndpointSequenceAbuseAnalysis(Boolean value)

getEnableHardLimitAnalysis

@Default.Boolean(value=false)
Boolean getEnableHardLimitAnalysis()

setEnableHardLimitAnalysis

void setEnableHardLimitAnalysis(Boolean value)

getEnableUserAgentBlocklistAnalysis

@Default.Boolean(value=false)
Boolean getEnableUserAgentBlocklistAnalysis()

setEnableUserAgentBlocklistAnalysis

void setEnableUserAgentBlocklistAnalysis(Boolean value)

getEnablePerEndpointErrorRateAnalysis

@Default.Boolean(value=false)
Boolean getEnablePerEndpointErrorRateAnalysis()

setEnablePerEndpointErrorRateAnalysis

void setEnablePerEndpointErrorRateAnalysis(Boolean value)

getHardLimitRequestCount

@Default.Long(value=100L)
Long getHardLimitRequestCount()

setHardLimitRequestCount

void setHardLimitRequestCount(Long value)

getAnalysisThresholdModifier

@Default.Double(value=75.0)
Double getAnalysisThresholdModifier()

setAnalysisThresholdModifier

void setAnalysisThresholdModifier(Double value)

getRequiredMinimumAverage

@Default.Double(value=5.0)
Double getRequiredMinimumAverage()

setRequiredMinimumAverage

void setRequiredMinimumAverage(Double value)

getRequiredMinimumClients

@Default.Long(value=5L)
Long getRequiredMinimumClients()

setRequiredMinimumClients

void setRequiredMinimumClients(Long value)

getClampThresholdMaximum

Double getClampThresholdMaximum()

setClampThresholdMaximum

void setClampThresholdMaximum(Double value)

getRequiredMinimumRequestsPerClient

@Default.Long(value=20L)
Long getRequiredMinimumRequestsPerClient()

setRequiredMinimumRequestsPerClient

void setRequiredMinimumRequestsPerClient(Long value)

getMaxClientErrorRate

@Default.Long(value=30L)
Long getMaxClientErrorRate()

setMaxClientErrorRate

void setMaxClientErrorRate(Long value)

getNatDetection

@Default.Boolean(value=false)
Boolean getNatDetection()

setNatDetection

void setNatDetection(Boolean value)

getKnownGatewaysPath

String getKnownGatewaysPath()

setKnownGatewaysPath

void setKnownGatewaysPath(String value)

getUserAgentBlocklistPath

String getUserAgentBlocklistPath()

setUserAgentBlocklistPath

void setUserAgentBlocklistPath(String value)

getEndpointAbusePath

String[] getEndpointAbusePath()

setEndpointAbusePath

void setEndpointAbusePath(String[] value)

getEndpointAbuseExtendedVariance

@Default.Boolean(value=false)
Boolean getEndpointAbuseExtendedVariance()

setEndpointAbuseExtendedVariance

void setEndpointAbuseExtendedVariance(Boolean value)

getEndpointAbuseCustomVarianceSubstrings

String[] getEndpointAbuseCustomVarianceSubstrings()

setEndpointAbuseCustomVarianceSubstrings

void setEndpointAbuseCustomVarianceSubstrings(String[] value)

getEndpointAbuseSuppressRecovery

Integer getEndpointAbuseSuppressRecovery()

setEndpointAbuseSuppressRecovery

void setEndpointAbuseSuppressRecovery(Integer value)

getEndpointSequenceAbuseSuppressRecovery

Integer getEndpointSequenceAbuseSuppressRecovery()

setEndpointSequenceAbuseSuppressRecovery

void setEndpointSequenceAbuseSuppressRecovery(Integer value)

getEndpointSequenceAbusePatterns

String[] getEndpointSequenceAbusePatterns()

setEndpointSequenceAbusePatterns

void setEndpointSequenceAbusePatterns(String[] value)

getPerEndpointErrorRatePaths

String[] getPerEndpointErrorRatePaths()

setPerEndpointErrorRatePaths

void setPerEndpointErrorRatePaths(String[] value)

getPerEndpointErrorRateAnalysisSuppressRecovery

Integer getPerEndpointErrorRateAnalysisSuppressRecovery()

setPerEndpointErrorRateAnalysisSuppressRecovery

void setPerEndpointErrorRateAnalysisSuppressRecovery(Integer value)

getPerEndpointErrorRateAlertSuppressionDurationSeconds

@Default.Long(value=120L)
Long getPerEndpointErrorRateAlertSuppressionDurationSeconds()

setPerEndpointErrorRateAlertSuppressionDurationSeconds

void setPerEndpointErrorRateAlertSuppressionDurationSeconds(Long value)

getErrorSessionGapDurationMinutes

@Default.Long(value=5L)
Long getErrorSessionGapDurationMinutes()

setErrorSessionGapDurationMinutes

void setErrorSessionGapDurationMinutes(Long value)

getFilterRequestPath

String[] getFilterRequestPath()

setFilterRequestPath

void setFilterRequestPath(String[] value)

getIncludeUrlHostRegex

String[] getIncludeUrlHostRegex()

setIncludeUrlHostRegex

void setIncludeUrlHostRegex(String[] value)

getCidrExclusionList

String getCidrExclusionList()

setCidrExclusionList

void setCidrExclusionList(String value)

getSessionGapDurationMinutes

@Default.Long(value=45L)
Long getSessionGapDurationMinutes()

setSessionGapDurationMinutes

void setSessionGapDurationMinutes(Long value)

getAlertSuppressionDurationSeconds

@Default.Long(value=600L)
Long getAlertSuppressionDurationSeconds()

setAlertSuppressionDurationSeconds

void setAlertSuppressionDurationSeconds(Long value)

getIgnoreCloudProviderRequests

@Default.Boolean(value=true)
Boolean getIgnoreCloudProviderRequests()

setIgnoreCloudProviderRequests

void setIgnoreCloudProviderRequests(Boolean value)

getIgnoreInternalRequests

@Default.Boolean(value=true)
Boolean getIgnoreInternalRequests()

setIgnoreInternalRequests

void setIgnoreInternalRequests(Boolean value)

getPipelineMultimodeConfiguration

String getPipelineMultimodeConfiguration()

setPipelineMultimodeConfiguration

void setPipelineMultimodeConfiguration(String value)

getEnableSourceCorrelator

@Default.Boolean(value=false)
Boolean getEnableSourceCorrelator()

setEnableSourceCorrelator

void setEnableSourceCorrelator(Boolean value)

getSourceCorrelatorMinimumAddresses

@Default.Integer(value=250)
Integer getSourceCorrelatorMinimumAddresses()

setSourceCorrelatorMinimumAddresses

void setSourceCorrelatorMinimumAddresses(Integer value)

getSourceCorrelatorAlertPercentage

@Default.Double(value=90.0)
Double getSourceCorrelatorAlertPercentage()

setSourceCorrelatorAlertPercentage

void setSourceCorrelatorAlertPercentage(Double value)

getEnableStatusCodeRateAnalysis

@Default.Boolean(value=false)
Boolean getEnableStatusCodeRateAnalysis()

setEnableStatusCodeRateAnalysis

void setEnableStatusCodeRateAnalysis(Boolean value)

getMaxClientStatusCodeRate

@Default.Long(value=60L)
Long getMaxClientStatusCodeRate()

setMaxClientStatusCodeRate

void setMaxClientStatusCodeRate(Long value)

getStatusCodeRateAnalysisCode

Integer getStatusCodeRateAnalysisCode()

setStatusCodeRateAnalysisCode

void setStatusCodeRateAnalysisCode(Integer value)

getEnableSessionLimitAnalysis

@Default.Boolean(value=false)
Boolean getEnableSessionLimitAnalysis()

setEnableSessionLimitAnalysis

void setEnableSessionLimitAnalysis(Boolean value)

getSessionLimitAnalysisPaths

String[] getSessionLimitAnalysisPaths()

setSessionLimitAnalysisPaths

void setSessionLimitAnalysisPaths(String[] value)

getSessionLimitAnalysisSuppressRecovery

Integer getSessionLimitAnalysisSuppressRecovery()

setSessionLimitAnalysisSuppressRecovery

void setSessionLimitAnalysisSuppressRecovery(Integer value)