Struct kumo_api_types::rebind::RebindV1Request

pub struct RebindV1Request {
    pub campaign: Option<String>,
    pub tenant: Option<String>,
    pub domain: Option<String>,
    pub routing_domain: Option<String>,
    pub reason: String,
    pub suppress_logging: bool,
    pub data: HashMap<String, String>,
    pub trigger_rebind_event: bool,
    pub always_flush: bool,
}

Describes which messages should be rebound. The criteria apply to the scheduled queue associated with a given message.

Fields

campaign: Option<String>

The campaign name to match. If omitted, any campaign will match.

tenant: Option<String>

The tenant to match. If omitted, any tenant will match.

domain: Option<String>

The domain name to match. If omitted, any domain will match.

routing_domain: Option<String>

The routing_domain name to match. If omitted, any routing_domain will match.

reason: String

Reason to log in the delivery log. Each matching message will log with an AdminRebind record unless you suppress logging.

suppress_logging: bool

If true, do not generate AdminRebind delivery logs for matching messages.

data: HashMap<String, String>

The data, a json object with string keys AND values to pass to the rebind operation

trigger_rebind_event: bool

If true, a rebind event will be triggered and passed each message and the supplied data. If false, no event will be triggered and each field in data will be applied to the msg metadata, overwriting any previous value for that key.

always_flush: bool

If true, make all matched messages immediately eligible for delivery. When false, (the default), only messages whose queue has changed will be made immediately eligible.

Trait Implementations

impl Debug for RebindV1Request

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RebindV1Request

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RebindV1Request

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<'__s> ToSchema<'__s> for RebindV1Request

fn schema() -> (&'__s str, RefOr<Schema>)

Return a tuple of name and schema or reference to a schema that can be referenced by the name or inlined directly to responses, request bodies or parameters.

fn aliases() -> Vec<(&'__s str, Schema)>

Optional set of alias schemas for the [ToSchema::schema].