Package | Description |
---|---|
com.mozilla.secops.httprequest |
HTTP request threshold and error rate monitoring
|
com.mozilla.secops.input |
Pipeline input
|
Modifier and Type | Method and Description |
---|---|
Input |
HTTPRequestMultiMode.getInput()
Get input configuration
|
static Input |
HTTPRequest.getInput(org.apache.beam.sdk.Pipeline p,
HTTPRequest.HTTPRequestOptions options)
Given HTTPRequest pipeline options, return a configured
Input class |
Modifier and Type | Method and Description |
---|---|
static org.apache.beam.sdk.values.PCollectionTuple |
HTTPRequest.readInput(org.apache.beam.sdk.Pipeline p,
Input input,
HTTPRequest.HTTPRequestOptions options)
Read from a configured
Input object, returning a PCollectionTuple of events |
void |
HTTPRequestMultiMode.setInput(Input input)
Set input configuration
|
Modifier and Type | Method and Description |
---|---|
Input |
Input.fromPipelineOptions(InputOptions options,
String cfgTickMessage)
Configure input using specified
InputOptions |
Input |
Input.multiplex()
Enable multiplex mode
|
Input |
Input.simplex()
Enable simplex input mode
|
Input |
Input.withInputElement(InputElement el)
Add input element
|
Modifier and Type | Method and Description |
---|---|
void |
InputElement.setParentInput(Input parent)
Set parent
Input object |
Constructor and Description |
---|
MultiplexReader(Input input)
Create new MultiplexReader
|
MultiplexReaderRaw(Input input)
Create new MultiplexReaderRaw
|
SimplexReader(Input input)
Create new SimplexReader
|
SimplexReaderRaw(Input input)
Create new SimplexReaderRaw
|
Copyright © 2022. All rights reserved.