pub struct NatsPublishPayload<T: serde::Serialize> {
pub stream: String,
pub subject: String,
pub data: T,
}
pub enum HandlerOutcome {
Ack,
AckAndPublish(NatsPublishPayload<serde_json::Value>),
AckAndPublishFailed(NatsPublishPayload<serde_json::Value>),
AckWithBusinessError(String), // Ticker code or relevant info
Ignore,
Error(String),
}
#[derive(Debug, Clone, PartialEq)]
pub enum SortOrder {
Ascending,
Descending,
}