Package | Description |
---|---|
com.mozilla.secops |
General utility classes and transforms for secops-beam
|
com.mozilla.secops.authprofile |
Pipeline for authentication source profiling and alerting
|
com.mozilla.secops.authstate |
Authentication state storage and utility classes
|
com.mozilla.secops.state |
Classes for handling persistent state for Beam pipelines
|
Constructor and Description |
---|
Watchlist()
Return a new watchlist interface for fetching watchlist entries
|
Watchlist(String datastoreProject)
Return a new watchlist interface for fetching watchlist entries
|
Modifier and Type | Method and Description |
---|---|
void |
AuthProfile.StateAnalyze.processElement(org.apache.beam.sdk.transforms.DoFn.ProcessContext c) |
void |
AuthProfile.StateAnalyze.setup() |
Modifier and Type | Method and Description |
---|---|
static AuthStateModel |
AuthStateModel.get(String user,
StateCursor<AuthStateModel> s,
PruningStrategy ps)
Retrieve state object for user
|
void |
AuthStateModel.set(StateCursor<AuthStateModel> s,
PruningStrategy ps)
Persist state using state interface
|
Modifier and Type | Method and Description |
---|---|
abstract void |
StateCursor.commit()
Commit transaction
|
void |
DatastoreStateCursor.commit()
Commit datastore transaction
|
void |
MemcachedStateCursor.commit() |
void |
StateInterface.deleteAll()
Flush all keys in the state implementation
|
void |
MemcachedStateInterface.deleteAll()
Flush all keys in the state implementation
|
void |
DatastoreStateInterface.deleteAll()
Flush all keys in the state implementation
|
void |
State.deleteAll()
Flush all keys in the underlying state storage
|
void |
StateCursor.execute()
Execute all operations in cursor
|
void |
DatastoreStateCursor.executeInner() |
void |
MemcachedStateCursor.executeInner() |
T |
StateCursor.get(String key)
Get a value from state
|
ArrayList<T> |
StateCursor.getAll()
Get all values from state
|
T |
StateCursor.getResultValueForId(UUID id)
Fetch a result value from a completed operation
|
ArrayList<T> |
StateCursor.getResultValuesForId(UUID id)
Fetch a set of result values from a completed operation
|
void |
StateInterface.initialize()
Perform any setup required to read and write state
|
void |
MemcachedStateInterface.initialize()
Perform any setup required to read and write state
|
void |
DatastoreStateInterface.initialize()
Perform any setup required to read and write state
|
void |
State.initialize()
Initialize state instance
|
<T> StateCursor<T> |
StateInterface.newCursor(Class<T> stateClass,
boolean transaction)
Allocate new state cursor
|
<T> StateCursor<T> |
MemcachedStateInterface.newCursor(Class<T> stateClass,
boolean transaction)
Allocate new state cursor
|
<T> StateCursor<T> |
DatastoreStateInterface.newCursor(Class<T> stateClass,
boolean transaction)
Allocate new state cursor
|
<T> StateCursor<T> |
State.newCursor(Class<T> stateClass,
boolean transaction)
Allocate new state cursor for a set of operations
|
void |
StateCursor.set(String key,
T value)
Set a value in state
|
StateCursor<T> |
StateCursor.withOperation(StateOperation<T> operation)
Add an operation for execution in the cursor
|
Copyright © 2022. All rights reserved.