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
- BoolResponse
- Response for operations returning bool.
- BulkInsertArrayRequest
- BulkInsertParallelRequest
- Parallel bulk insert through pool.
- CacheMetricsResponse
- Response for cache metrics (sendable record).
- CancelStatementRequest
- Cancel prepared statement execution.
- CatalogColumnsRequest
- Catalog columns.
- CatalogForeignKeysRequest
- Catalog foreign keys.
- CatalogIndexesRequest
- Catalog indexes.
- CatalogPrimaryKeysRequest
- Catalog primary keys.
- CatalogTablesRequest
- CatalogTypeInfoRequest
- Catalog type info.
- ClearAllStatementsRequest
- 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.
- ExecuteAsyncStartParamsRequest
- Start non-blocking async execution with serialized parameters.
- ExecuteAsyncStartRequest
- ExecutePreparedRequest
- Execute prepared statement. Params sent as serialized Uint8List.
- ExecuteQueryMultiParamsRequest
- Execute parameterised multi-result query (M5 in v3.2.0).
- ExecuteQueryMultiRequest
- Execute query returning multiple result sets.
- ExecuteQueryParamsRequest
- GetCacheMetricsRequest
- Get cache metrics.
- GetConnectionDbmsInfoRequest
- Get live DBMS information JSON payload for an open native connection.
- GetDriverCapabilitiesRequest
- Get driver capabilities JSON payload from connection string.
- GetErrorRequest
- Get last error message.
- GetErrorResponse
- Response for getError.
- GetMetricsRequest
- Get metrics.
- GetStructuredErrorForConnectionRequest
- Get structured error scoped to a specific connection.
- 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 pool state.
- PoolCloseRequest
- Close pool.
- PoolCreateRequest
- 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
- Bulk insert.
- PrepareRequest
- Begin transaction.
- QueryResponse
- Response for query/exec operations returning binary or error.
- RollbackTransactionRequest
- Rollback transaction.
- SavepointCreateRequest
- Create savepoint.
- SavepointReleaseRequest
- Release savepoint.
- SavepointRollbackRequest
- Rollback to savepoint.
- SetLogLevelRequest
- Set native engine log verbosity.
- StreamCancelRequest
- Cancel active stream.
- StreamCloseRequest
- Close active stream.
- StreamFetchRequest
- Fetch next chunk from an active stream.
- StreamFetchResponse
- Close all prepared statements.
- StreamMultiStartAsyncRequest
- Start async streaming multi-result batch (M8 in v3.3.0).
- StreamMultiStartBatchedRequest
- Start streaming multi-result batch (M8 in v3.3.0).
- StreamPollAsyncRequest
- Poll async stream status.
- StreamStartAsyncRequest
- Start low-level async batched streaming query.
- StreamStartBatchedRequest
- Start low-level batched streaming query.
- StreamStartRequest
- 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
Constants
- isolateTransferablePayloadThresholdBytes → const int
- Minimum payload size before isolate messages use TransferableTypedData.
Functions
-
isolateQueryDataResponse(
int requestId, Uint8List data) → QueryResponse - Builds a worker QueryResponse with inline or transferable payload.
-
isolateStreamDataResponse(
{required int requestId, required bool success, required Uint8List? data, required bool hasMore, String? error}) → StreamFetchResponse - Builds a worker StreamFetchResponse with inline or transferable payload.
-
transferableIsolatePayload(
Uint8List bytes) → TransferableTypedData? - Returns transferable ownership for large byte payloads sent to workers.