Skip to main content

LockRequestBuilder

Struct LockRequestBuilder 

Source
pub struct LockRequestBuilder<'a, S: State = Empty> { /* private fields */ }
Expand description

Use builder syntax to set the inputs and finish with build().

Implementations§

Source§

impl<'a, S: State> LockRequestBuilder<'a, S>

Source

pub fn build(self) -> LockRequest<'a>
where S: IsComplete,

Finish building and return the requested object

Source

pub fn key(self, value: &'a str) -> LockRequestBuilder<'a, SetKey<S>>
where S::Key: IsUnset,

Required.

The key to use for locking.

Source

pub fn session_id( self, value: &'a str, ) -> LockRequestBuilder<'a, SetSessionId<S>>
where S::SessionId: IsUnset,

Optional (Some / Option setters). Default: <&'a str as Default>::default().

The name of the session to use.

Source

pub fn maybe_session_id( self, value: Option<&'a str>, ) -> LockRequestBuilder<'a, SetSessionId<S>>
where S::SessionId: IsUnset,

Optional (Some / Option setters). Default: <&'a str as Default>::default().

The name of the session to use.

Source

pub fn namespace( self, value: &'a str, ) -> LockRequestBuilder<'a, SetNamespace<S>>
where S::Namespace: IsUnset,

Optional (Some / Option setters). Default: <&'a str as Default>::default().

Specifies the namespace to use. If not provided, the namespace will be inferred from the request’s ACL token, or will default to the default namespace. This is specified as part of the URL as a query parameter. Added in Consul 1.7.0.

Source

pub fn maybe_namespace( self, value: Option<&'a str>, ) -> LockRequestBuilder<'a, SetNamespace<S>>
where S::Namespace: IsUnset,

Optional (Some / Option setters). Default: <&'a str as Default>::default().

Specifies the namespace to use. If not provided, the namespace will be inferred from the request’s ACL token, or will default to the default namespace. This is specified as part of the URL as a query parameter. Added in Consul 1.7.0.

Source

pub fn datacenter( self, value: &'a str, ) -> LockRequestBuilder<'a, SetDatacenter<S>>
where S::Datacenter: IsUnset,

Optional (Some / Option setters). Default: <&'a str as Default>::default().

Specifies the datacenter to query. This will default to the datacenter of the agent being queried. This is specified as part of the URL as a query parameter.

Source

pub fn maybe_datacenter( self, value: Option<&'a str>, ) -> LockRequestBuilder<'a, SetDatacenter<S>>
where S::Datacenter: IsUnset,

Optional (Some / Option setters). Default: <&'a str as Default>::default().

Specifies the datacenter to query. This will default to the datacenter of the agent being queried. This is specified as part of the URL as a query parameter.

Source

pub fn timeout(self, value: Duration) -> LockRequestBuilder<'a, SetTimeout<S>>
where S::Timeout: IsUnset,

Optional (Some / Option setters). Default: Duration::from_secs(10).

Specifies the duration of a session (between 10s and 86400s). If provided, the session is invalidated if it is not renewed before the TTL expires. The lowest practical TTL should be used to keep the number of managed sessions low. When locks are forcibly expired, such as when following the leader election pattern in an application, sessions may not be reaped for up to double this TTL, so long TTL values (> 1 hour) should be avoided. Defaults to 10 seconds.

Source

pub fn maybe_timeout( self, value: Option<Duration>, ) -> LockRequestBuilder<'a, SetTimeout<S>>
where S::Timeout: IsUnset,

Optional (Some / Option setters). Default: Duration::from_secs(10).

Specifies the duration of a session (between 10s and 86400s). If provided, the session is invalidated if it is not renewed before the TTL expires. The lowest practical TTL should be used to keep the number of managed sessions low. When locks are forcibly expired, such as when following the leader election pattern in an application, sessions may not be reaped for up to double this TTL, so long TTL values (> 1 hour) should be avoided. Defaults to 10 seconds.

Source

pub fn behavior( self, value: LockExpirationBehavior, ) -> LockRequestBuilder<'a, SetBehavior<S>>
where S::Behavior: IsUnset,

Optional (Some / Option setters). Default: <LockExpirationBehavior as Default>::default().

Controls the behavior to take when a session is invalidated. See also LockExpirationBehavior

Source

pub fn maybe_behavior( self, value: Option<LockExpirationBehavior>, ) -> LockRequestBuilder<'a, SetBehavior<S>>
where S::Behavior: IsUnset,

Optional (Some / Option setters). Default: <LockExpirationBehavior as Default>::default().

Controls the behavior to take when a session is invalidated. See also LockExpirationBehavior

Source

pub fn lock_delay( self, value: Duration, ) -> LockRequestBuilder<'a, SetLockDelay<S>>
where S::LockDelay: IsUnset,

Optional (Some / Option setters). Default: Duration::from_secs(1).

Specifies the duration for the lock delay. Defaults to 1 second.

Source

pub fn maybe_lock_delay( self, value: Option<Duration>, ) -> LockRequestBuilder<'a, SetLockDelay<S>>
where S::LockDelay: IsUnset,

Optional (Some / Option setters). Default: Duration::from_secs(1).

Specifies the duration for the lock delay. Defaults to 1 second.

Auto Trait Implementations§

§

impl<'a, S> Freeze for LockRequestBuilder<'a, S>

§

impl<'a, S> RefUnwindSafe for LockRequestBuilder<'a, S>

§

impl<'a, S> Send for LockRequestBuilder<'a, S>

§

impl<'a, S> Sync for LockRequestBuilder<'a, S>

§

impl<'a, S> Unpin for LockRequestBuilder<'a, S>

§

impl<'a, S> UnsafeUnpin for LockRequestBuilder<'a, S>

§

impl<'a, S> UnwindSafe for LockRequestBuilder<'a, S>

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> SendSyncUnwindSafe for T
where T: Send + Sync + UnwindSafe + ?Sized,

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<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