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

use crate::redpanda::adminapi::TransformMetadataIn;
use reqwest::Body;
use serde_derive::{Deserialize, Serialize};

#[derive(Debug, Deserialize, Serialize)]
pub struct Transform {
    pub metadata: TransformMetadataIn,
    pub contents: Vec<u8>,
}

impl From<Transform> for Body {
    fn from(val: Transform) -> Self {
        let mut bytes = serde_json::to_vec(&val.metadata).unwrap();
        let mut contents = val.contents.clone();
        bytes.append(&mut contents);
        Body::from(bytes)
    }
}