samsa 0.1.8

Rust-native Kafka/Redpanda protocol and client implementation.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use crate::prelude::redpanda::adminapi::EnvironmentVariable;
use crate::redpanda::adminapi::PartitionTransformStatus;
use serde_derive::{Deserialize, Serialize};

#[derive(Debug, Default, Deserialize, Serialize)]
pub struct TransformMetadataIn {
    pub name: String,
    pub input_topic: String,
    pub output_topics: Vec<String>,
    pub environment: Vec<EnvironmentVariable>,
}

#[derive(Debug, Default, Deserialize, Serialize)]
pub struct TransformMetadataOut {
    pub name: String,
    pub input_topic: String,
    pub output_topics: Vec<String>,
    pub status: Vec<PartitionTransformStatus>,
}