Skip to main content

SecureCreateNewFilePublisher

Struct SecureCreateNewFilePublisher 

Source
pub struct SecureCreateNewFilePublisher { /* private fields */ }
Expand description

One fixed staging file and one fixed create-new destination.

Implementations§

Source§

impl SecureCreateNewFilePublisher

Source

pub async fn open( stage_directory: PathBuf, stage_name: String, destination: PathBuf, ) -> Result<Self, SecurePublicationError>

Source

pub async fn stage( &self, bytes: Vec<u8>, maximum_bytes: usize, expected: Option<PublishedFileIdentity>, ) -> Result<PublishedFileIdentity, SecurePublicationError>

Source

pub async fn stage_sensitive( &self, bytes: Vec<u8>, maximum_bytes: usize, expected: Option<PublishedFileIdentity>, ) -> Result<PublishedFileIdentity, SecurePublicationError>

Stages secret bytes and clears the caller-owned buffer before the blocking task returns.

Source

pub async fn read_stage( &self, maximum_bytes: usize, ) -> Result<Option<Vec<u8>>, SecurePublicationError>

Reopens one fixed staged file for a typed owner that will clear secret bytes after decoding.

Source

pub async fn read_published( &self, maximum_bytes: usize, ) -> Result<Option<Vec<u8>>, SecurePublicationError>

Reopens the fixed published destination for a typed owner.

Source

pub async fn remove_unpublished_stage( &self, expected: Option<PublishedFileIdentity>, ) -> Result<(), SecurePublicationError>

Removes only the exact unpublished staging inode.

Source

pub async fn publish( &self, expected: PublishedFileIdentity, ) -> Result<(), SecurePublicationError>

Source

pub async fn publish_deterministic( &self, bytes: Vec<u8>, maximum_bytes: usize, ) -> Result<PublishedFileIdentity, SecurePublicationError>

Publishes fully deterministic, non-sensitive bytes and repairs the narrow crash window after the destination link exists but before the staging link is removed.

Secret or randomly generated material must instead record the identity returned by Self::stage_sensitive in its sealed workflow journal before calling Self::publish.

Source

pub async fn verify_published( &self, expected: PublishedFileIdentity, ) -> Result<(), SecurePublicationError>

Source

pub async fn validate_destination( &self, expected: Option<PublishedFileIdentity>, required: bool, ) -> Result<(), SecurePublicationError>

Validates whether the fixed destination is absent or has the exact recorded identity.

Auto Trait Implementations§

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> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<L> LayerExt<L> for L

Source§

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

Applies the layer to a service and wraps it in Layered.
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

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