picodata-pike 3.2.1

Cargo plugin for Picodata plugin development
Documentation 
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

use picotest::*;
use reqwest::blocking as req;
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize, Debug)]
pub struct User {
    name: String,
}

#[derive(Serialize, Deserialize, Debug)]
pub struct ExampleResponse {
    rpc_hello_response: String,
}

#[picotest]
fn test_cluster_handles() {
    let http_port = cluster.main().http_port;

    let resp = req::get(format!("http://127.0.0.1:{http_port}/metrics")).unwrap();
    assert!(resp.status().is_success());

    let resp = req::get(format!("http://127.0.0.1:{http_port}/hello")).unwrap();
    assert!(resp.status().is_success());
}

#[tokio::test]
#[picotest]
async fn test_rpc_handle() {
    let user_to_send = User {
        name: "Dodo".to_string(),
    };

    let response = cluster
        .main()
        .execute_rpc::<User, ExampleResponse>(
            env!("CARGO_PKG_NAME"),
            "/greetings_rpc",
            "example_service",
            env!("CARGO_PKG_VERSION"),
            &user_to_send,
        )
        .await
        .unwrap();

    assert_eq!(response.rpc_hello_response, "Hello Dodo, long time no see.");
}