Struct PublicManagedStream

pub struct PublicManagedStream {
    pub contract: PublicManagedStreamContract,
    pub kafka_properties: HashMap<String, String>,
    pub partitions: i64,
    pub replication_factor: i64,
}

A public stream. A stream that can be shared between different tenants, and is accessible over the MQTT protocol adapter.

JSON schema

{
 "description": "A public stream.  A stream that can be shared between different tenants, and is accessible over the MQTT protocol adapter.\n",
 "type": "object",
 "allOf": [
   {
     "$ref": "#/components/schemas/ManagedStream"
   },
   {
     "$ref": "#/components/schemas/PublicManagedStream_allOf"
   }
 ]
}

Fields

contract: PublicManagedStreamContract

kafka_properties: HashMap<String, String>

Additional Kafka properties to be set on the topic. The properties are key-value pairs. The key is the property name and the value is the property value. The following properties are allowed:

• cleanup.policy: delete|compact
• compression.type: uncompressed|zstd|lz4|snappy|gzip|producer
• delete.retention.ms: min 0
• max.message.bytes: min 1024, max 1048576 (1024x1024)
• message.timestamp.type: CreateTime|LogAppendTime
• retention.bytes min 0
• retention.ms min 3600000 (1 hour), max: 3,1536E+10 (365 days)
• segment.bytes: min 52428800 (1024x1024x50)

partitions: i64

replication_factor: i64

Trait Implementations

impl Clone for PublicManagedStream

fn clone(&self) -> PublicManagedStream

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PublicManagedStream

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PublicManagedStream

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for PublicManagedStream

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

Formats the value using the given formatter.

impl From<&PublicManagedStream> for PublicManagedStream

fn from(value: &PublicManagedStream) -> Self

Converts to this type from the input type.

impl PartialEq for PublicManagedStream

fn eq(&self, other: &PublicManagedStream) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for PublicManagedStream

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for PublicManagedStream