pub struct WatchDirectoryParams {
pub path: String,
pub table: String,
pub max_concurrent: Option<u32>,
}Expand description
Parameters for the watch_directory tool.
Fields§
§path: StringAbsolute path to the directory to watch
table: StringTarget table name — all files in the directory are appended to this table
max_concurrent: Option<u32>Maximum number of files ingested in parallel. Defaults to 4; capped at 32. Each in-flight ingest holds one connection to hyperd plus a transaction.
Trait Implementations§
Source§impl Debug for WatchDirectoryParams
impl Debug for WatchDirectoryParams
Source§impl<'de> Deserialize<'de> for WatchDirectoryParams
impl<'de> Deserialize<'de> for WatchDirectoryParams
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 WatchDirectoryParams
impl JsonSchema for WatchDirectoryParams
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 WatchDirectoryParams
impl RefUnwindSafe for WatchDirectoryParams
impl Send for WatchDirectoryParams
impl Sync for WatchDirectoryParams
impl Unpin for WatchDirectoryParams
impl UnsafeUnpin for WatchDirectoryParams
impl UnwindSafe for WatchDirectoryParams
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