pub struct LoadFilesParams {
pub files: Vec<LoadFilesEntry>,
pub concurrency: Option<u32>,
}Expand description
Parameters for the load_files workspace tool.
Fields§
§files: Vec<LoadFilesEntry>Batch of files to ingest in parallel. Each entry targets its own table and runs independently — one entry’s failure does not abort the others.
concurrency: Option<u32>Maximum number of concurrent ingest tasks. Each task checks out
its own connection from a pool sized to match. Default:
min(files.len(), 8). Large parquet ingests are I/O-bound on
hyperd’s side; more connections don’t help past a certain point
and can starve the primary connection.
Trait Implementations§
Source§impl Debug for LoadFilesParams
impl Debug for LoadFilesParams
Source§impl<'de> Deserialize<'de> for LoadFilesParams
impl<'de> Deserialize<'de> for LoadFilesParams
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl JsonSchema for LoadFilesParams
impl JsonSchema for LoadFilesParams
Source§fn schema_id() -> Cow<'static, str>
fn schema_id() -> Cow<'static, str>
Returns a string that uniquely identifies the schema produced by this type. Read more
Source§fn json_schema(generator: &mut SchemaGenerator) -> Schema
fn json_schema(generator: &mut SchemaGenerator) -> Schema
Generates a JSON Schema for this type. Read more
Source§fn inline_schema() -> bool
fn inline_schema() -> bool
Whether JSON Schemas generated for this type should be included directly in parent schemas,
rather than being re-used where possible using the
$ref keyword. Read moreAuto Trait Implementations§
impl Freeze for LoadFilesParams
impl RefUnwindSafe for LoadFilesParams
impl Send for LoadFilesParams
impl Sync for LoadFilesParams
impl Unpin for LoadFilesParams
impl UnsafeUnpin for LoadFilesParams
impl UnwindSafe for LoadFilesParams
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request