mod access;
mod batch;
mod budget;
mod error;
mod observe_result;
mod observe_tasks;
mod report;
mod worker;
pub use access::{
AuthorizedWorkspaceReadAccess, AuthorizedWorkspaceWriteAccess, PluginWorkspaceReadError,
PluginWorkspaceWriteError, WorkspaceAccessKind,
};
#[cfg(test)]
use batch::PluginWorkspaceWritePayload;
pub use batch::{
PendingPluginWorkspaceIoBatch, PluginWorkspaceIoDiscardReport, PluginWorkspaceIoExecutionModel,
SealedPluginWorkspaceIoBatch,
};
pub use budget::{
PluginWorkspaceIoBudget, PluginWorkspaceIoBudgetField, PluginWorkspaceReadByteLimit,
PluginWorkspaceWriteByteLimit,
};
pub use error::{
PluginWorkspaceIoCommitError, PluginWorkspaceIoCommitErrorKind,
PluginWorkspaceIoIdentityMismatchSource,
};
pub use observe_result::{
PluginWorkspaceObserveTaskCompletion, PluginWorkspaceObserveTaskCompletionShape,
PluginWorkspaceObserveTaskHandle, PluginWorkspaceObserveTaskId,
PluginWorkspaceObserveTaskIdError, PluginWorkspaceObserveTaskPoll,
PluginWorkspaceObserveTaskResultShape, PluginWorkspaceObserveTaskState,
PluginWorkspaceObserveTaskTake,
};
pub(in crate::plugin) use observe_tasks::PendingPluginWorkspaceObserveTaskBatch;
pub use observe_tasks::{
PluginWorkspaceObserveTaskCancellationReport, PluginWorkspaceObserveTaskDiscardReport,
PluginWorkspaceObserveTaskEnqueueError, PluginWorkspaceObserveTaskEnqueueErrorParts,
PluginWorkspaceObserveTaskEnqueueReport, PluginWorkspaceObserveTaskQueue,
PluginWorkspaceObserveTaskQueueError, PluginWorkspaceObserveTaskQueueErrorKind,
PluginWorkspaceObserveTaskQueueLimit, PluginWorkspaceObserveTaskQueueLimitField,
PluginWorkspaceObserveTaskReservationMismatch, PluginWorkspaceObserveTaskReserveError,
SealedPluginWorkspaceObserveTaskBatch,
};
pub use report::{
PluginWorkspaceIoCompletion, PluginWorkspaceIoReport, PluginWorkspaceObserveBytes,
PluginWorkspaceObserveOutcome, PluginWorkspaceObserveOutcomeShape,
PluginWorkspaceObserveProjectionError, PluginWorkspaceReadCompletion,
PluginWorkspaceReadSuccess, PluginWorkspaceWriteCompletion, PluginWorkspaceWriteSuccess,
};
pub use worker::PluginWorkspaceIoWorkerQueueAdmission;
pub use worker::{
PluginWorkspaceIoCancellationReport, PluginWorkspaceIoWorkerEnqueueError,
PluginWorkspaceIoWorkerEnqueueErrorParts, PluginWorkspaceIoWorkerQueue,
PluginWorkspaceIoWorkerQueueError, PluginWorkspaceIoWorkerQueueErrorKind,
PluginWorkspaceIoWorkerQueueLimit, PluginWorkspaceIoWorkerQueueLimitField,
};
#[cfg(test)]
mod tests;