Struct RsyncSyntax

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 more

Source §

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

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 more

Source §

impl<This> IntoExt<This> for This

Source §

fn to<R>(self) -> R
where This: Into<R>,

A version of Into::into function that can be used to explicitly specify the target conversion type.

use alux_sdk::*;
// `Into` requires context to infer the type,
let _: i64 = Into::into(42_i8);
// The opposite `From` requires context to infer the type,
let _: i64 = From::from(42_i8);
// `.to()` can be used in the same way as a postfix function (the same as `.into()`),
let _: i64 = 42_i8.to();
// but also with the type specified explicitly.
let _ = 42_i8.to::<i64>();
// Especially useful to chain multiple conversions inline.
let _: i64 = 42_i8.to::<i16>().to::<i32>().into();

Source §

impl<This> IntoIteratorExt<This> for This

Source §

fn try_collect_vec<T, E>(self) -> Result<Vec<T>, E>
where This: Iterator<Item = Result<T, E>>,

A variant of the try_collect and collect_vec combined function from the Itertools library. The materialized value is a Vec inside a Result object.

Returns the first error without collecting later values.

use alux_sdk::*;

let values = [Ok::<_, &str>(1), Ok(2), Ok(3)]
    .into_iter()
    .try_collect_vec();

assert_eq!(values, Ok(vec![1, 2, 3]));

Source §

fn collect_exact<T>(self, n: usize) -> Option<Vec<T>>
where This: Iterator<Item = T>,

Takes exactly n elements from the iterator.

Returns Some(Vec<T>) if the iterator yields exactly n elements, otherwise returns None.

use alux_sdk::*;

let v = [1, 2, 3];

assert_eq!(v.iter().copied().collect_exact(3), Some(vec![1, 2, 3]));
assert_eq!(v.iter().copied().collect_exact(4), None);
assert_eq!(v.iter().copied().collect_exact(2), None);

Source §

fn try_unzip<A, B, E>(self) -> Result<(Vec<A>, Vec), E>
where This: IntoIterator<Item = Result<(A, B), E>>,

Efficiently splits an iterator of Result<(A, B), E> into two Vecs, short-circuiting on error.

Consumes the iterator, collecting all A elements into one vector and all B elements into another, without first allocating an intermediate vector of tuples. Returns the tuple (Vec<A>, Vec) on success, or the first error encountered.

use alux_sdk::*;

let input = vec![Ok((1, "x")), Ok((2, "y"))];
let (xs, ys) = input.try_unzip::<_, _, ()>().unwrap();

assert_eq!(xs, vec![1, 2]);
assert_eq!(ys, vec!["x", "y"]);

Source §

impl<This> RsyncEndpointExt<This> for This
where This: RsyncEndpointAlg + RsyncEndpointViewAlg,

Source §

fn read_endpoint(&self, input: &str) -> <This as RsyncSorts>::Endpoint

Reads one endpoint from the text somebody submitted.

Three shapes name a path on another machine: a daemon URL, and a machine and a path separated by a colon with nothing path-like before it. A text naming any other scheme names a resource somewhere else, and a text naming neither names a path here.

Source §

fn read_transfer( &self, line: &str, ) -> Option<(<This as RsyncSorts>::Endpoint, <This as RsyncSorts>::Endpoint)>

Reads one submitted line as the two ends of a transfer, when it names two.

A transfer is written the way it is run: what comes from, then what it comes to. Anything naming how rather than what — the program itself, and the arguments given to it — is already stated by the transfer, so a whole command can be submitted and still be read.

Source §

fn endpoint_remote(&self, endpoint: &<This as RsyncSorts>::Endpoint) -> bool

Observes whether the path rests on another machine.

Source §

fn endpoint_text(&self, endpoint: &<This as RsyncSorts>::Endpoint) -> String

States the endpoint the way the transfer program is given it.

Source §

fn endpoint_name<'a>( &self, endpoint: &'a <This as RsyncSorts>::Endpoint, ) -> &'a str

Names what the path ends with, without the path that leads to it.

Source §

impl<This> SyncCommandExt<This> for This
where This: SyncCommandAlg + SyncCommandViewAlg + RsyncEndpointAlg + RsyncEndpointViewAlg,

Source §

fn transfer_command( &self, source: &<This as RsyncSorts>::Endpoint, destination: &<This as RsyncSorts>::Endpoint, mode: SyncMode, ) -> <This as RsyncSorts>::Command

States the command transferring one endpoint into another.

What is transferred may be one file or a whole folder, and each end is stated exactly as it was written. A source ending with a separator names the contents of a folder; one without names the path itself, which comes to rest inside the destination. Both are wanted, so neither is invented here.

Source §

fn command_rehearses(&self, command: &<This as RsyncSorts>::Command) -> bool

Observes whether the command states what it would do instead of doing it.

Source §

fn command_mirrors(&self, command: &<This as RsyncSorts>::Command) -> bool

Observes whether the command removes what the source no longer holds.

Source §

impl<This> SyncReadExt<This> for This
where This: SyncChangeAlg + SyncObservationAlg,

Source §

fn read_sync_line(&self, line: &str) -> <This as RsyncSorts>::Observation

Reads one line the transfer program wrote as what it states.

A change is stated in three fields: the flags naming what happens, the byte count, and the path. Anything else on the stream is progress, or is nothing this specification reads.

Source §

fn read_sync_change(&self, line: &str) -> Option<<This as RsyncSorts>::Change>

Reads one itemized line as the change it denotes, and states nothing for a line naming only that a folder was opened on the way to what is inside it.

Source §

impl<T> ToOwned for T
where T: Clone,

Source §

type Owned = T

The resulting type after obtaining ownership.

Source §

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

Source §

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more

Source §

impl<T, U> TryFrom for T
where U: Into<T>,

Source §

type Error = !

The type returned in the event of a conversion error.

Source §

fn try_from(value: U) -> Result<T, !>

Performs the conversion.

Source §

impl<T, U> TryInto for T
where U: TryFrom<T>,

Source §

type Error = >::Error

The type returned in the event of a conversion error.

Source §

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

RsyncSyntax

Struct RsyncSyntax Copy item path

Trait Implementations§

impl Clone for RsyncSyntax

fn clone(&self) -> Self

fn clone_from(&mut self, source: &Self)

impl Copy for RsyncSyntax

impl Debug for RsyncSyntax

fn fmt(&self, f: &mut Formatter<'_>) -> Result

impl Default for RsyncSyntax

fn default() -> Self

impl Eq for RsyncSyntax

impl PartialEq for RsyncSyntax

fn eq(&self, other: &Self) -> bool

fn ne(&self, other: &Rhs) -> bool

impl RsyncEndpointAlg for RsyncSyntax

fn endpoint( &self, user: Option<String>, host: Option<String>, path: impl Into<String>, ) -> Self::Endpoint

impl RsyncEndpointViewAlg for RsyncSyntax

fn endpoint_user<'a>(&self, endpoint: &'a Self::Endpoint) -> Option<&'a str>

fn endpoint_host<'a>(&self, endpoint: &'a Self::Endpoint) -> Option<&'a str>

fn endpoint_path<'a>(&self, endpoint: &'a Self::Endpoint) -> &'a str

impl RsyncSorts for RsyncSyntax

type Endpoint = RsyncEndpoint

type Command = SyncCommand

type Observation = SyncObservation

type Change = PlannedChange

impl StructuralPartialEq for RsyncSyntax

impl SyncChangeAlg for RsyncSyntax

fn sync_change( &self, path: impl Into<String>, kind: ChangeKind, size: Option<u64>, ) -> Self::Change

impl SyncCommandAlg for RsyncSyntax

fn sync_command( &self, program: impl Into<String>, arguments: impl IntoIterator<Item = String>, ) -> Self::Command

impl SyncCommandViewAlg for RsyncSyntax

fn command_program<'a>(&self, command: &'a Self::Command) -> &'a str

fn command_arguments<'a>( &self, command: &'a Self::Command, ) -> impl Iterator<Item = &'a str>

impl SyncObservationAlg for RsyncSyntax

fn observed_change(&self, change: Self::Change) -> Self::Observation

fn observed_progress(&self, transferred: u64, percent: u16) -> Self::Observation

fn observed_nothing(&self) -> Self::Observation

impl SyncObservationViewAlg for RsyncSyntax

fn observation_change<'a>( &self, observation: &'a Self::Observation, ) -> Option<&'a Self::Change>

fn observation_progress( &self, observation: &Self::Observation, ) -> Option<(u64, u16)>

Auto Trait Implementations§

impl Freeze for RsyncSyntax

impl RefUnwindSafe for RsyncSyntax

impl Send for RsyncSyntax

impl Sync for RsyncSyntax

impl Unpin for RsyncSyntax

impl UnsafeUnpin for RsyncSyntax

impl UnwindSafe for RsyncSyntax

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<This> GaugeLaws<This> for This

fn gauge_laws(&self) -> Result<(), Error>

§Errors

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘwhere F: FnOnce(&Self) -> bool,

impl<This> IntoExt<This> for This

fn to<R>(self) -> Rwhere This: Into<R>,

impl<This> IntoIteratorExt<This> for This

fn try_collect_vec<T, E>(self) -> Result<Vec<T>, E>where This: Iterator<Item = Result<T, E>>,

fn collect_exact<T>(self, n: usize) -> Option<Vec<T>>where This: Iterator<Item = T>,

fn try_unzip<A, B, E>(self) -> Result<(Vec<A>, Vec<B>), E>where This: IntoIterator<Item = Result<(A, B), E>>,

impl<This> RsyncEndpointExt<This> for Thiswhere This: RsyncEndpointAlg + RsyncEndpointViewAlg,

fn read_endpoint(&self, input: &str) -> <This as RsyncSorts>::Endpoint

fn read_transfer( &self, line: &str, ) -> Option<(<This as RsyncSorts>::Endpoint, <This as RsyncSorts>::Endpoint)>

fn endpoint_remote(&self, endpoint: &<This as RsyncSorts>::Endpoint) -> bool

fn endpoint_text(&self, endpoint: &<This as RsyncSorts>::Endpoint) -> String

fn endpoint_name<'a>( &self, endpoint: &'a <This as RsyncSorts>::Endpoint, ) -> &'a str

Struct RsyncSyntax

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

fn to<R>(self) -> R
where This: Into<R>,

fn try_collect_vec<T, E>(self) -> Result<Vec<T>, E>
where This: Iterator<Item = Result<T, E>>,

fn collect_exact<T>(self, n: usize) -> Option<Vec<T>>
where This: Iterator<Item = T>,

fn try_unzip<A, B, E>(self) -> Result<(Vec<A>, Vec<B>), E>
where This: IntoIterator<Item = Result<(A, B), E>>,

impl<This> RsyncEndpointExt<This> for This
where This: RsyncEndpointAlg + RsyncEndpointViewAlg,

impl<This> SyncCommandExt<This> for This
where This: SyncCommandAlg + SyncCommandViewAlg + RsyncEndpointAlg + RsyncEndpointViewAlg,

impl<This> SyncReadExt<This> for This
where This: SyncChangeAlg + SyncObservationAlg,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,