Skip to content
This repository has been archived by the owner on Nov 6, 2023. It is now read-only.

Commit

Permalink
Merge pull request #64 from thomastaylor312/feat/unified_api
Browse files Browse the repository at this point in the history
feat(*)!: Unifies all calls behind the ctl interface topics
  • Loading branch information
thomastaylor312 authored Oct 24, 2023
2 parents 13cb190 + e394b27 commit e2f3142
Show file tree
Hide file tree
Showing 6 changed files with 137 additions and 1,243 deletions.
16 changes: 16 additions & 0 deletions src/broker.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,14 @@ pub fn actor_auction_subject(topic_prefix: &Option<String>, lattice_prefix: &str
format!("{}.auction.actor", prefix(topic_prefix, lattice_prefix))
}

pub fn advertise_link(topic_prefix: &Option<String>, lattice_prefix: &str) -> String {
format!("{}.linkdefs.put", prefix(topic_prefix, lattice_prefix))
}

pub fn remove_link(topic_prefix: &Option<String>, lattice_prefix: &str) -> String {
format!("{}.linkdefs.del", prefix(topic_prefix, lattice_prefix))
}

pub fn publish_registries(topic_prefix: &Option<String>, lattice_prefix: &str) -> String {
format!("{}.registries.put", prefix(topic_prefix, lattice_prefix))
}
Expand Down Expand Up @@ -80,6 +88,14 @@ pub mod commands {
pub mod queries {
use super::prefix;

pub fn link_definitions(topic_prefix: &Option<String>, lattice_prefix: &str) -> String {
format!("{}.get.links", prefix(topic_prefix, lattice_prefix))
}

pub fn claims(topic_prefix: &Option<String>, lattice_prefix: &str) -> String {
format!("{}.get.claims", prefix(topic_prefix, lattice_prefix))
}

pub fn host_inventory(
topic_prefix: &Option<String>,
lattice_prefix: &str,
Expand Down
356 changes: 0 additions & 356 deletions src/kv/cached.rs

This file was deleted.

Loading

0 comments on commit e2f3142

Please sign in to comment.