Struct TaskDescriptor 

pub struct TaskDescriptor {

    pub name: &'static str,
    pub invoke: fn(Box<dyn ExecutionContext>, Value) -> Pin<Box<dyn Future<Output = Result<(), BosonError>> + Send>>,
    pub signature_json: &'static str,
    pub signature_hash: u64,
    pub default_priority: i32,
    pub default_pool: &'static str,
    pub default_retry_max_attempts: u32,
    pub default_retry_base_delay_ms: u64,
    pub default_retry_backoff_multiplier: f64,
    pub default_retry_max_delay_ms: u64,
    pub default_rate_max_in_flight: u32,
    pub default_rate_max_enqueue_per_second: u32,
    pub default_idempotency_mode: Option<IdempotencyMode>,
}

Descriptor for a registered task.

Registration defaults flow into TaskConfig on first enqueue. Use TaskDescriptor::with_defaults to set retry, rate, priority, and pool in one call.

Signature versioning

• signature_json — JSON schema string describing task parameters (convention for tooling; Boson does not validate against it at runtime).
• signature_hash — hash of the parameter schema/version. Stored on each Job at enqueue; if the registered task’s hash changes while a job is still active, dispatch returns BosonError::SignatureMismatch. Bump signature_hash when you change parameter shape incompatibly.

Fields

name: &'static str

Unique task name (registry key and enqueue target).

invoke: fn(Box<dyn ExecutionContext>, Value) -> Pin<Box<dyn Future<Output = Result<(), BosonError>> + Send>>

Function to invoke the task.

signature_json: &'static str

JSON schema string for parameters (documentation / tooling; not validated at runtime).

signature_hash: u64

Version hash checked against enqueued jobs; change when parameters change incompatibly.

default_priority: i32

Default priority (lower = higher priority).

default_pool: &'static str

Default pool name for worker assignment.

default_retry_max_attempts: u32

Default retry max attempts (see RetryPolicy::max_attempts).

default_retry_base_delay_ms: u64

Default retry base delay ms (see RetryPolicy::base_delay_ms).

default_retry_backoff_multiplier: f64

Default retry backoff multiplier (see RetryPolicy::backoff_multiplier).

default_retry_max_delay_ms: u64

Default retry max delay ms (see RetryPolicy::max_delay_ms).

default_rate_max_in_flight: u32

Default max in-flight jobs (see RateLimitPolicy::max_in_flight; 0 = unlimited).

default_rate_max_enqueue_per_second: u32

Default max enqueues per second (see RateLimitPolicy::max_enqueue_per_second; 0 = unlimited).

default_idempotency_mode: Option<IdempotencyMode>

Per-task idempotency override (None = inherit runtime default).

Implementations

impl TaskDescriptor

pub const fn new( name: &'static str, invoke: fn(Box<dyn ExecutionContext>, Value) -> Pin<Box<dyn Future<Output = Result<(), BosonError>> + Send>>, ) -> TaskDescriptor

Minimal descriptor for tests (signature_json "{}", signature_hash 0).

pub const fn with_defaults( name: &'static str, invoke: fn(Box<dyn ExecutionContext>, Value) -> Pin<Box<dyn Future<Output = Result<(), BosonError>> + Send>>, signature_json: &'static str, signature_hash: u64, defaults: TaskDefaults, ) -> TaskDescriptor

Descriptor with grouped policy defaults.

pub const fn with_policy( name: &'static str, invoke: fn(Box<dyn ExecutionContext>, Value) -> Pin<Box<dyn Future<Output = Result<(), BosonError>> + Send>>, signature_json: &'static str, signature_hash: u64, priority: i32, pool: &'static str, max_attempts: u32, base_delay_ms: u64, backoff_multiplier: f64, max_delay_ms: u64, max_in_flight: u32, max_enqueue_per_second: u32, idempotency_mode: Option<IdempotencyMode>, ) -> TaskDescriptor

Descriptor with explicit per-field policy defaults.

Used by the #[task] attribute when policy fields are set on the handler. Prefer Self::with_defaults for manual registration in tests.

pub fn to_task_config(&self) -> TaskConfig

Materialize descriptor defaults into a TaskConfig.

Trait Implementations

impl Clone for TaskDescriptor

fn clone(&self) -> TaskDescriptor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Collect for TaskDescriptor

impl Copy for TaskDescriptor

impl Debug for TaskDescriptor

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

Formats the value using the given formatter.

impl Registrable for TaskDescriptor

fn registry_key(&self) -> &str

Return the unique lookup key used by the registry.