Struct MigratorBuilder

Source
pub struct MigratorBuilder<P, T, FRO, FRN, FWO, FWN>
where P: Send + Sync, T: Send + Sync, FRO: Fn(&P) -> BoxFuture<'_, Result<T, String>> + Sync + Send, FRN: Fn(&P) -> BoxFuture<'_, Result<T, String>> + Sync + Send, FWO: Fn(&P) -> BoxFuture<'_, Result<T, String>> + Sync + Send, FWN: Fn(&P) -> BoxFuture<'_, Result<T, String>> + Sync + Send,
{ /* private fields */ }
Expand description

The migration builder is used to configure and construct an instance of a Migrator. This migrator can be used to perform LaunchDarkly assisted technology migrations through the use of migration-based feature flags.

Implementations§

Source§

impl<P, T, FRO, FRN, FWO, FWN> MigratorBuilder<P, T, FRO, FRN, FWO, FWN>
where P: Send + Sync, T: Send + Sync, FRO: Fn(&P) -> BoxFuture<'_, Result<T, String>> + Sync + Send, FRN: Fn(&P) -> BoxFuture<'_, Result<T, String>> + Sync + Send, FWO: Fn(&P) -> BoxFuture<'_, Result<T, String>> + Sync + Send, FWN: Fn(&P) -> BoxFuture<'_, Result<T, String>> + Sync + Send,

Source

pub fn new(client: Arc<Client>) -> Self

Create a new migrator builder instance with the provided client.

Source

pub fn read_execution_order(self, order: ExecutionOrder) -> Self

The read execution order influences the concurrency and execution order for read operations involving multiple origins.

Source

pub fn track_latency(self, measure: bool) -> Self

Enable or disable latency tracking for migration operations. This latency information can be sent upstream to LaunchDarkly to enhance migration visibility.

Source

pub fn track_errors(self, measure: bool) -> Self

Enable or disable error tracking for migration operations. This error information can be sent upstream to LaunchDarkly to enhance migration visibility.

Source

pub fn read( self, old: FRO, new: FRN, compare: Option<fn(&T, &T) -> bool>, ) -> Self

Read can be used to configure the migration-read behavior of the resulting Migrator instance.

Users are required to provide two different read methods – one to read from the old migration origin, and one to read from the new origin. Additionally, users can opt-in to consistency tracking by providing a comparison function.

Depending on the migration stage, one or both of these read methods may be called.

Source

pub fn write(self, old: FWO, new: FWN) -> Self

Write can be used to configure the migration-write behavior of the resulting crate::Migrator instance.

Users are required to provide two different write methods – one to write to the old migration origin, and one to write to the new origin. Not every stage requires

Depending on the migration stage, one or both of these write methods may be called.

Source

pub fn build(self) -> Result<Migrator<P, T, FRO, FRN, FWO, FWN>, String>

Build constructs a crate::Migrator instance to support migration-based reads and writes. A string describing any failure conditions will be returned if the build fails.

Auto Trait Implementations§

§

impl<P, T, FRO, FRN, FWO, FWN> Freeze for MigratorBuilder<P, T, FRO, FRN, FWO, FWN>
where FRO: Freeze, FRN: Freeze, FWO: Freeze, FWN: Freeze,

§

impl<P, T, FRO, FRN, FWO, FWN> !RefUnwindSafe for MigratorBuilder<P, T, FRO, FRN, FWO, FWN>

§

impl<P, T, FRO, FRN, FWO, FWN> Send for MigratorBuilder<P, T, FRO, FRN, FWO, FWN>

§

impl<P, T, FRO, FRN, FWO, FWN> Sync for MigratorBuilder<P, T, FRO, FRN, FWO, FWN>

§

impl<P, T, FRO, FRN, FWO, FWN> Unpin for MigratorBuilder<P, T, FRO, FRN, FWO, FWN>
where FRO: Unpin, FRN: Unpin, FWO: Unpin, FWN: Unpin, P: Unpin,

§

impl<P, T, FRO, FRN, FWO, FWN> !UnwindSafe for MigratorBuilder<P, T, FRO, FRN, FWO, FWN>

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

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

Source§

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

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

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

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

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 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<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

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

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

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

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more