Struct ReferencedPendingPipeline 

pub struct ReferencedPendingPipeline<C> { /* private fields */ }

A pipeline of encryption operations.

Example

use cipherstash_client::encryption::{ReferencedPendingPipeline, PlaintextTarget, ScopedCipher};
use cipherstash_client::config::EnvSource;
use zerokms_protocol::cipherstash_config::column::{ColumnConfig, Index};
use zerokms_protocol::{IdentifiedBy, Name};
let zerokms = ZeroKMSConfig::builder()
    .add_source(EnvSource::default())
    .try_with_client_id("29f4c409-da51-496d-a1b8-cea9a9fd2660")?
    .try_with_client_key("e27aaa358784340a822d692a99c12692cd0...")?
    .build_with_client_key()
    .expect("failed to build config")
    .create_client();

let scoped_cipher = ScopedCipher::init(Arc::new(zerokms), Some(IdentifiedBy::Uuid( Uuid::parse_str("<keyset-id>").unwrap() ))).await?;
let mut pipeline = ReferencedPendingPipeline::new(Arc::new(scoped_cipher));

// Add a plaintext target to the pipeline
let config = ColumnConfig::build("name").add_index(Index::new_match());
pipeline
    .add_with_ref::<PlaintextTarget>(PlaintextTarget::new("hello world", config), 0)
    .expect("failed to add target");

// Or with context
let config = ColumnConfig::build("name").add_index(Index::new_match());
let target = PlaintextTarget::new("hello world", config)
    .with_context(Context::new_identity_claim("sub"));
pipeline
    .add_with_ref::<PlaintextTarget>(target, 0)
    .expect("failed to add target");

// Encrypt the pipeline
pipeline.encrypt(None, None).await.expect("failed to encrypt pipeline");

Implementations

impl<C> ReferencedPendingPipeline<C>

where C: Credentials<Token = ServiceToken>,

pub fn new(scoped_cipher: Arc<ScopedCipher<C>>) -> Self

pub fn add_with_ref<E>( &mut self, encryptable: E, reference: usize, ) -> Result<(), EncryptionError>

where for<'k> E: Encryptable<'k>, for<'k> BytesWithDescriptor: From<(<E as Encryptable<'k>>::Output, String)>,

pub fn is_empty(&self) -> bool

pub async fn encrypt( self, service_token: Option<ServiceToken>, unverified_context: Option<UnverifiedContext>, ) -> Result<EncryptedPipelineResult, EncryptionError>