Struct fiberplane_models::proxies::ServerMessage

#[non_exhaustive]
pub struct ServerMessage {
    pub op_id: Base64Uuid,
    pub data_source_name: Name,
    pub protocol_version: u8,
    pub payload: ServerMessagePayload,
}

Messages sent to the Proxy

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

op_id: Base64Uuid

data_source_name: Name

protocol_version: u8

payload: ServerMessagePayload

Implementations

impl ServerMessage

pub fn builder() -> ServerMessageBuilder<((), (), (), ())>

Create a builder for building ServerMessage. On the builder, call .op_id(...), .data_source_name(...), .protocol_version(...), .payload(...) to set the values of the fields. Finally, call .build() to create the instance of ServerMessage.

impl ServerMessage

pub fn deserialize_msgpack( input: impl AsRef<[u8]> ) -> Result<ServerMessage, Error>

pub fn serialize_msgpack(&self) -> Vec<u8>

pub fn op_id(&self) -> Option<Base64Uuid>

pub fn new_invoke_proxy_request( data: Vec<u8>, data_source_name: Name, protocol_version: u8, op_id: Base64Uuid ) -> Self

pub fn new_create_cells_request( data: Blob, query_type: String, data_source_name: Name, protocol_version: u8, op_id: Base64Uuid ) -> Self

pub fn new_extract_data_request( data: Blob, mime_type: String, query: Option<String>, data_source_name: Name, protocol_version: u8, op_id: Base64Uuid ) -> Self

pub fn new_get_config_schema_request( data_source_name: Name, protocol_version: u8, op_id: Base64Uuid ) -> Self

pub fn new_get_supported_query_types_request( config: ProviderConfig, data_source_name: Name, protocol_version: u8, op_id: Base64Uuid ) -> Self

Trait Implementations

impl Debug for ServerMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ServerMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ServerMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.