Struct WorkerConfig

Source

pub struct WorkerConfig {
    pub nats_url: String,
    pub stream_name: String,
    pub consumer_name: String,
    pub subject_prefix: String,
    pub api_prefix: String,
    pub scratchpad_retention_secs: u64,
    pub nats_auth: Option<NatsAuth>,
    pub max_concurrent_jobs: Option<usize>,
}

Expand description

Configuration for the NATS connection and behavior.

NATS subjects are split across two namespaces:

subject_prefix ("nsed") — scientific deliberation protocol: tasks (nsed.{session}.task.{agent}.{action}), results, events.
api_prefix ("sphera") — product API layer: job manifests (sphera.jobs.manifest.>), ACKs, heartbeats, pings.

Fields§

§nats_url: String

NATS server URL (e.g. nats://localhost:4222).

§stream_name: String

JetStream stream name to consume from.

§consumer_name: String

Durable consumer name for task messages.

§subject_prefix: String

Subject prefix for the deliberation protocol (default: "nsed").

§api_prefix: String

Subject prefix for the product API layer (default: "sphera").

§scratchpad_retention_secs: u64

TTL for scratchpad data in seconds. Defaults to 7 days.

§nats_auth: Option<NatsAuth>

Optional NATS authentication credentials.

§max_concurrent_jobs: Option<usize>

Max jobs this agent processes concurrently. Enforced as the pull consumer’s max_ack_pending — the server won’t deliver the next task until an in-flight one is acked. None leaves it unbounded (server default). Set to 1 for agents whose jobs share mutable state (e.g. a git repo a middleware resets per job) so concurrent jobs can’t race.

Struct WorkerConfig Copy item path

Fields§

Implementations§

impl WorkerConfig

pub fn new(nats_url: String, stream_name: String, consumer_name: String) -> Self

pub fn with_subject_prefix(self, prefix: String) -> Self

pub fn with_api_prefix(self, prefix: String) -> Self

pub fn with_scratchpad_retention(self, secs: u64) -> Self

pub fn with_nats_auth(self, auth: NatsAuth) -> Self

pub fn with_max_concurrent_jobs(self, n: usize) -> Self

Trait Implementations§

impl Clone for WorkerConfig

fn clone(&self) -> WorkerConfig

fn clone_from(&mut self, source: &Self)

impl Debug for WorkerConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Auto Trait Implementations§

impl Freeze for WorkerConfig

impl RefUnwindSafe for WorkerConfig

impl Send for WorkerConfig

impl Sync for WorkerConfig

impl Unpin for WorkerConfig

impl UnsafeUnpin for WorkerConfig

impl UnwindSafe for WorkerConfig

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

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

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

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> DynClone for Twhere T: Clone,

fn __clone_box(&self, _: Private) -> *mut ()

impl<T, U> ExactFrom<T> for Uwhere U: TryFrom<T>,

fn exact_from(value: T) -> U

impl<T, U> ExactInto<U> for Twhere U: ExactFrom<T>,

fn exact_into(self) -> U

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<A, B, T> HttpServerConnExec<A, B> for Twhere B: Body,

impl<T> Instrument for T

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

fn in_current_span(self) -> Instrumented<Self> ⓘ

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘwhere F: FnOnce(&Self) -> bool,

impl<T, U> OverflowingInto<U> for Twhere U: OverflowingFrom<T>,

fn overflowing_into(self) -> (U, bool)

impl<D> OwoColorize for D

fn fg<C>(&self) -> FgColorDisplay<'_, C, Self>where C: Color,

fn bg<C>(&self) -> BgColorDisplay<'_, C, Self>where C: Color,

fn black(&self) -> FgColorDisplay<'_, Black, Self>

fn on_black(&self) -> BgColorDisplay<'_, Black, Self>

fn red(&self) -> FgColorDisplay<'_, Red, Self>

fn on_red(&self) -> BgColorDisplay<'_, Red, Self>

fn green(&self) -> FgColorDisplay<'_, Green, Self>

fn on_green(&self) -> BgColorDisplay<'_, Green, Self>

fn yellow(&self) -> FgColorDisplay<'_, Yellow, Self>

fn on_yellow(&self) -> BgColorDisplay<'_, Yellow, Self>

fn blue(&self) -> FgColorDisplay<'_, Blue, Self>

fn on_blue(&self) -> BgColorDisplay<'_, Blue, Self>

fn magenta(&self) -> FgColorDisplay<'_, Magenta, Self>

fn on_magenta(&self) -> BgColorDisplay<'_, Magenta, Self>

fn purple(&self) -> FgColorDisplay<'_, Magenta, Self>

fn on_purple(&self) -> BgColorDisplay<'_, Magenta, Self>

fn cyan(&self) -> FgColorDisplay<'_, Cyan, Self>

fn on_cyan(&self) -> BgColorDisplay<'_, Cyan, Self>

fn white(&self) -> FgColorDisplay<'_, White, Self>

fn on_white(&self) -> BgColorDisplay<'_, White, Self>

fn default_color(&self) -> FgColorDisplay<'_, Default, Self>

fn on_default_color(&self) -> BgColorDisplay<'_, Default, Self>

fn bright_black(&self) -> FgColorDisplay<'_, BrightBlack, Self>

Struct WorkerConfig

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

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,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> DynClone for T
where T: Clone,

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

impl<T, U> ExactInto<U> for T
where U: ExactFrom<T>,

impl<T> FromRef<T> for T
where T: Clone,

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,

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

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

impl<T, U> OverflowingInto<U> for T
where U: OverflowingFrom<T>,

fn fg<C>(&self) -> FgColorDisplay<'_, C, Self>
where C: Color,

fn bg<C>(&self) -> BgColorDisplay<'_, C, Self>
where C: Color,

fn color<Color>(&self, color: Color) -> FgDynColorDisplay<'_, Color, Self>
where Color: DynColor,

fn on_color<Color>(&self, color: Color) -> BgDynColorDisplay<'_, Color, Self>
where Color: DynColor,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

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

impl<T, U> RoundingInto<U> for T
where U: RoundingFrom<T>,

impl<T, U> SaturatingInto<U> for T
where U: SaturatingFrom<T>,

impl<T> ToDebugString for T
where T: Debug,

impl<T> ToOwned for T
where T: Clone,

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

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

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,