Skip to content

Commit

Permalink
runtime: Move unseal out of runtime into its own crate
Browse files Browse the repository at this point in the history
We need `runtime` to depend on `dekaf`, and they both need `unseal`, so it needed to be moved somewhere, and there didn't seem to be anywhere good to put it other than its own crate.
  • Loading branch information
jshearer committed Jan 3, 2025
1 parent df57977 commit 4db55d9
Show file tree
Hide file tree
Showing 14 changed files with 48 additions and 4 deletions.
18 changes: 18 additions & 0 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 1 addition & 0 deletions crates/dekaf/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@ models = { path = "../models" }
ops = { path = "../ops" }
proto-flow = { path = "../proto-flow" }
proto-gazette = { path = "../proto-gazette" }
unseal = { path = "../unseal" }
simd-doc = { path = "../simd-doc" }

aes-siv = { workspace = true }
Expand Down
1 change: 1 addition & 0 deletions crates/runtime/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -35,6 +35,7 @@ proto-grpc = { path = "../proto-grpc", features = [
] }
simd-doc = { path = "../simd-doc" }
tuple = { path = "../tuple" }
unseal = { path = "../unseal" }

anyhow = { workspace = true }
bytes = { workspace = true }
Expand Down
3 changes: 2 additions & 1 deletion crates/runtime/src/capture/connector.rs
Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
use crate::{unseal, verify, LogHandler, Runtime};
use crate::{verify, LogHandler, Runtime};
use anyhow::Context;
use futures::{channel::mpsc, stream::BoxStream, FutureExt, StreamExt};
use proto_flow::{
capture::{Request, Response},
flow::capture_spec::ConnectorType,
};
use unseal;

// Start a capture connector as indicated by the `initial` Request.
// Returns a pair of Streams for sending Requests and receiving Responses.
Expand Down
3 changes: 2 additions & 1 deletion crates/runtime/src/derive/connector.rs
Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
use crate::{unseal, LogHandler, Runtime};
use crate::{LogHandler, Runtime};
use anyhow::Context;
use futures::{channel::mpsc, stream::BoxStream, FutureExt, StreamExt};
use proto_flow::{
derive::{Request, Response},
flow::collection_spec::derivation::ConnectorType,
};
use unseal;

// Start a derivation connector as indicated by the `initial` Request.
// Returns a pair of Streams for sending Requests and receiving Responses.
Expand Down
1 change: 0 additions & 1 deletion crates/runtime/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@ mod rocksdb;
mod task_service;
mod tokio_context;
mod unary;
mod unseal;
pub mod uuid;

pub use container::flow_runtime_protocol;
Expand Down
3 changes: 2 additions & 1 deletion crates/runtime/src/materialize/connector.rs
Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
use crate::{unseal, LogHandler, Runtime};
use crate::{LogHandler, Runtime};
use anyhow::{bail, Context};
use futures::{channel::mpsc, stream::BoxStream, FutureExt, StreamExt};
use proto_flow::{
flow::materialization_spec::ConnectorType,
materialize::{Request, Response},
};
use unseal;

// Start a materialization connector as indicated by the `initial` Request.
// Returns a pair of Streams for sending Requests and receiving Responses.
Expand Down
22 changes: 22 additions & 0 deletions crates/unseal/Cargo.toml
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
[package]
name = "unseal"
version.workspace = true
rust-version.workspace = true
edition.workspace = true
authors.workspace = true
homepage.workspace = true
repository.workspace = true
license.workspace = true

[dependencies]
async-process = { path = "../async-process" }
models = { path = "../models" }
locate-bin = { path = "../locate-bin" }

anyhow = { workspace = true }
serde = { workspace = true }
serde_json = { workspace = true }
zeroize = { workspace = true }
futures = { workspace = true }
tokio = { workspace = true }
insta = { workspace = true }
File renamed without changes.
File renamed without changes.
File renamed without changes.

0 comments on commit 4db55d9

Please sign in to comment.