pub struct RemoteControlPlane { /* private fields */ }Expand description
Reads client records from a remote control repository.
Records are stored at clients/by-key/{sha256(api_key)}.json and
must conform to the ClientRecord JSON schema.
Implementations§
Source§impl RemoteControlPlane
impl RemoteControlPlane
Sourcepub fn new(config: LakeFSConfig) -> Result<Self, ControlPlaneError>
pub fn new(config: LakeFSConfig) -> Result<Self, ControlPlaneError>
Create a new remote control plane.
The config should point at the _briefcase_control repository
(or whichever repo holds client records).
Sourcepub fn client_path(key_hash: &str) -> String
pub fn client_path(key_hash: &str) -> String
Build the object path for a given key hash.
Trait Implementations§
Source§impl ControlPlane for RemoteControlPlane
impl ControlPlane for RemoteControlPlane
Source§fn lookup_client<'life0, 'life1, 'async_trait>(
&'life0 self,
api_key: &'life1 str,
) -> Pin<Box<dyn Future<Output = Result<ClientRecord, ControlPlaneError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn lookup_client<'life0, 'life1, 'async_trait>(
&'life0 self,
api_key: &'life1 str,
) -> Pin<Box<dyn Future<Output = Result<ClientRecord, ControlPlaneError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Look up a client by raw API key. Read more
Source§fn health_check<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn health_check<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Quick connectivity check. Returns
true if the backend is reachable.Source§fn backend_name(&self) -> &str
fn backend_name(&self) -> &str
Human-readable backend name for logging (e.g. “remote”, “local”).
Auto Trait Implementations§
impl Freeze for RemoteControlPlane
impl !RefUnwindSafe for RemoteControlPlane
impl Send for RemoteControlPlane
impl Sync for RemoteControlPlane
impl Unpin for RemoteControlPlane
impl UnsafeUnpin for RemoteControlPlane
impl !UnwindSafe for RemoteControlPlane
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