pub struct StateExport {
pub version: u32,
pub pipeline: String,
pub exported_at: Option<String>,
pub keys: BTreeMap<String, Value>,
}Expand description
A portable snapshot of one pipeline’s durable state — every key under its
namespace ({pipeline}::…) with its stored value, exactly as the store
holds it (exactly-once envelopes included).
Serialized as { "version": 1, "pipeline": …, "exported_at": …, "keys": {…} }.
Fields§
§version: u32Document version — STATE_EXPORT_VERSION for documents this build writes.
pipeline: StringThe pipeline whose namespace the keys belong to.
exported_at: Option<String>When the snapshot was taken (RFC 3339), informational.
keys: BTreeMap<String, Value>Every key and its stored value.
Implementations§
Source§impl StateExport
impl StateExport
Sourcepub fn new(pipeline: impl Into<String>) -> Self
pub fn new(pipeline: impl Into<String>) -> Self
A version-STATE_EXPORT_VERSION snapshot of pipeline.
Sourcepub fn from_value(value: Value) -> Result<Self, FaucetError>
pub fn from_value(value: Value) -> Result<Self, FaucetError>
Parse and validate a document. A version newer than
this build understands is refused rather than half-read.
Sourcepub fn validate(&self) -> Result<(), FaucetError>
pub fn validate(&self) -> Result<(), FaucetError>
Every key must be a valid state key inside the pipeline’s namespace.
Trait Implementations§
Source§impl Clone for StateExport
impl Clone for StateExport
Source§impl Debug for StateExport
impl Debug for StateExport
Source§impl<'de> Deserialize<'de> for StateExport
impl<'de> Deserialize<'de> for StateExport
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl PartialEq for StateExport
impl PartialEq for StateExport
Source§impl Serialize for StateExport
impl Serialize for StateExport
impl StructuralPartialEq for StateExport
Auto Trait Implementations§
impl Freeze for StateExport
impl RefUnwindSafe for StateExport
impl Send for StateExport
impl Sync for StateExport
impl Unpin for StateExport
impl UnsafeUnpin for StateExport
impl UnwindSafe for StateExport
Blanket Implementations§
impl<T> Allocation for T
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
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> 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