Struct Stream

pub struct Stream {
    pub brokers: Vec<String>,
    pub config: StreamConfig,
    pub endpoints: StreamEndpoints,
    pub id: String,
    pub key_schema: String,
    pub links: Vec<StreamLink>,
    pub name: String,
    pub partitions: usize,
    pub replication: usize,
    pub serialization: String,
    pub tags: Value,
    pub value_schema: String,
}

Fields

brokers: Vec<String>

config: StreamConfig

endpoints: StreamEndpoints

id: String

key_schema: String

links: Vec<StreamLink>

name: String

partitions: usize

replication: usize

serialization: String

tags: Value

value_schema: String

Implementations

impl Stream

pub fn value_schema_link(&self) -> Option<&StreamLink>

Trait Implementations

impl Debug for Stream

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Stream

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Stream

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

where __S: Serializer,

Serialize this value into the given Serde serializer.