Persistent Batch Manager. Subclass of BatchManager that adds the ability to persist batches to disk and restore from disk This BatchManager enforces that type T is a JsonSerializable.ISerializable
More...
|
| | PersistentBatchManager (CoroutineService coroutineService, string storageKey, int batchCapacity, double batchTimeoutSeconds, float heartbeatInterval=1f) |
| | Initializes a new instance of the PersistentBatchManager<T> class. More...
|
| |
| override void | Add (T item) |
| | Add an item to the Batch More...
|
| |
| | BatchManager (CoroutineService coroutineService, int batchCapacity, double batchTimeoutSeconds, float heartbeatInterval=1f) |
| | Initializes a new instance of the BatchManager<T> class. More...
|
| |
|
void | Start () |
| | Start this batch's lifecycle processing This starts a coroutine which executs a Heartbeat at a regular interval
|
| |
|
void | Stop () |
| | Stop this batch's lifecycle processing This means the Heartbeat will cease to execute
|
| |
|
void | RestartHeartbeat (bool onlyIfStarted=true) |
| |
|
virtual void | Flush () |
| | Flush this Batch This causes it to expire, trigger the relevant callbacks, and rotate
|
| |
| void | SetCapacity (int batchCapacity) |
| | Sets the batch's capacity threshold before expiration. More...
|
| |
| void | SetTimeoutSeconds (double batchTimeoutSeconds) |
| | Sets the timeout seconds before expiration. More...
|
| |
|
void | SetHeartbeat (float heatbeatInterval) |
| |
|
| override void | OnStart () |
| |
| override void | RotateBatch () |
| | Rotates the batch. This creates a new batch, hooks OnExpired event, and declares the batch ready for backup More...
|
| |
| override void | OnHeartbeat () |
| | Raises the heartbeat event. This runs the base class OnHeartbeat and also checks whether we should backup the batch. More...
|
| |
|
void | BackupEventBatch () |
| | Backups the event batch to disk.
|
| |
|
void | RestoreEventBatch () |
| | Restores the event batch from disk and adds any elements to the current batch.
|
| |
| void | OnExpired (List< T > batchItems) |
| | Raises the expired event. More...
|
| |
|
virtual void | CheckBatchExpired () |
| | Checks whether the batch should be expired.
|
| |
|
|
string | _storageKey |
| | The storage key used for persisting to disk.
|
| |
|
bool | _backupBatchNow |
| | A flag which determines whether to backup the current batch on the next Heartbeat.
|
| |
|
bool | _isActive |
| | Flag for whether the BatchManager is actively evaluating the batch's lifecycle
|
| |
|
int | _batchCapacity |
| |
|
double | _batchTimeoutSeconds |
| |
|
double | _heartbeatSeconds |
| |
|
WaitForSeconds | _heartbeatInterval |
| |
|
IEnumerator | _heatbeatCoroutine |
| |
|
IBatchContainer< T > | _currentBatch |
| |
|
|
Action< List< T > > | OnBatchExpired |
| | Occurs when on batch expired.
|
| |
Persistent Batch Manager. Subclass of BatchManager that adds the ability to persist batches to disk and restore from disk This BatchManager enforces that type T is a JsonSerializable.ISerializable
- Type Constraints
-
| T | : | class | |
| T | : | JsonSerializable.ISerializable | |
◆ PersistentBatchManager()
Initializes a new instance of the PersistentBatchManager<T> class.
- Parameters
-
| storageKey | Storage key used for persistent storage. |
| batchCapacity | Batch capacity threshold for batch expiration. |
| batchTimeoutSeconds | Maximum seconds before a batch is expired. |
| heartbeatInterval | Heartbeat interval. |
◆ Add()
◆ OnHeartbeat()
◆ OnStart()
◆ RotateBatch()
The documentation for this class was generated from the following file:
- com.beamable/Runtime/Core/Platform/SDK/Analytics/Batch/PersistentBatchManager.cs