[−][src]Struct netidx::resolver::ResolverRead
Implementations
impl ResolverRead
[src]
pub fn new(default: Config, desired_auth: Auth) -> Self
[src]
pub async fn send(
&self,
batch: &Pooled<Vec<ToRead>>
) -> Result<Pooled<Vec<FromRead>>>
[src]
&self,
batch: &Pooled<Vec<ToRead>>
) -> Result<Pooled<Vec<FromRead>>>
send the specified messages to the resolver, and return the answers (in send order)
pub async fn resolve<I>(&self, batch: I) -> Result<Pooled<Vec<Resolved>>> where
I: IntoIterator<Item = Path>,
[src]
I: IntoIterator<Item = Path>,
resolve the specified paths, results are in send order
pub async fn list(&self, path: Path) -> Result<Pooled<Vec<Path>>>
[src]
list children of the specified path. Order is unspecified.
pub async fn list_matching(
&self,
globset: &GlobSet
) -> Result<Pooled<Vec<Pooled<Vec<Path>>>>>
[src]
&self,
globset: &GlobSet
) -> Result<Pooled<Vec<Pooled<Vec<Path>>>>>
list all paths in the cluster matching the specified globset. You will get a list of batches of paths. If your globset is configured to match only published paths, then the batches should be disjoint, otherwise there may be some duplicate structural elements.
pub async fn check_changed(&self, tracker: &mut ChangeTracker) -> Result<bool>
[src]
Check whether that have been any changes to the specified path or any of it's children on any server in the resolver cluster. A change in this context consists of,
- A new publisher publishing an existing path
- A publisher publishing a new path
- A publisher no longer publishing a path
Changes to the value of already published paths is not a change in this context.
This method is meant to be used as a light alternative to
list, or list_matching in order to discover when structural
changes are made by publishers that result in the need to
adjust subscriptions. It is much cheaper and faster to call
this method than list
or list_matching
.
The first call with a new ChangeTracker
will always result
in true
. If true
is returned at any point it is not a
guarantee that there were changes, but it is a strong
possibility. If false
is returned it is guaranteed that
there was no change.
pub async fn table(&self, path: Path) -> Result<Table>
[src]
Trait Implementations
impl Clone for ResolverRead
[src]
fn clone(&self) -> ResolverRead
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for ResolverRead
[src]
Auto Trait Implementations
impl !RefUnwindSafe for ResolverRead
[src]
impl Send for ResolverRead
[src]
impl Sync for ResolverRead
[src]
impl Unpin for ResolverRead
[src]
impl !UnwindSafe for ResolverRead
[src]
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Pointable for T
pub const ALIGN: usize
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize
pub unsafe fn deref<'a>(ptr: usize) -> &'a T
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T
pub unsafe fn drop(ptr: usize)
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,