deeed92
zhenyi
chore(workspace): add lib/mcp to workspace, regenerate lockfile, add mcp defaults to default.yaml
deeed92
#[derive(Debug, thiserror::Error)]
pub enum QueueError {
#[error("kafka error: {0}")]
Kafka(#[from] rdkafka::error::KafkaError),
#[error("serialization error: {0}")]
Serde(#[from] serde_json::Error),
#[error("subscribe handler error: {0}")]
Handler(String),
#[error("queue is disabled")]
Disabled,
#[error("config invalid: {0}")]
Config(String),
#[error("topic name invalid: {0}")]
Topic(String),
#[error("subscribe join error: {0}")]
Join(#[from] tokio::task::JoinError),
#[error("subscribe cancelled")]
Cancelled,
}