Module builder 

Fluent message builder API

This module provides a builder pattern for constructing Celery protocol messages with a clean, fluent API.

Example

use celers_protocol::builder::MessageBuilder;
use serde_json::json;

let message = MessageBuilder::new("tasks.add")
    .args(vec![json!(1), json!(2)])
    .priority(5)
    .queue("high-priority")
    .build()
    .unwrap();

assert_eq!(message.task_name(), "tasks.add");

Structs

MessageBuilder

Fluent builder for creating Celery messages

Enums

BuilderError

Error type for message building

Functions

delayed_task

Create a delayed task message

scheduled_task

Create a scheduled task message

task

Create a simple task message

task_with_args

Create a task message with args

Type Aliases

BuilderResult

Result type for message building