pub struct DamlActiveContractsService<'a> { /* private fields */ }Expand description
Returns a stream of the active contracts on a Daml ledger.
Allows clients to initialize themselves according to a fairly recent state of the ledger without reading through all transactions that were committed since the ledger’s creation.
Getting an empty stream means that the active contracts set is empty and the client should listen to transactions
using DamlLedgerOffsetBoundary::Begin. Clients SHOULD NOT assume that the set of active contracts they receive
reflects the state at the ledger end.
Implementations§
Source§impl<'a> DamlActiveContractsService<'a>
impl<'a> DamlActiveContractsService<'a>
pub fn new( channel: Channel, ledger_id: &'a str, auth_token: Option<&'a str>, ) -> Self
Sourcepub fn with_token(self, auth_token: &'a str) -> Self
pub fn with_token(self, auth_token: &'a str) -> Self
Override the JWT token to use for this service.
Sourcepub fn with_ledger_id(self, ledger_id: &'a str) -> Self
pub fn with_ledger_id(self, ledger_id: &'a str) -> Self
Override the ledger id to use for this service.
pub async fn get_active_contracts( &self, filter: impl Into<DamlTransactionFilter> + Debug, verbose: impl Into<DamlVerbosity> + Debug, ) -> DamlResult<impl Stream<Item = DamlResult<DamlActiveContracts>>>
Trait Implementations§
Auto Trait Implementations§
impl<'a> Freeze for DamlActiveContractsService<'a>
impl<'a> !RefUnwindSafe for DamlActiveContractsService<'a>
impl<'a> Send for DamlActiveContractsService<'a>
impl<'a> Sync for DamlActiveContractsService<'a>
impl<'a> Unpin for DamlActiveContractsService<'a>
impl<'a> !UnwindSafe for DamlActiveContractsService<'a>
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
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 moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
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 moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request