Skip to main content

CooperationSetup

Struct CooperationSetup 

Source
pub struct CooperationSetup {
    pub identity: Arc<NodeIdentity>,
    pub runtime: String,
    pub repository: MeshRepositoryIdentity,
    pub endpoints: Vec<String>,
    pub version: String,
    pub config: CooperationConfig,
    pub trust: TrustConfig,
    pub journal_path: Option<PathBuf>,
    pub registry: Arc<MeshRegistry>,
    pub transport: Arc<dyn LinkTransport>,
    pub board: Option<Arc<PeerBoard>>,
    pub checkout: CheckoutFacts,
}
Expand description

Everything one runtime needs before it can link to another, gathered in one place so that the runtime never reaches for it later. Each field is a decision somebody else already made — the declaration’s policy, the checkout’s identity, this process’s key, the socket to speak through — and passing them in is what lets a test replace any of them without a fixture: a fake transport, an ephemeral key, a journal that never touches the disk.

use std::sync::Arc;

use majordomus_cli::mesh::config::{CooperationConfig, TrustConfig};
use majordomus_cli::mesh::cooperation::{CheckoutFacts, Cooperation, CooperationSetup};
use majordomus_cli::mesh::identity::NodeIdentity;
use majordomus_cli::mesh::link::HttpTransport;
use majordomus_cli::mesh::registry::MeshRegistry;
use majordomus_cli::mesh::repository::of_root_commits;

let setup = CooperationSetup {
    identity: Arc::new(NodeIdentity::ephemeral().unwrap()),
    runtime: "0000000000000001".into(),
    repository: of_root_commits(&["root".into()]),
    endpoints: vec!["127.0.0.1:9".into()],
    version: "doc".into(),
    config: CooperationConfig::default(),
    trust: TrustConfig::default(),
    journal_path: None,
    registry: Arc::new(MeshRegistry::new()),
    transport: Arc::new(HttpTransport),
    board: None,
    checkout: CheckoutFacts::default(),
};

let cooperation = Cooperation::new(setup).unwrap();
assert!(cooperation.runtime_key().ends_with("-0000000000000001"));

Fields§

§identity: Arc<NodeIdentity>

This node’s identity.

§runtime: String

This runtime’s slot, 16 hex.

§repository: MeshRepositoryIdentity

The repository’s mesh identity.

§endpoints: Vec<String>

Where this runtime answers.

§version: String

The executable version.

§config: CooperationConfig

The declaration’s cooperation section.

§trust: TrustConfig

The declaration’s trust section.

§journal_path: Option<PathBuf>

Where the journal persists, when anywhere.

§registry: Arc<MeshRegistry>

The discovery registry candidates come from.

§transport: Arc<dyn LinkTransport>

How link messages travel.

§board: Option<Arc<PeerBoard>>

The peer board of this process, projected into the journal every heartbeat: each attached session becomes a mesh session and each of its announcements an advisory claim, so a board announcement is visible on every linked runtime.

§checkout: CheckoutFacts

Facts about this checkout the projected sessions carry.

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
§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

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.

§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

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

Source§

type Error = Infallible

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

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

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.
§

impl<T> WithSubscriber for T

§

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
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more