gestalt-sdk 0.0.1-alpha.25

Rust SDK scaffolding and generated protocol bindings for Gestalt executable providers
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
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

// Code generated by sdkgen. DO NOT EDIT.

//! Transport-neutral unary call contract for generated public clients.

use std::future::Future;

use prost::Message;

use crate::public::generated::metadata::Method;
use crate::public::generated::rpc_support::GestaltError;

/// Performs one unary public App call.
pub trait UnaryTransport: Send + Sync {
    fn unary<Req, Resp>(
        &self,
        method: &Method,
        request: &Req,
        response: &mut Resp,
    ) -> impl Future<Output = Result<(), GestaltError>> + Send
    where
        Req: Message + Clone + Send + Sync + 'static,
        Resp: Message + Default + Send + 'static;
}

/// Performs one unary public App call synchronously. REST methods use
/// SyncRestTransport; gRPC-only methods use SyncGrpcTransport.
pub trait SyncUnaryTransport: Send + Sync {
    fn unary<Req, Resp>(
        &self,
        method: &Method,
        request: &Req,
        response: &mut Resp,
    ) -> Result<(), GestaltError>
    where
        Req: Message + Clone + Send + Sync + 'static,
        Resp: Message + Default + Send + 'static;
}

/// Marker for transports that can call gRPC-only public methods.
pub trait GrpcCapable: UnaryTransport {}

/// Marker for sync transports that can call gRPC-only public methods.
pub trait SyncGrpcCapable: SyncUnaryTransport {}

/// A streaming frame iterator returned by [ServerStreamingTransport::server_stream].
/// 'recv' decodes one frame and returns it; 'None' ends the stream. Callers
/// should drop the handle to release transport resources.
pub trait ServerStreamRecv<Resp: Message + Default + Send + 'static>: Send {
    fn recv(
        &mut self,
    ) -> std::pin::Pin<Box<dyn Future<Output = Result<Option<Resp>, GestaltError>> + Send + '_>>;
}

/// Performs one server-streaming public App call. The transport returns a
/// frame iterator whose 'recv' yields decoded response messages.
pub trait ServerStreamingTransport: Send + Sync {
    fn server_stream<Req, Resp>(
        &self,
        method: &Method,
        request: &Req,
    ) -> impl Future<Output = Result<Box<dyn ServerStreamRecv<Resp>>, GestaltError>> + Send
    where
        Req: Message + Clone + Send + Sync + 'static,
        Resp: Message + Default + Send + 'static;
}

/// Performs one server-streaming public App call synchronously.
pub trait SyncServerStreamingTransport: Send + Sync {
    fn server_stream<Req, Resp>(
        &self,
        method: &Method,
        request: &Req,
    ) -> Result<Box<dyn ServerStreamRecv<Resp>>, GestaltError>
    where
        Req: Message + Clone + Send + Sync + 'static,
        Resp: Message + Default + Send + 'static;
}