pub struct Reassignment {
pub update_id: String,
pub command_id: String,
pub workflow_id: String,
pub offset: i64,
pub events: Vec<ReassignmentEvent>,
pub trace_context: Option<TraceContext>,
pub record_time: Option<Timestamp>,
pub synchronizer_id: String,
pub paid_traffic_cost: Option<i64>,
}Expand description
Complete view of an on-ledger reassignment.
Fields§
§update_id: StringAssigned by the server. Useful for correlating logs.
Must be a valid LedgerString (as described in value.proto).
Required
command_id: StringThe ID of the command which resulted in this reassignment. Missing for everyone except the submitting party on the submitting participant.
Must be a valid LedgerString (as described in value.proto).
Optional
workflow_id: StringThe workflow ID used in reassignment command submission. Only set if the workflow_id for the command was set.
Must be a valid LedgerString (as described in value.proto).
Optional
offset: i64The participant’s offset. The details of this field are described in community/ledger-api/README.md.
Must be a valid absolute offset (positive integer).
Required
events: Vec<ReassignmentEvent>The collection of reassignment events.
Required: must be non-empty
trace_context: Option<TraceContext>Ledger API trace context
The trace context transported in this message corresponds to the trace context supplied by the client application in a HTTP2 header of the original command submission. We typically use a header to transfer this type of information. Here we use message body, because it is used in gRPC streams which do not support per message headers. This field will be populated with the trace context contained in the original submission. If that was not provided, a unique ledger-api-server generated trace context will be used instead.
Optional
record_time: Option<Timestamp>The time at which the reassignment was recorded. The record time refers to the source/target synchronizer for an unassign/assign event respectively.
Required
synchronizer_id: StringA valid synchronizer id. Identifies the synchronizer that synchronized this Reassignment.
Required
paid_traffic_cost: Option<i64>The traffic cost that this participant node paid for the corresponding (un)assignment request.
Not set for transactions that were
- initiated by another participant
- initiated offline via the repair service
- processed before the participant started serving traffic cost on the Ledger API
- returned as part of a query filtering for a non submitting party
Optional
Implementations§
Source§impl Reassignment
impl Reassignment
Sourcepub fn paid_traffic_cost(&self) -> i64
pub fn paid_traffic_cost(&self) -> i64
Returns the value of paid_traffic_cost, or the default value if paid_traffic_cost is unset.
Trait Implementations§
Source§impl Clone for Reassignment
impl Clone for Reassignment
Source§fn clone(&self) -> Reassignment
fn clone(&self) -> Reassignment
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for Reassignment
impl Debug for Reassignment
Source§impl Default for Reassignment
impl Default for Reassignment
Source§fn default() -> Reassignment
fn default() -> Reassignment
Source§impl Message for Reassignment
impl Message for Reassignment
Source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Source§fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
Source§fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Source§fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
Source§fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Source§fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Source§fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Source§fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self. Read moreSource§fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self.Source§impl PartialEq for Reassignment
impl PartialEq for Reassignment
impl StructuralPartialEq for Reassignment
Auto Trait Implementations§
impl Freeze for Reassignment
impl RefUnwindSafe for Reassignment
impl Send for Reassignment
impl Sync for Reassignment
impl Unpin for Reassignment
impl UnsafeUnpin for Reassignment
impl UnwindSafe for Reassignment
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::RequestSource§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>
T in a tonic::Request