pub struct LazyCloudObjectStoreRegistry { /* private fields */ }Expand description
Registry that lazily constructs S3-compatible stores on first reference.
Implementations§
Trait Implementations§
Source§impl Debug for LazyCloudObjectStoreRegistry
impl Debug for LazyCloudObjectStoreRegistry
Source§impl Default for LazyCloudObjectStoreRegistry
impl Default for LazyCloudObjectStoreRegistry
Source§fn default() -> LazyCloudObjectStoreRegistry
fn default() -> LazyCloudObjectStoreRegistry
Returns the “default value” for a type. Read more
Source§impl ObjectStoreRegistry for LazyCloudObjectStoreRegistry
impl ObjectStoreRegistry for LazyCloudObjectStoreRegistry
Source§fn register_store(
&self,
url: &Url,
store: Arc<dyn ObjectStore>,
) -> Option<Arc<dyn ObjectStore>>
fn register_store( &self, url: &Url, store: Arc<dyn ObjectStore>, ) -> Option<Arc<dyn ObjectStore>>
If a store with the same key existed before, it is replaced and returned
Source§fn get_store(&self, url: &Url) -> DataFusionResult<Arc<dyn ObjectStore>>
fn get_store(&self, url: &Url) -> DataFusionResult<Arc<dyn ObjectStore>>
Get a suitable store for the provided URL. For example: Read more
Source§fn deregister_store(
&self,
url: &Url,
) -> Result<Arc<dyn ObjectStore>, DataFusionError>
fn deregister_store( &self, url: &Url, ) -> Result<Arc<dyn ObjectStore>, DataFusionError>
Deregister the store previously registered with the same key. Returns the
deregistered store if it existed.
Auto Trait Implementations§
impl !RefUnwindSafe for LazyCloudObjectStoreRegistry
impl !UnwindSafe for LazyCloudObjectStoreRegistry
impl Freeze for LazyCloudObjectStoreRegistry
impl Send for LazyCloudObjectStoreRegistry
impl Sync for LazyCloudObjectStoreRegistry
impl Unpin for LazyCloudObjectStoreRegistry
impl UnsafeUnpin for LazyCloudObjectStoreRegistry
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§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