fluvio_spu_schema/server/
mirror.rs

1use fluvio_protocol::{Decoder, Encoder, api::Request};
2
3use crate::COMMON_VERSION;
4
5use super::SpuServerApiKey;
6
7/// Request to start mirror request
8/// After this, SPU to SPU will use internal mirror protocol
9/// This should be moved to Fluvio
10#[derive(Decoder, Encoder, Default, Debug)]
11pub struct StartMirrorRequest {
12    pub remote_replica: String,
13    pub remote_cluster_id: String,
14}
15
16impl Request for StartMirrorRequest {
17    const API_KEY: u16 = SpuServerApiKey::StartMirror as u16;
18    const DEFAULT_API_VERSION: i16 = COMMON_VERSION;
19    type Response = StartMirrorResponse;
20}
21
22#[derive(Decoder, Encoder, Default, Debug)]
23pub struct StartMirrorResponse;