fluvio-controlplane 0.6.0

Fluvio control plane API
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87

#![allow(clippy::assign_op_pattern)]

//!
//! # Register SPU
//!
//! SPU sends Register message to the SC to ask permission to join the cluster.
//! SC matches spu-id, token-name and token-secret to ensure this SPU can be authorized.
//!
//! Authorization result:
//!     * FlvErrorCode::None - for success
//!     * FLVErrorCode::SpuNotAuthorized - for error
//!
//! In subsequent releases, Register SPU will carry additional credentials for mTLS
//!
use dataplane::api::Request;
use dataplane::ErrorCode;
use dataplane::derive::Decode;
use dataplane::derive::Encode;
use fluvio_types::SpuId;

use crate::InternalScKey;

// -----------------------------------
// Data Structures
// -----------------------------------

#[derive(Decode, Encode, Debug, Default)]
pub struct RegisterSpuRequest {
    spu: SpuId,
}

impl Request for RegisterSpuRequest {
    const API_KEY: u16 = InternalScKey::RegisterSpu as u16;
    type Response = RegisterSpuResponse;
}

#[derive(Decode, Encode, Default, Debug)]
pub struct RegisterSpuResponse {
    error_code: ErrorCode,
    error_message: Option<String>,
}

// -----------------------------------
// RegisterSpuRequest
// -----------------------------------

impl RegisterSpuRequest {
    pub fn new(spu: SpuId) -> Self {
        Self { spu }
    }

    pub fn spu(&self) -> SpuId {
        self.spu
    }
}

// -----------------------------------
// RegisterSpuResponse
// -----------------------------------

impl RegisterSpuResponse {
    pub fn ok() -> Self {
        RegisterSpuResponse {
            error_code: ErrorCode::None,
            error_message: None,
        }
    }

    pub fn failed_registeration() -> Self {
        RegisterSpuResponse {
            error_code: ErrorCode::SpuRegisterationFailed,
            error_message: None,
        }
    }

    pub fn is_error(&self) -> bool {
        self.error_code.is_error()
    }

    pub fn error_message(&self) -> String {
        if let Some(ref err_msg) = &self.error_message {
            err_msg.clone()
        } else {
            self.error_code.to_sentence()
        }
    }
}