logos-blockchain/logos-blockchain-testing
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-testing.git synced 2026-03-31 08:13:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add semantic existing-cluster constructors

Browse Source
This commit is contained in:
andrussal 2026-03-08 14:22:09 +01:00
parent fbede7f535
commit ad288e7421
4 changed files with 16 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
testing-framework/core/src/scenario/runtime/orchestration/source_orchestration_plan.rs
View File

@ -73,8 +73,11 @@ mod tests {
#[test]
fn attached_sources_are_planned() {
let sources = ScenarioSources::default()
.with_attach(ExistingCluster::compose(vec!["node-0".to_string()]));
let sources =
ScenarioSources::default().with_attach(ExistingCluster::for_compose_services(
"test-project".to_string(),
vec!["node-0".to_string()],
));
let plan = SourceOrchestrationPlan::try_from_sources(&sources)
.expect("attached sources should build a source orchestration plan");

16
testing-framework/core/src/scenario/sources/model.rs
View File

@ -18,8 +18,7 @@ enum ExistingClusterKind {
impl ExistingCluster {
#[must_use]
#[doc(hidden)]
pub fn k8s(label_selector: String) -> Self {
pub fn for_k8s_selector(label_selector: String) -> Self {
Self {
kind: ExistingClusterKind::K8s {
namespace: None,
@ -29,8 +28,7 @@ impl ExistingCluster {
}
#[must_use]
#[doc(hidden)]
pub fn k8s_in_namespace(label_selector: String, namespace: String) -> Self {
pub fn for_k8s_selector_in_namespace(namespace: String, label_selector: String) -> Self {
Self {
kind: ExistingClusterKind::K8s {
namespace: Some(namespace),
@ -40,19 +38,17 @@ impl ExistingCluster {
}
#[must_use]
#[doc(hidden)]
pub fn compose(services: Vec<String>) -> Self {
pub fn for_compose_project(project: String) -> Self {
Self {
kind: ExistingClusterKind::Compose {
project: None,
services,
project: Some(project),
services: Vec::new(),
},
}
}
#[must_use]
#[doc(hidden)]
pub fn compose_in_project(services: Vec<String>, project: String) -> Self {
pub fn for_compose_services(project: String, services: Vec<String>) -> Self {
Self {
kind: ExistingClusterKind::Compose {
project: Some(project),

7
testing-framework/deployers/compose/src/deployer/mod.rs
View File

@ -66,8 +66,7 @@ impl ComposeDeploymentMetadata {
.project_name()
.ok_or(ComposeMetadataError::MissingProjectName)?;
Ok(ExistingCluster::compose_in_project(
Vec::new(),
Ok(ExistingCluster::for_compose_project(
project_name.to_owned(),
))
}
@ -81,9 +80,9 @@ impl ComposeDeploymentMetadata {
.project_name()
.ok_or(ComposeMetadataError::MissingProjectName)?;
Ok(ExistingCluster::compose_in_project(
services,
Ok(ExistingCluster::for_compose_services(
project_name.to_owned(),
services,
))
}

4
testing-framework/deployers/k8s/src/deployer/mod.rs
View File

@ -53,9 +53,9 @@ impl K8sDeploymentMetadata {
.label_selector()
.ok_or(K8sMetadataError::MissingLabelSelector)?;
Ok(ExistingCluster::k8s_in_namespace(
label_selector.to_owned(),
Ok(ExistingCluster::for_k8s_selector_in_namespace(
namespace.to_owned(),
label_selector.to_owned(),
))
}