Struct IoArgoprojEventsV1alpha1KafkaTrigger 

pub struct IoArgoprojEventsV1alpha1KafkaTrigger {
    pub compress: Option<bool>,
    pub flush_frequency: Option<i64>,
    pub parameters: Vec<IoArgoprojEventsV1alpha1TriggerParameter>,
    pub partition: Option<i64>,
    pub partitioning_key: Option<String>,
    pub payload: Vec<IoArgoprojEventsV1alpha1TriggerParameter>,
    pub required_acks: Option<i64>,
    pub sasl: Option<IoArgoprojEventsV1alpha1SaslConfig>,
    pub tls: Option<IoArgoprojEventsV1alpha1TlsConfig>,
    pub topic: Option<String>,
    pub url: Option<String>,
    pub version: Option<String>,
}

KafkaTrigger refers to the specification of the Kafka trigger.

Fields

compress: Option<bool>

flush_frequency: Option<i64>

parameters: Vec<IoArgoprojEventsV1alpha1TriggerParameter>

Parameters is the list of parameters that is applied to resolved Kafka trigger object.

partition: Option<i64>

Partition to write data to.

partitioning_key: Option<String>

The partitioning key for the messages put on the Kafka topic. Defaults to broker url. +optional.

payload: Vec<IoArgoprojEventsV1alpha1TriggerParameter>

Payload is the list of key-value extracted from an event payload to construct the request payload.

required_acks: Option<i64>

RequiredAcks used in producer to tell the broker how many replica acknowledgements Defaults to 1 (Only wait for the leader to ack). +optional.

sasl: Option<IoArgoprojEventsV1alpha1SaslConfig>

tls: Option<IoArgoprojEventsV1alpha1TlsConfig>

topic: Option<String>

url: Option<String>

URL of the Kafka broker, multiple URLs separated by comma.

version: Option<String>

Trait Implementations

impl Clone for IoArgoprojEventsV1alpha1KafkaTrigger

fn clone(&self) -> IoArgoprojEventsV1alpha1KafkaTrigger

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IoArgoprojEventsV1alpha1KafkaTrigger

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for IoArgoprojEventsV1alpha1KafkaTrigger

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<&IoArgoprojEventsV1alpha1KafkaTrigger> for IoArgoprojEventsV1alpha1KafkaTrigger

fn from(value: &IoArgoprojEventsV1alpha1KafkaTrigger) -> Self

Converts to this type from the input type.

impl Serialize for IoArgoprojEventsV1alpha1KafkaTrigger

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

where __S: Serializer,

Serialize this value into the given Serde serializer.