infrastructure/native/isolate/message_protocol library

Classes

AsyncCancelRequest
Cancel async request.
AsyncFreeRequest
Free async request resources.
AsyncGetResultRequest
Retrieve async request result.
AsyncPollRequest
Poll async request status.
AuditClearRequest
Clear all audit events.
AuditEnableRequest
Enable/disable audit logging.
AuditGetEventsRequest
Get audit events JSON payload.
AuditGetStatusRequest
Get audit status JSON payload.
AuditPayloadResponse
Response carrying JSON payload for audit operations.
BeginTransactionRequest
Begin transaction.
BoolResponse
Response for operations returning bool.
BulkInsertArrayRequest
Bulk insert.
BulkInsertParallelRequest
Parallel bulk insert through pool.
CacheMetricsResponse
Response for cache metrics (sendable record).
CancelStatementRequest
Cancel prepared statement execution.
CatalogColumnsRequest
Catalog columns.
CatalogTablesRequest
Catalog tables.
CatalogTypeInfoRequest
Catalog type info.
ClearAllStatementsRequest
Close all prepared statements.
ClearCacheRequest
Clear cache.
ClearCacheResponse
Response for clear cache.
CloseStatementRequest
Close prepared statement.
CommitTransactionRequest
Commit transaction.
ConnectRequest
Establish database connection.
ConnectResponse
Response for connect.
DetectDriverRequest
Detect database driver from connection string.
DetectDriverResponse
Response for detectDriver.
DisconnectRequest
Disconnect and close connection.
ExecuteAsyncStartRequest
Start non-blocking async execution.
ExecutePreparedRequest
Execute prepared statement. Params sent as serialized Uint8List.
ExecuteQueryMultiRequest
Execute query returning multiple result sets.
ExecuteQueryParamsRequest
Execute parameterized query. Params sent as serialized Uint8List.
GetCacheMetricsRequest
Get cache metrics.
GetDriverCapabilitiesRequest
Get driver capabilities JSON payload from connection string.
GetErrorRequest
Get last error message.
GetErrorResponse
Response for getError.
GetMetricsRequest
Get metrics.
GetStructuredErrorRequest
Get structured error.
GetVersionRequest
Get engine version (api + abi).
InitializeRequest
Initialize ODBC environment.
InitializeResponse
Response for initialize.
IntResponse
Response for operations returning int (stmtId, poolId, connId, rowCount).
MetadataCacheClearRequest
Clear metadata cache entries.
MetadataCacheEnableRequest
Enable/reconfigure metadata cache.
MetadataCacheStatsRequest
Get metadata cache stats as JSON payload.
MetricsResponse
Response for metrics (sendable record).
PoolCloseRequest
Close pool.
PoolCreateRequest
Create connection pool.
PoolGetConnectionRequest
Get connection from pool.
PoolGetStateJsonRequest
Get detailed pool state JSON payload.
PoolGetStateRequest
Get pool state.
PoolHealthCheckRequest
Health check on pool.
PoolReleaseConnectionRequest
Release connection to pool.
PoolSetSizeRequest
Resize pool.
PoolStateResponse
Response for pool state.
PrepareRequest
Prepare SQL statement.
QueryResponse
Response for query/exec operations returning binary or error.
RollbackTransactionRequest
Rollback transaction.
SavepointCreateRequest
Create savepoint.
SavepointReleaseRequest
Release savepoint.
SavepointRollbackRequest
Rollback to savepoint.
StreamCancelRequest
Cancel active stream.
StreamCloseRequest
Close active stream.
StreamFetchRequest
Fetch next chunk from an active stream.
StreamFetchResponse
Response for stream fetch operation.
StreamPollAsyncRequest
Poll async stream status.
StreamStartAsyncRequest
Start low-level async batched streaming query.
StreamStartBatchedRequest
Start low-level batched streaming query.
StreamStartRequest
Start low-level streaming query.
StructuredErrorResponse
Response for getStructuredError (sendable fields only).
ValidateConnectionStringRequest
Validate connection string without connecting.
ValidateConnectionStringResponse
Response for connection string validation.
VersionResponse
Response for engine version.
WorkerRequest
Base class for worker requests. All subclasses must be sendable.
WorkerResponse
Base class for worker responses. All subclasses must be sendable.

Enums

RequestType
Request types for worker isolate communication.