// @generated by jacquard-lexicon. DO NOT EDIT. // // Lexicon: com.atproto.sync.getHostStatus // // This file was automatically generated from Lexicon schemas. // Any manual changes will be overwritten on the next regeneration. #[derive( serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq, jacquard_derive::IntoStatic )] #[serde(rename_all = "camelCase")] pub struct GetHostStatus<'a> { #[serde(borrow)] pub hostname: jacquard_common::CowStr<'a>, } pub mod get_host_status_state { pub use crate::builder_types::{Set, Unset, IsSet, IsUnset}; #[allow(unused)] use ::core::marker::PhantomData; mod sealed { pub trait Sealed {} } /// State trait tracking which required fields have been set pub trait State: sealed::Sealed { type Hostname; } /// Empty state - all required fields are unset pub struct Empty(()); impl sealed::Sealed for Empty {} impl State for Empty { type Hostname = Unset; } ///State transition - sets the `hostname` field to Set pub struct SetHostname(PhantomData S>); impl sealed::Sealed for SetHostname {} impl State for SetHostname { type Hostname = Set; } /// Marker types for field names #[allow(non_camel_case_types)] pub mod members { ///Marker type for the `hostname` field pub struct hostname(()); } } /// Builder for constructing an instance of this type pub struct GetHostStatusBuilder<'a, S: get_host_status_state::State> { _phantom_state: ::core::marker::PhantomData S>, __unsafe_private_named: (::core::option::Option>,), _phantom: ::core::marker::PhantomData<&'a ()>, } impl<'a> GetHostStatus<'a> { /// Create a new builder for this type pub fn new() -> GetHostStatusBuilder<'a, get_host_status_state::Empty> { GetHostStatusBuilder::new() } } impl<'a> GetHostStatusBuilder<'a, get_host_status_state::Empty> { /// Create a new builder with all fields unset pub fn new() -> Self { GetHostStatusBuilder { _phantom_state: ::core::marker::PhantomData, __unsafe_private_named: (None,), _phantom: ::core::marker::PhantomData, } } } impl<'a, S> GetHostStatusBuilder<'a, S> where S: get_host_status_state::State, S::Hostname: get_host_status_state::IsUnset, { /// Set the `hostname` field (required) pub fn hostname( mut self, value: impl Into>, ) -> GetHostStatusBuilder<'a, get_host_status_state::SetHostname> { self.__unsafe_private_named.0 = ::core::option::Option::Some(value.into()); GetHostStatusBuilder { _phantom_state: ::core::marker::PhantomData, __unsafe_private_named: self.__unsafe_private_named, _phantom: ::core::marker::PhantomData, } } } impl<'a, S> GetHostStatusBuilder<'a, S> where S: get_host_status_state::State, S::Hostname: get_host_status_state::IsSet, { /// Build the final struct pub fn build(self) -> GetHostStatus<'a> { GetHostStatus { hostname: self.__unsafe_private_named.0.unwrap(), } } } #[jacquard_derive::lexicon] #[derive( serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq, jacquard_derive::IntoStatic, Default )] #[serde(rename_all = "camelCase")] pub struct GetHostStatusOutput<'a> { /// Number of accounts on the server which are associated with the upstream host. Note that the upstream may actually have more accounts. #[serde(skip_serializing_if = "std::option::Option::is_none")] pub account_count: std::option::Option, #[serde(borrow)] pub hostname: jacquard_common::CowStr<'a>, /// Recent repo stream event sequence number. May be delayed from actual stream processing (eg, persisted cursor not in-memory cursor). #[serde(skip_serializing_if = "std::option::Option::is_none")] pub seq: std::option::Option, #[serde(skip_serializing_if = "std::option::Option::is_none")] #[serde(borrow)] pub status: std::option::Option>, } #[jacquard_derive::open_union] #[derive( serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq, thiserror::Error, miette::Diagnostic, jacquard_derive::IntoStatic )] #[serde(tag = "error", content = "message")] #[serde(bound(deserialize = "'de: 'a"))] pub enum GetHostStatusError<'a> { #[serde(rename = "HostNotFound")] HostNotFound(std::option::Option>), } impl core::fmt::Display for GetHostStatusError<'_> { fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result { match self { Self::HostNotFound(msg) => { write!(f, "HostNotFound")?; if let Some(msg) = msg { write!(f, ": {}", msg)?; } Ok(()) } Self::Unknown(err) => write!(f, "Unknown error: {:?}", err), } } } /// Response type for ///com.atproto.sync.getHostStatus pub struct GetHostStatusResponse; impl jacquard_common::xrpc::XrpcResp for GetHostStatusResponse { const NSID: &'static str = "com.atproto.sync.getHostStatus"; const ENCODING: &'static str = "application/json"; type Output<'de> = GetHostStatusOutput<'de>; type Err<'de> = GetHostStatusError<'de>; } impl<'a> jacquard_common::xrpc::XrpcRequest for GetHostStatus<'a> { const NSID: &'static str = "com.atproto.sync.getHostStatus"; const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Query; type Response = GetHostStatusResponse; } /// Endpoint type for ///com.atproto.sync.getHostStatus pub struct GetHostStatusRequest; impl jacquard_common::xrpc::XrpcEndpoint for GetHostStatusRequest { const PATH: &'static str = "/xrpc/com.atproto.sync.getHostStatus"; const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Query; type Request<'de> = GetHostStatus<'de>; type Response = GetHostStatusResponse; }