Struct daml_grpc::service::DamlActiveContractsService
source · [−]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
sourceimpl<'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> !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
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcepub fn borrow_mut(&mut self) -> &mut T
pub fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcepub fn into_request(self) -> Request<T>
pub fn into_request(self) -> Request<T>
Wrap the input message T in a tonic::Request
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
pub fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
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
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more