radroots_transport.txt (86417B)
1 pub mod radroots_transport 2 pub mod radroots_transport::capability 3 pub enum radroots_transport::capability::Availability 4 pub radroots_transport::capability::Availability::Available 5 pub radroots_transport::capability::Availability::Degraded 6 pub radroots_transport::capability::Availability::Unavailable 7 impl core::convert::From<radroots_protocol::capability::v1::Availability> for radroots_transport::capability::Availability 8 pub fn radroots_transport::capability::Availability::from(radroots_protocol::capability::v1::Availability) -> Self 9 impl core::convert::From<radroots_transport::capability::Availability> for radroots_protocol::capability::v1::Availability 10 pub fn radroots_protocol::capability::v1::Availability::from(radroots_transport::capability::Availability) -> Self 11 pub enum radroots_transport::capability::Maturity 12 pub radroots_transport::capability::Maturity::Experimental 13 pub radroots_transport::capability::Maturity::Preview 14 pub radroots_transport::capability::Maturity::Stable 15 impl core::convert::From<radroots_protocol::capability::v1::Maturity> for radroots_transport::capability::Maturity 16 pub fn radroots_transport::capability::Maturity::from(radroots_protocol::capability::v1::Maturity) -> Self 17 impl core::convert::From<radroots_transport::capability::Maturity> for radroots_protocol::capability::v1::Maturity 18 pub fn radroots_protocol::capability::v1::Maturity::from(radroots_transport::capability::Maturity) -> Self 19 pub struct radroots_transport::capability::SinkCapabilities 20 impl radroots_transport::capability::SinkCapabilities 21 pub const radroots_transport::capability::SinkCapabilities::DELIVER: Self 22 pub const radroots_transport::capability::SinkCapabilities::NONE: Self 23 pub const fn radroots_transport::capability::SinkCapabilities::can_deliver(self) -> bool 24 pub const fn radroots_transport::capability::SinkCapabilities::can_gateway_forward(self) -> bool 25 pub const fn radroots_transport::capability::SinkCapabilities::can_observe_receipts(self) -> bool 26 pub const fn radroots_transport::capability::SinkCapabilities::with_gateway_forwarding(self, bool) -> Self 27 pub const fn radroots_transport::capability::SinkCapabilities::with_receipt_observation(self, bool) -> Self 28 impl core::convert::From<&radroots_protocol::capability::v1::TransportDescriptor> for radroots_transport::capability::SinkCapabilities 29 pub fn radroots_transport::capability::SinkCapabilities::from(&radroots_protocol::capability::v1::TransportDescriptor) -> Self 30 pub struct radroots_transport::capability::SourceCapabilities 31 impl radroots_transport::capability::SourceCapabilities 32 pub const radroots_transport::capability::SourceCapabilities::FETCH: Self 33 pub const radroots_transport::capability::SourceCapabilities::NONE: Self 34 pub const fn radroots_transport::capability::SourceCapabilities::can_discover(self) -> bool 35 pub const fn radroots_transport::capability::SourceCapabilities::can_fetch(self) -> bool 36 pub const fn radroots_transport::capability::SourceCapabilities::with_discovery(self, bool) -> Self 37 impl core::convert::From<&radroots_protocol::capability::v1::TransportDescriptor> for radroots_transport::capability::SourceCapabilities 38 pub fn radroots_transport::capability::SourceCapabilities::from(&radroots_protocol::capability::v1::TransportDescriptor) -> Self 39 pub mod radroots_transport::endpoint 40 pub struct radroots_transport::endpoint::EndpointUri(_) 41 impl radroots_transport::target::EndpointUri 42 pub fn radroots_transport::target::EndpointUri::as_str(&self) -> &str 43 pub fn radroots_transport::target::EndpointUri::parse(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 44 impl core::convert::AsRef<str> for radroots_transport::target::EndpointUri 45 pub fn radroots_transport::target::EndpointUri::as_ref(&self) -> &str 46 impl core::convert::TryFrom<&str> for radroots_transport::target::EndpointUri 47 pub type radroots_transport::target::EndpointUri::Error = radroots_transport::error::Error 48 pub fn radroots_transport::target::EndpointUri::try_from(&str) -> core::result::Result<Self, Self::Error> 49 impl core::fmt::Display for radroots_transport::target::EndpointUri 50 pub fn radroots_transport::target::EndpointUri::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 51 impl core::str::traits::FromStr for radroots_transport::target::EndpointUri 52 pub type radroots_transport::target::EndpointUri::Err = radroots_transport::error::Error 53 pub fn radroots_transport::target::EndpointUri::from_str(&str) -> core::result::Result<Self, Self::Err> 54 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::target::EndpointUri 55 pub fn radroots_transport::target::EndpointUri::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 56 pub struct radroots_transport::endpoint::TargetLabel(_) 57 impl radroots_transport::target::TargetLabel 58 pub fn radroots_transport::target::TargetLabel::as_str(&self) -> &str 59 pub fn radroots_transport::target::TargetLabel::parse(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 60 impl core::convert::AsRef<str> for radroots_transport::target::TargetLabel 61 pub fn radroots_transport::target::TargetLabel::as_ref(&self) -> &str 62 impl core::convert::TryFrom<&str> for radroots_transport::target::TargetLabel 63 pub type radroots_transport::target::TargetLabel::Error = radroots_transport::error::Error 64 pub fn radroots_transport::target::TargetLabel::try_from(&str) -> core::result::Result<Self, Self::Error> 65 impl core::fmt::Display for radroots_transport::target::TargetLabel 66 pub fn radroots_transport::target::TargetLabel::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 67 impl core::str::traits::FromStr for radroots_transport::target::TargetLabel 68 pub type radroots_transport::target::TargetLabel::Err = radroots_transport::error::Error 69 pub fn radroots_transport::target::TargetLabel::from_str(&str) -> core::result::Result<Self, Self::Err> 70 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::target::TargetLabel 71 pub fn radroots_transport::target::TargetLabel::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 72 pub struct radroots_transport::endpoint::TargetScope(_) 73 impl radroots_transport::target::TargetScope 74 pub fn radroots_transport::target::TargetScope::as_str(&self) -> &str 75 pub fn radroots_transport::target::TargetScope::parse(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 76 impl core::convert::AsRef<str> for radroots_transport::target::TargetScope 77 pub fn radroots_transport::target::TargetScope::as_ref(&self) -> &str 78 impl core::convert::TryFrom<&str> for radroots_transport::target::TargetScope 79 pub type radroots_transport::target::TargetScope::Error = radroots_transport::error::Error 80 pub fn radroots_transport::target::TargetScope::try_from(&str) -> core::result::Result<Self, Self::Error> 81 impl core::fmt::Display for radroots_transport::target::TargetScope 82 pub fn radroots_transport::target::TargetScope::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 83 impl core::str::traits::FromStr for radroots_transport::target::TargetScope 84 pub type radroots_transport::target::TargetScope::Err = radroots_transport::error::Error 85 pub fn radroots_transport::target::TargetScope::from_str(&str) -> core::result::Result<Self, Self::Err> 86 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::target::TargetScope 87 pub fn radroots_transport::target::TargetScope::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 88 pub const radroots_transport::endpoint::ENDPOINT_URI_MAX_BYTES: usize 89 pub const radroots_transport::endpoint::TARGET_LABEL_MAX_BYTES: usize 90 pub const radroots_transport::endpoint::TARGET_SCOPE_MAX_BYTES: usize 91 pub mod radroots_transport::error 92 pub enum radroots_transport::error::Error 93 pub radroots_transport::error::Error::DeliveryReceiptRequestIdMismatch 94 pub radroots_transport::error::Error::DeliveryReceiptTargetSetMismatch 95 pub radroots_transport::error::Error::DeliveryTargetReceiptAttemptMismatch 96 pub radroots_transport::error::Error::DeliveryTargetReceiptStatusMismatch 97 pub radroots_transport::error::Error::DuplicateDeliveryTargetReceipt 98 pub radroots_transport::error::Error::DuplicateFetchAuthor 99 pub radroots_transport::error::Error::DuplicateFetchKind 100 pub radroots_transport::error::Error::DuplicateFetchTagValue 101 pub radroots_transport::error::Error::DuplicateFetchTargetOutcome 102 pub radroots_transport::error::Error::DuplicateRequiredTargetFingerprint 103 pub radroots_transport::error::Error::DuplicateSubscriptionCheckpoint 104 pub radroots_transport::error::Error::DuplicateTargetFingerprint 105 pub radroots_transport::error::Error::EmptyDeliveryRequestId 106 pub radroots_transport::error::Error::EmptyFetchCursor 107 pub radroots_transport::error::Error::EmptyFetchRequestId 108 pub radroots_transport::error::Error::EmptyPayloadBytes 109 pub radroots_transport::error::Error::EmptyPayloadId 110 pub radroots_transport::error::Error::EmptyPayloadLabel 111 pub radroots_transport::error::Error::EmptyRequiredTargetSet 112 pub radroots_transport::error::Error::EmptySubscriptionRequestId 113 pub radroots_transport::error::Error::EmptyTargetLabel 114 pub radroots_transport::error::Error::EmptyTargetScope 115 pub radroots_transport::error::Error::EmptyTargetSet 116 pub radroots_transport::error::Error::EmptyTargetUri 117 pub radroots_transport::error::Error::EmptyTransportKind 118 pub radroots_transport::error::Error::FetchPageLimitExceeded 119 pub radroots_transport::error::Error::FetchPageRequestMismatch 120 pub radroots_transport::error::Error::FetchSelectorTooLarge 121 pub radroots_transport::error::Error::InvalidDeliveryDeadline 122 pub radroots_transport::error::Error::InvalidDeliveryOutcome 123 pub radroots_transport::error::Error::InvalidDeliveryRequestId 124 pub radroots_transport::error::Error::InvalidDeliveryTargetSelection 125 pub radroots_transport::error::Error::InvalidDeliveryTimestamp 126 pub radroots_transport::error::Error::InvalidFetchCursor 127 pub radroots_transport::error::Error::InvalidFetchDeadline 128 pub radroots_transport::error::Error::InvalidFetchLimit 129 pub radroots_transport::error::Error::InvalidFetchRequestId 130 pub radroots_transport::error::Error::InvalidFetchTagKey 131 pub radroots_transport::error::Error::InvalidFetchTagValue 132 pub radroots_transport::error::Error::InvalidFetchTimeRange 133 pub radroots_transport::error::Error::InvalidObservedAt 134 pub radroots_transport::error::Error::InvalidPayloadBytes 135 pub radroots_transport::error::Error::InvalidPayloadDigest 136 pub radroots_transport::error::Error::InvalidPayloadId 137 pub radroots_transport::error::Error::InvalidPayloadLabel 138 pub radroots_transport::error::Error::InvalidSatisfactionPolicy 139 pub radroots_transport::error::Error::InvalidSubscriptionDeadline 140 pub radroots_transport::error::Error::InvalidSubscriptionEnd 141 pub radroots_transport::error::Error::InvalidSubscriptionLimit 142 pub radroots_transport::error::Error::InvalidSubscriptionRequestId 143 pub radroots_transport::error::Error::InvalidTargetFingerprint 144 pub radroots_transport::error::Error::InvalidTargetLabel 145 pub radroots_transport::error::Error::InvalidTargetScope 146 pub radroots_transport::error::Error::InvalidTargetUri 147 pub radroots_transport::error::Error::InvalidTransportKind 148 pub radroots_transport::error::Error::MissingDeliveryTargetReceipt 149 pub radroots_transport::error::Error::PayloadDigestMismatch 150 pub radroots_transport::error::Error::RequiredTargetNotRequested 151 pub radroots_transport::error::Error::SubscriptionCheckpointSetTooLarge 152 pub radroots_transport::error::Error::SubscriptionEndLimitExceeded 153 pub radroots_transport::error::Error::SubscriptionEndRequestMismatch 154 pub radroots_transport::error::Error::SubscriptionEventCheckpointMismatch 155 pub radroots_transport::error::Error::SubscriptionUnavailable 156 pub radroots_transport::error::Error::TargetSetTooLarge 157 pub radroots_transport::error::Error::TransportOutcomeStatusMismatch 158 pub radroots_transport::error::Error::UnexpectedDeliveryTargetReceipt 159 pub radroots_transport::error::Error::UnexpectedFetchEvent 160 pub radroots_transport::error::Error::UnexpectedFetchProvenance 161 pub radroots_transport::error::Error::UnexpectedFetchTargetOutcome 162 pub radroots_transport::error::Error::UnexpectedSubscriptionCheckpoint 163 pub radroots_transport::error::Error::UnexpectedSubscriptionEvent 164 pub radroots_transport::error::Error::UnsupportedOperation 165 impl core::fmt::Display for radroots_transport::error::Error 166 pub fn radroots_transport::error::Error::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 167 pub mod radroots_transport::outcome 168 pub enum radroots_transport::outcome::DeliveryOutcomeKind 169 pub radroots_transport::outcome::DeliveryOutcomeKind::Accepted 170 pub radroots_transport::outcome::DeliveryOutcomeKind::Delivered 171 pub radroots_transport::outcome::DeliveryOutcomeKind::Failed 172 pub radroots_transport::outcome::DeliveryOutcomeKind::Rejected 173 pub radroots_transport::outcome::DeliveryOutcomeKind::Unavailable 174 pub enum radroots_transport::outcome::FetchTargetState 175 pub radroots_transport::outcome::FetchTargetState::Cancelled 176 pub radroots_transport::outcome::FetchTargetState::Complete 177 pub radroots_transport::outcome::FetchTargetState::FailedRetryable 178 pub radroots_transport::outcome::FetchTargetState::FailedTerminal 179 pub radroots_transport::outcome::FetchTargetState::Partial 180 pub radroots_transport::outcome::FetchTargetState::Unavailable 181 impl radroots_transport::outcome::FetchTargetState 182 pub const fn radroots_transport::outcome::FetchTargetState::is_retryable(self) -> bool 183 pub const fn radroots_transport::outcome::FetchTargetState::is_terminal(self) -> bool 184 pub enum radroots_transport::outcome::Retryability 185 pub radroots_transport::outcome::Retryability::NotApplicable 186 pub radroots_transport::outcome::Retryability::Retryable 187 pub radroots_transport::outcome::Retryability::Terminal 188 pub struct radroots_transport::outcome::DeliveryOutcome 189 impl radroots_transport::outcome::DeliveryOutcome 190 pub const fn radroots_transport::outcome::DeliveryOutcome::accepted() -> Self 191 pub fn radroots_transport::outcome::DeliveryOutcome::code(&self) -> core::option::Option<&str> 192 pub const fn radroots_transport::outcome::DeliveryOutcome::delivered() -> Self 193 pub const fn radroots_transport::outcome::DeliveryOutcome::failed(radroots_transport::outcome::Retryability) -> core::result::Result<Self, radroots_transport::error::Error> 194 pub const fn radroots_transport::outcome::DeliveryOutcome::is_retryable(&self) -> bool 195 pub const fn radroots_transport::outcome::DeliveryOutcome::is_terminal(&self) -> bool 196 pub const fn radroots_transport::outcome::DeliveryOutcome::kind(&self) -> radroots_transport::outcome::DeliveryOutcomeKind 197 pub fn radroots_transport::outcome::DeliveryOutcome::message(&self) -> core::option::Option<&str> 198 pub const fn radroots_transport::outcome::DeliveryOutcome::rejected() -> Self 199 pub const fn radroots_transport::outcome::DeliveryOutcome::retryability(&self) -> radroots_transport::outcome::Retryability 200 pub const fn radroots_transport::outcome::DeliveryOutcome::satisfies(&self, radroots_transport::policy::SatisfactionClass) -> bool 201 pub const fn radroots_transport::outcome::DeliveryOutcome::unavailable() -> Self 202 pub fn radroots_transport::outcome::DeliveryOutcome::with_detail(self, impl core::convert::Into<alloc::string::String>, impl core::convert::Into<alloc::string::String>) -> core::result::Result<Self, radroots_transport::error::Error> 203 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::outcome::DeliveryOutcome 204 pub fn radroots_transport::outcome::DeliveryOutcome::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 205 pub struct radroots_transport::outcome::FetchTargetOutcome 206 impl radroots_transport::outcome::FetchTargetOutcome 207 pub fn radroots_transport::outcome::FetchTargetOutcome::message(&self) -> core::option::Option<&str> 208 pub const fn radroots_transport::outcome::FetchTargetOutcome::new(radroots_transport::target::TargetFingerprint, radroots_transport::outcome::FetchTargetState) -> Self 209 pub const fn radroots_transport::outcome::FetchTargetOutcome::state(&self) -> radroots_transport::outcome::FetchTargetState 210 pub const fn radroots_transport::outcome::FetchTargetOutcome::target(&self) -> &radroots_transport::target::TargetFingerprint 211 pub fn radroots_transport::outcome::FetchTargetOutcome::with_message(self, impl core::convert::Into<alloc::string::String>) -> Self 212 pub const radroots_transport::outcome::DELIVERY_OUTCOME_CODE_MAX_BYTES: usize 213 pub const radroots_transport::outcome::DELIVERY_OUTCOME_MESSAGE_MAX_BYTES: usize 214 pub mod radroots_transport::policy 215 pub enum radroots_transport::policy::SatisfactionClass 216 pub radroots_transport::policy::SatisfactionClass::Accepted 217 pub radroots_transport::policy::SatisfactionClass::Delivered 218 pub enum radroots_transport::policy::SatisfactionState 219 pub radroots_transport::policy::SatisfactionState::Exhausted 220 pub radroots_transport::policy::SatisfactionState::Pending 221 pub radroots_transport::policy::SatisfactionState::Satisfied 222 pub struct radroots_transport::policy::SatisfactionPolicy 223 impl radroots_transport::policy::SatisfactionPolicy 224 pub const fn radroots_transport::policy::SatisfactionPolicy::class(&self) -> radroots_transport::policy::SatisfactionClass 225 pub const fn radroots_transport::policy::SatisfactionPolicy::new(radroots_transport::policy::SatisfactionClass, radroots_transport::policy::TargetPolicy) -> Self 226 pub const fn radroots_transport::policy::SatisfactionPolicy::targets(&self) -> &radroots_transport::policy::TargetPolicy 227 pub fn radroots_transport::policy::SatisfactionPolicy::validate_for(&self, &radroots_transport::target::TargetSet) -> core::result::Result<(), radroots_transport::error::Error> 228 pub struct radroots_transport::policy::TargetPolicy 229 impl radroots_transport::policy::TargetPolicy 230 pub const fn radroots_transport::policy::TargetPolicy::all() -> Self 231 pub const fn radroots_transport::policy::TargetPolicy::any() -> Self 232 pub const fn radroots_transport::policy::TargetPolicy::is_all(&self) -> bool 233 pub const fn radroots_transport::policy::TargetPolicy::is_any(&self) -> bool 234 pub const fn radroots_transport::policy::TargetPolicy::quorum(u16) -> core::result::Result<Self, radroots_transport::error::Error> 235 pub const fn radroots_transport::policy::TargetPolicy::quorum_threshold(&self) -> core::option::Option<u16> 236 pub fn radroots_transport::policy::TargetPolicy::required(alloc::vec::Vec<radroots_transport::target::TargetFingerprint>) -> core::result::Result<Self, radroots_transport::error::Error> 237 pub fn radroots_transport::policy::TargetPolicy::required_targets(&self) -> core::option::Option<&[radroots_transport::target::TargetFingerprint]> 238 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::policy::TargetPolicy 239 pub fn radroots_transport::policy::TargetPolicy::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 240 pub fn radroots_transport::policy::evaluate_satisfaction<'a, I>(&radroots_transport::policy::SatisfactionPolicy, &radroots_transport::target::TargetSet, I) -> core::result::Result<radroots_transport::policy::SatisfactionState, radroots_transport::error::Error> where I: core::iter::traits::collect::IntoIterator<Item = (&'a radroots_transport::target::TargetFingerprint, &'a radroots_transport::outcome::DeliveryOutcome)> 241 pub mod radroots_transport::sink 242 pub struct radroots_transport::sink::DeliveryPayload 243 impl radroots_transport::sink::DeliveryPayload 244 pub const fn radroots_transport::sink::DeliveryPayload::event(&self) -> &radroots_event::draft::SignedEvent 245 pub const fn radroots_transport::sink::DeliveryPayload::new(radroots_event::draft::SignedEvent) -> Self 246 pub struct radroots_transport::sink::DeliveryReceipt 247 impl radroots_transport::sink::DeliveryReceipt 248 pub fn radroots_transport::sink::DeliveryReceipt::for_request(&radroots_transport::sink::DeliveryRequest, alloc::vec::Vec<radroots_transport::sink::DeliveryTargetReceipt>) -> core::result::Result<Self, radroots_transport::error::Error> 249 pub fn radroots_transport::sink::DeliveryReceipt::is_satisfied(&self, &radroots_transport::sink::DeliveryRequest) -> core::result::Result<bool, radroots_transport::error::Error> 250 pub const fn radroots_transport::sink::DeliveryReceipt::request_id(&self) -> &radroots_transport::sink::DeliveryRequestId 251 pub fn radroots_transport::sink::DeliveryReceipt::satisfaction(&self, &radroots_transport::sink::DeliveryRequest) -> core::result::Result<radroots_transport::policy::SatisfactionState, radroots_transport::error::Error> 252 pub fn radroots_transport::sink::DeliveryReceipt::target_receipts(&self) -> &[radroots_transport::sink::DeliveryTargetReceipt] 253 pub fn radroots_transport::sink::DeliveryReceipt::validate_for_request(&self, &radroots_transport::sink::DeliveryRequest) -> core::result::Result<(), radroots_transport::error::Error> 254 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::sink::DeliveryReceipt 255 pub fn radroots_transport::sink::DeliveryReceipt::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 256 pub struct radroots_transport::sink::DeliveryRequest 257 impl radroots_transport::sink::DeliveryRequest 258 pub const fn radroots_transport::sink::DeliveryRequest::deadline_unix_ms(&self) -> u64 259 pub fn radroots_transport::sink::DeliveryRequest::new(impl core::convert::Into<alloc::string::String>, radroots_transport::sink::DeliveryPayload, radroots_transport::target::TargetSet, radroots_transport::policy::SatisfactionPolicy, u64) -> core::result::Result<Self, radroots_transport::error::Error> 260 pub const fn radroots_transport::sink::DeliveryRequest::payload(&self) -> &radroots_transport::sink::DeliveryPayload 261 pub const fn radroots_transport::sink::DeliveryRequest::request_id(&self) -> &radroots_transport::sink::DeliveryRequestId 262 pub const fn radroots_transport::sink::DeliveryRequest::satisfaction(&self) -> &radroots_transport::policy::SatisfactionPolicy 263 pub const fn radroots_transport::sink::DeliveryRequest::target_set(&self) -> &radroots_transport::target::TargetSet 264 pub fn radroots_transport::sink::DeliveryRequest::validate_target_selection(&self, &radroots_transport::target::TargetSet) -> core::result::Result<(), radroots_transport::error::Error> 265 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::sink::DeliveryRequest 266 pub fn radroots_transport::sink::DeliveryRequest::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 267 pub struct radroots_transport::sink::DeliveryRequestId(_) 268 impl radroots_transport::sink::DeliveryRequestId 269 pub fn radroots_transport::sink::DeliveryRequestId::as_str(&self) -> &str 270 pub fn radroots_transport::sink::DeliveryRequestId::parse(impl core::convert::Into<alloc::string::String>) -> core::result::Result<Self, radroots_transport::error::Error> 271 impl serde_core::ser::Serialize for radroots_transport::sink::DeliveryRequestId 272 pub fn radroots_transport::sink::DeliveryRequestId::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 273 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::sink::DeliveryRequestId 274 pub fn radroots_transport::sink::DeliveryRequestId::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 275 pub struct radroots_transport::sink::DeliveryTargetReceipt 276 impl radroots_transport::sink::DeliveryTargetReceipt 277 pub const fn radroots_transport::sink::DeliveryTargetReceipt::attempted(radroots_transport::target::Target, radroots_transport::outcome::DeliveryOutcome) -> Self 278 pub const fn radroots_transport::sink::DeliveryTargetReceipt::outcome(&self) -> &radroots_transport::outcome::DeliveryOutcome 279 pub fn radroots_transport::sink::DeliveryTargetReceipt::skipped(radroots_transport::target::Target, radroots_transport::outcome::DeliveryOutcome) -> core::result::Result<Self, radroots_transport::error::Error> 280 pub const fn radroots_transport::sink::DeliveryTargetReceipt::target(&self) -> &radroots_transport::target::Target 281 pub const fn radroots_transport::sink::DeliveryTargetReceipt::was_attempted(&self) -> bool 282 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::sink::DeliveryTargetReceipt 283 pub fn radroots_transport::sink::DeliveryTargetReceipt::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 284 pub struct radroots_transport::sink::SinkFailure 285 impl radroots_transport::sink::SinkFailure 286 pub fn radroots_transport::sink::SinkFailure::code(&self) -> &str 287 pub fn radroots_transport::sink::SinkFailure::for_request(&radroots_transport::sink::DeliveryRequest, impl core::convert::Into<alloc::string::String>, radroots_transport::outcome::Retryability, core::option::Option<u64>, core::option::Option<alloc::string::String>, alloc::vec::Vec<radroots_transport::sink::DeliveryTargetReceipt>) -> core::result::Result<Self, radroots_transport::error::Error> 288 pub fn radroots_transport::sink::SinkFailure::invalid_contract(&radroots_transport::sink::DeliveryRequest) -> Self 289 pub fn radroots_transport::sink::SinkFailure::message(&self) -> core::option::Option<&str> 290 pub fn radroots_transport::sink::SinkFailure::partial_evidence(&self) -> &[radroots_transport::sink::DeliveryTargetReceipt] 291 pub const fn radroots_transport::sink::SinkFailure::retry_after_unix_ms(&self) -> core::option::Option<u64> 292 pub const fn radroots_transport::sink::SinkFailure::retryability(&self) -> radroots_transport::outcome::Retryability 293 pub fn radroots_transport::sink::SinkFailure::validate_for_request(&self, &radroots_transport::sink::DeliveryRequest) -> core::result::Result<(), radroots_transport::error::Error> 294 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::sink::SinkFailure 295 pub fn radroots_transport::sink::SinkFailure::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 296 pub struct radroots_transport::sink::SinkStatus 297 impl radroots_transport::SinkStatus 298 pub const fn radroots_transport::SinkStatus::availability(&self) -> radroots_transport::capability::Availability 299 pub const fn radroots_transport::SinkStatus::capabilities(&self) -> radroots_transport::capability::SinkCapabilities 300 pub fn radroots_transport::SinkStatus::from_descriptor(&radroots_protocol::capability::v1::TransportDescriptor, bool, impl core::convert::Into<alloc::string::String>) -> Self 301 pub const fn radroots_transport::SinkStatus::is_configured(&self) -> bool 302 pub const fn radroots_transport::SinkStatus::maturity(&self) -> radroots_transport::capability::Maturity 303 pub fn radroots_transport::SinkStatus::message(&self) -> &str 304 pub fn radroots_transport::SinkStatus::new(radroots_transport::TransportId, bool, radroots_transport::capability::Maturity, radroots_transport::capability::Availability, radroots_transport::capability::SinkCapabilities, impl core::convert::Into<alloc::string::String>) -> Self 305 pub const fn radroots_transport::SinkStatus::transport_id(&self) -> radroots_transport::TransportId 306 pub const radroots_transport::sink::DELIVERY_REQUEST_ID_MAX_BYTES: usize 307 pub trait radroots_transport::sink::EventSink: core::marker::Send + core::marker::Sync 308 pub fn radroots_transport::sink::EventSink::deliver(&self, radroots_transport::sink::DeliveryRequest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::sink::DeliveryReceipt, radroots_transport::sink::SinkFailure>> 309 pub fn radroots_transport::sink::EventSink::deliver_selected(&self, radroots_transport::sink::DeliveryRequest, radroots_transport::target::TargetSet) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::sink::DeliveryReceipt, radroots_transport::sink::SinkFailure>> 310 pub fn radroots_transport::sink::EventSink::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::SinkStatus, radroots_transport::error::Error>> 311 pub mod radroots_transport::source 312 pub enum radroots_transport::source::NextPage 313 pub radroots_transport::source::NextPage::Cancelled 314 pub radroots_transport::source::NextPage::Cancelled::resume_from: core::option::Option<radroots_transport::source::FetchCursor> 315 pub radroots_transport::source::NextPage::Complete 316 pub radroots_transport::source::NextPage::Cursor(radroots_transport::source::FetchCursor) 317 pub enum radroots_transport::source::SubscriptionEndReason 318 pub radroots_transport::source::SubscriptionEndReason::Cancelled 319 pub radroots_transport::source::SubscriptionEndReason::Deadline 320 pub radroots_transport::source::SubscriptionEndReason::EventLimit 321 pub radroots_transport::source::SubscriptionEndReason::SourceClosed 322 pub enum radroots_transport::source::SubscriptionNext 323 pub radroots_transport::source::SubscriptionNext::End(radroots_transport::source::SubscriptionEnd) 324 pub radroots_transport::source::SubscriptionNext::Event(alloc::boxed::Box<radroots_transport::source::SubscriptionEvent>) 325 pub struct radroots_transport::source::EventProvenance 326 impl radroots_transport::source::EventProvenance 327 pub const fn radroots_transport::source::EventProvenance::cursor(&self) -> core::option::Option<&radroots_transport::source::FetchCursor> 328 pub fn radroots_transport::source::EventProvenance::new(radroots_transport::TransportId, radroots_transport::target::TargetFingerprint, u64) -> core::result::Result<Self, radroots_transport::error::Error> 329 pub const fn radroots_transport::source::EventProvenance::observed_at_unix_ms(&self) -> u64 330 pub const fn radroots_transport::source::EventProvenance::target(&self) -> &radroots_transport::target::TargetFingerprint 331 pub const fn radroots_transport::source::EventProvenance::transport_id(&self) -> radroots_transport::TransportId 332 pub fn radroots_transport::source::EventProvenance::with_cursor(self, radroots_transport::source::FetchCursor) -> Self 333 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::EventProvenance 334 pub fn radroots_transport::source::EventProvenance::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 335 pub struct radroots_transport::source::FetchBounds 336 impl radroots_transport::source::FetchBounds 337 pub const fn radroots_transport::source::FetchBounds::deadline_unix_ms(self) -> u64 338 pub const fn radroots_transport::source::FetchBounds::limit(self) -> u16 339 pub const fn radroots_transport::source::FetchBounds::new(u16, u64) -> core::result::Result<Self, radroots_transport::error::Error> 340 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::FetchBounds 341 pub fn radroots_transport::source::FetchBounds::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 342 pub struct radroots_transport::source::FetchCursor(_) 343 impl radroots_transport::source::FetchCursor 344 pub fn radroots_transport::source::FetchCursor::as_str(&self) -> &str 345 pub fn radroots_transport::source::FetchCursor::parse(impl core::convert::Into<alloc::string::String>) -> core::result::Result<Self, radroots_transport::error::Error> 346 impl core::fmt::Display for radroots_transport::source::FetchCursor 347 pub fn radroots_transport::source::FetchCursor::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 348 impl serde_core::ser::Serialize for radroots_transport::source::FetchCursor 349 pub fn radroots_transport::source::FetchCursor::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 350 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::FetchCursor 351 pub fn radroots_transport::source::FetchCursor::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 352 pub struct radroots_transport::source::FetchPage 353 impl radroots_transport::source::FetchPage 354 pub fn radroots_transport::source::FetchPage::events(&self) -> &[radroots_transport::source::ObservedEvent] 355 pub fn radroots_transport::source::FetchPage::for_request(&radroots_transport::source::FetchRequest, alloc::vec::Vec<radroots_transport::source::ObservedEvent>, alloc::vec::Vec<radroots_transport::outcome::FetchTargetOutcome>, radroots_transport::source::NextPage) -> core::result::Result<Self, radroots_transport::error::Error> 356 pub const fn radroots_transport::source::FetchPage::next_page(&self) -> &radroots_transport::source::NextPage 357 pub const fn radroots_transport::source::FetchPage::request_id(&self) -> &radroots_transport::source::FetchRequestId 358 pub fn radroots_transport::source::FetchPage::target_outcomes(&self) -> &[radroots_transport::outcome::FetchTargetOutcome] 359 pub fn radroots_transport::source::FetchPage::validate(&self) -> core::result::Result<(), radroots_transport::error::Error> 360 pub fn radroots_transport::source::FetchPage::validate_for_request(&self, &radroots_transport::source::FetchRequest) -> core::result::Result<(), radroots_transport::error::Error> 361 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::FetchPage 362 pub fn radroots_transport::source::FetchPage::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 363 pub struct radroots_transport::source::FetchRequest 364 impl radroots_transport::source::FetchRequest 365 pub const fn radroots_transport::source::FetchRequest::bounds(&self) -> radroots_transport::source::FetchBounds 366 pub fn radroots_transport::source::FetchRequest::cursor(&self) -> core::option::Option<&radroots_transport::source::FetchCursor> 367 pub fn radroots_transport::source::FetchRequest::new(impl core::convert::Into<alloc::string::String>, radroots_transport::target::TargetSet, radroots_transport::source::FetchBounds) -> core::result::Result<Self, radroots_transport::error::Error> 368 pub fn radroots_transport::source::FetchRequest::request_id(&self) -> &radroots_transport::source::FetchRequestId 369 pub const fn radroots_transport::source::FetchRequest::selector(&self) -> &radroots_transport::source::FetchSelector 370 pub fn radroots_transport::source::FetchRequest::target_set(&self) -> &radroots_transport::target::TargetSet 371 pub fn radroots_transport::source::FetchRequest::with_cursor(self, radroots_transport::source::FetchCursor) -> Self 372 pub fn radroots_transport::source::FetchRequest::with_selector(self, radroots_transport::source::FetchSelector) -> Self 373 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::FetchRequest 374 pub fn radroots_transport::source::FetchRequest::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 375 pub struct radroots_transport::source::FetchRequestId(_) 376 impl radroots_transport::source::FetchRequestId 377 pub fn radroots_transport::source::FetchRequestId::as_str(&self) -> &str 378 pub fn radroots_transport::source::FetchRequestId::parse(impl core::convert::Into<alloc::string::String>) -> core::result::Result<Self, radroots_transport::error::Error> 379 impl core::fmt::Display for radroots_transport::source::FetchRequestId 380 pub fn radroots_transport::source::FetchRequestId::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 381 impl serde_core::ser::Serialize for radroots_transport::source::FetchRequestId 382 pub fn radroots_transport::source::FetchRequestId::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 383 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::FetchRequestId 384 pub fn radroots_transport::source::FetchRequestId::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 385 pub struct radroots_transport::source::FetchSelector 386 impl radroots_transport::source::FetchSelector 387 pub const fn radroots_transport::source::FetchSelector::all() -> Self 388 pub fn radroots_transport::source::FetchSelector::authors(&self) -> &[radroots_identity::key::PublicKey] 389 pub fn radroots_transport::source::FetchSelector::exact_tag_filters(&self) -> impl core::iter::traits::iterator::Iterator<Item = (char, &[alloc::string::String])> + '_ 390 pub fn radroots_transport::source::FetchSelector::kinds(&self) -> &[u32] 391 pub fn radroots_transport::source::FetchSelector::matches(&self, &radroots_event::draft::SignedEvent) -> bool 392 pub const fn radroots_transport::source::FetchSelector::since_unix_seconds(&self) -> core::option::Option<u64> 393 pub const fn radroots_transport::source::FetchSelector::until_unix_seconds(&self) -> core::option::Option<u64> 394 pub fn radroots_transport::source::FetchSelector::with_authors(self, alloc::vec::Vec<radroots_identity::key::PublicKey>) -> core::result::Result<Self, radroots_transport::error::Error> 395 pub fn radroots_transport::source::FetchSelector::with_exact_tag_value(self, char, impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 396 pub fn radroots_transport::source::FetchSelector::with_kinds(self, alloc::vec::Vec<u32>) -> core::result::Result<Self, radroots_transport::error::Error> 397 pub fn radroots_transport::source::FetchSelector::with_since_unix_seconds(self, u64) -> core::result::Result<Self, radroots_transport::error::Error> 398 pub fn radroots_transport::source::FetchSelector::with_until_unix_seconds(self, u64) -> core::result::Result<Self, radroots_transport::error::Error> 399 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::FetchSelector 400 pub fn radroots_transport::source::FetchSelector::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 401 pub struct radroots_transport::source::ObservedEvent 402 impl radroots_transport::source::ObservedEvent 403 pub const fn radroots_transport::source::ObservedEvent::event(&self) -> &radroots_event::draft::SignedEvent 404 pub const fn radroots_transport::source::ObservedEvent::new(radroots_event::draft::SignedEvent, radroots_transport::source::EventProvenance) -> Self 405 pub const fn radroots_transport::source::ObservedEvent::provenance(&self) -> &radroots_transport::source::EventProvenance 406 pub struct radroots_transport::source::SourceStatus 407 impl radroots_transport::SourceStatus 408 pub const fn radroots_transport::SourceStatus::availability(&self) -> radroots_transport::capability::Availability 409 pub const fn radroots_transport::SourceStatus::capabilities(&self) -> radroots_transport::capability::SourceCapabilities 410 pub fn radroots_transport::SourceStatus::from_descriptor(&radroots_protocol::capability::v1::TransportDescriptor, bool, impl core::convert::Into<alloc::string::String>) -> Self 411 pub const fn radroots_transport::SourceStatus::is_configured(&self) -> bool 412 pub const fn radroots_transport::SourceStatus::maturity(&self) -> radroots_transport::capability::Maturity 413 pub fn radroots_transport::SourceStatus::message(&self) -> &str 414 pub fn radroots_transport::SourceStatus::new(radroots_transport::TransportId, bool, radroots_transport::capability::Maturity, radroots_transport::capability::Availability, radroots_transport::capability::SourceCapabilities, impl core::convert::Into<alloc::string::String>) -> Self 415 pub const fn radroots_transport::SourceStatus::transport_id(&self) -> radroots_transport::TransportId 416 pub struct radroots_transport::source::SubscriptionBounds 417 impl radroots_transport::source::SubscriptionBounds 418 pub const fn radroots_transport::source::SubscriptionBounds::deadline_unix_ms(self) -> u64 419 pub const fn radroots_transport::source::SubscriptionBounds::event_limit(self) -> u16 420 pub const fn radroots_transport::source::SubscriptionBounds::new(u16, u64) -> core::result::Result<Self, radroots_transport::error::Error> 421 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::SubscriptionBounds 422 pub fn radroots_transport::source::SubscriptionBounds::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 423 pub struct radroots_transport::source::SubscriptionCheckpoint 424 impl radroots_transport::source::SubscriptionCheckpoint 425 pub const fn radroots_transport::source::SubscriptionCheckpoint::cursor(&self) -> &radroots_transport::source::FetchCursor 426 pub const fn radroots_transport::source::SubscriptionCheckpoint::new(radroots_transport::target::TargetFingerprint, radroots_transport::source::FetchCursor) -> Self 427 pub const fn radroots_transport::source::SubscriptionCheckpoint::target(&self) -> &radroots_transport::target::TargetFingerprint 428 pub struct radroots_transport::source::SubscriptionEnd 429 impl radroots_transport::source::SubscriptionEnd 430 pub fn radroots_transport::source::SubscriptionEnd::checkpoints(&self) -> &[radroots_transport::source::SubscriptionCheckpoint] 431 pub const fn radroots_transport::source::SubscriptionEnd::event_count(&self) -> u16 432 pub fn radroots_transport::source::SubscriptionEnd::for_request<I>(&radroots_transport::source::SubscriptionRequest, u16, I, radroots_transport::source::SubscriptionEndReason) -> core::result::Result<Self, radroots_transport::error::Error> where I: core::iter::traits::collect::IntoIterator<Item = radroots_transport::source::SubscriptionCheckpoint> 433 pub const fn radroots_transport::source::SubscriptionEnd::reason(&self) -> radroots_transport::source::SubscriptionEndReason 434 pub const fn radroots_transport::source::SubscriptionEnd::request(&self) -> &radroots_transport::source::SubscriptionRequest 435 pub fn radroots_transport::source::SubscriptionEnd::validate_for_request(&self, &radroots_transport::source::SubscriptionRequest) -> core::result::Result<(), radroots_transport::error::Error> 436 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::SubscriptionEnd 437 pub fn radroots_transport::source::SubscriptionEnd::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 438 pub struct radroots_transport::source::SubscriptionEvent 439 impl radroots_transport::source::SubscriptionEvent 440 pub const fn radroots_transport::source::SubscriptionEvent::checkpoint(&self) -> &radroots_transport::source::SubscriptionCheckpoint 441 pub fn radroots_transport::source::SubscriptionEvent::for_request(&radroots_transport::source::SubscriptionRequest, radroots_transport::source::ObservedEvent, radroots_transport::source::SubscriptionCheckpoint) -> core::result::Result<Self, radroots_transport::error::Error> 442 pub const fn radroots_transport::source::SubscriptionEvent::observed(&self) -> &radroots_transport::source::ObservedEvent 443 pub const fn radroots_transport::source::SubscriptionEvent::request(&self) -> &radroots_transport::source::SubscriptionRequest 444 pub const fn radroots_transport::source::SubscriptionEvent::request_id(&self) -> &radroots_transport::source::SubscriptionRequestId 445 pub fn radroots_transport::source::SubscriptionEvent::validate_for_request(&self, &radroots_transport::source::SubscriptionRequest) -> core::result::Result<(), radroots_transport::error::Error> 446 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::SubscriptionEvent 447 pub fn radroots_transport::source::SubscriptionEvent::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 448 pub struct radroots_transport::source::SubscriptionRequest 449 impl radroots_transport::source::SubscriptionRequest 450 pub const fn radroots_transport::source::SubscriptionRequest::bounds(&self) -> radroots_transport::source::SubscriptionBounds 451 pub fn radroots_transport::source::SubscriptionRequest::checkpoints(&self) -> &[radroots_transport::source::SubscriptionCheckpoint] 452 pub fn radroots_transport::source::SubscriptionRequest::new(impl core::convert::AsRef<str>, radroots_transport::target::TargetSet, radroots_transport::source::SubscriptionBounds) -> core::result::Result<Self, radroots_transport::error::Error> 453 pub const fn radroots_transport::source::SubscriptionRequest::request_id(&self) -> &radroots_transport::source::SubscriptionRequestId 454 pub const fn radroots_transport::source::SubscriptionRequest::selector(&self) -> &radroots_transport::source::FetchSelector 455 pub const fn radroots_transport::source::SubscriptionRequest::target_set(&self) -> &radroots_transport::target::TargetSet 456 pub fn radroots_transport::source::SubscriptionRequest::with_checkpoints<I>(self, I) -> core::result::Result<Self, radroots_transport::error::Error> where I: core::iter::traits::collect::IntoIterator<Item = radroots_transport::source::SubscriptionCheckpoint> 457 pub fn radroots_transport::source::SubscriptionRequest::with_selector(self, radroots_transport::source::FetchSelector) -> Self 458 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::SubscriptionRequest 459 pub fn radroots_transport::source::SubscriptionRequest::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 460 pub struct radroots_transport::source::SubscriptionRequestId(_) 461 impl radroots_transport::source::SubscriptionRequestId 462 pub fn radroots_transport::source::SubscriptionRequestId::as_str(&self) -> &str 463 pub fn radroots_transport::source::SubscriptionRequestId::parse(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 464 impl core::fmt::Display for radroots_transport::source::SubscriptionRequestId 465 pub fn radroots_transport::source::SubscriptionRequestId::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 466 impl serde_core::ser::Serialize for radroots_transport::source::SubscriptionRequestId 467 pub fn radroots_transport::source::SubscriptionRequestId::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 468 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::SubscriptionRequestId 469 pub fn radroots_transport::source::SubscriptionRequestId::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 470 pub const radroots_transport::source::FETCH_CURSOR_MAX_BYTES: usize 471 pub const radroots_transport::source::FETCH_PAGE_MAX_EVENTS: u16 472 pub const radroots_transport::source::FETCH_REQUEST_ID_MAX_BYTES: usize 473 pub const radroots_transport::source::FETCH_SELECTOR_MAX_AUTHORS: usize 474 pub const radroots_transport::source::FETCH_SELECTOR_MAX_KINDS: usize 475 pub const radroots_transport::source::FETCH_SELECTOR_MAX_TAG_KEYS: usize 476 pub const radroots_transport::source::FETCH_SELECTOR_MAX_TAG_VALUES: usize 477 pub const radroots_transport::source::FETCH_SELECTOR_TAG_VALUE_MAX_BYTES: usize 478 pub const radroots_transport::source::SUBSCRIPTION_MAX_EVENTS: u16 479 pub const radroots_transport::source::SUBSCRIPTION_REQUEST_ID_MAX_BYTES: usize 480 pub trait radroots_transport::source::EventSource: core::marker::Send + core::marker::Sync 481 pub fn radroots_transport::source::EventSource::fetch(&self, radroots_transport::source::FetchRequest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::source::FetchPage, radroots_transport::error::Error>> 482 pub fn radroots_transport::source::EventSource::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::SourceStatus, radroots_transport::error::Error>> 483 pub trait radroots_transport::source::EventSubscriber: core::marker::Send + core::marker::Sync 484 pub fn radroots_transport::source::EventSubscriber::subscribe(&self, radroots_transport::source::SubscriptionRequest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::source::BoxSubscription, radroots_transport::error::Error>> 485 pub trait radroots_transport::source::EventSubscription: core::marker::Send 486 pub fn radroots_transport::source::EventSubscription::cancel(&mut self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::source::SubscriptionEnd, radroots_transport::error::Error>> 487 pub fn radroots_transport::source::EventSubscription::next(&mut self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::source::SubscriptionNext, radroots_transport::error::Error>> 488 pub fn radroots_transport::source::EventSubscription::request(&self) -> &radroots_transport::source::SubscriptionRequest 489 pub type radroots_transport::source::BoxFuture<'a, T> = core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = T> + core::marker::Send + 'a)>> 490 pub type radroots_transport::source::BoxSubscription = alloc::boxed::Box<dyn radroots_transport::source::EventSubscription> 491 pub mod radroots_transport::target 492 #[non_exhaustive] pub enum radroots_transport::target::TargetNetworkPolicy 493 pub radroots_transport::target::TargetNetworkPolicy::PrivateDevice 494 pub radroots_transport::target::TargetNetworkPolicy::TlsOrLoopback 495 pub struct radroots_transport::target::EndpointUri(_) 496 impl radroots_transport::target::EndpointUri 497 pub fn radroots_transport::target::EndpointUri::as_str(&self) -> &str 498 pub fn radroots_transport::target::EndpointUri::parse(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 499 impl core::convert::AsRef<str> for radroots_transport::target::EndpointUri 500 pub fn radroots_transport::target::EndpointUri::as_ref(&self) -> &str 501 impl core::convert::TryFrom<&str> for radroots_transport::target::EndpointUri 502 pub type radroots_transport::target::EndpointUri::Error = radroots_transport::error::Error 503 pub fn radroots_transport::target::EndpointUri::try_from(&str) -> core::result::Result<Self, Self::Error> 504 impl core::fmt::Display for radroots_transport::target::EndpointUri 505 pub fn radroots_transport::target::EndpointUri::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 506 impl core::str::traits::FromStr for radroots_transport::target::EndpointUri 507 pub type radroots_transport::target::EndpointUri::Err = radroots_transport::error::Error 508 pub fn radroots_transport::target::EndpointUri::from_str(&str) -> core::result::Result<Self, Self::Err> 509 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::target::EndpointUri 510 pub fn radroots_transport::target::EndpointUri::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 511 pub struct radroots_transport::target::Target 512 impl radroots_transport::target::Target 513 pub fn radroots_transport::target::Target::fingerprint(&self) -> &radroots_transport::target::TargetFingerprint 514 pub fn radroots_transport::target::Target::kind(&self) -> &radroots_transport::TransportId 515 pub fn radroots_transport::target::Target::label(&self) -> core::option::Option<&radroots_transport::target::TargetLabel> 516 pub fn radroots_transport::target::Target::local(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 517 pub fn radroots_transport::target::Target::local_with_metadata(impl core::convert::AsRef<str>, core::option::Option<radroots_transport::target::TargetScope>, core::option::Option<radroots_transport::target::TargetLabel>) -> core::result::Result<Self, radroots_transport::error::Error> 518 pub fn radroots_transport::target::Target::new(radroots_transport::TransportId, impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 519 pub fn radroots_transport::target::Target::new_with_metadata(radroots_transport::TransportId, impl core::convert::AsRef<str>, core::option::Option<radroots_transport::target::TargetScope>, core::option::Option<radroots_transport::target::TargetLabel>) -> core::result::Result<Self, radroots_transport::error::Error> 520 pub fn radroots_transport::target::Target::nostr_relay(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 521 pub fn radroots_transport::target::Target::nostr_relay_with_metadata(impl core::convert::AsRef<str>, core::option::Option<radroots_transport::target::TargetScope>, core::option::Option<radroots_transport::target::TargetLabel>) -> core::result::Result<Self, radroots_transport::error::Error> 522 pub fn radroots_transport::target::Target::nostr_relay_with_policy(impl core::convert::AsRef<str>, radroots_transport::target::TargetNetworkPolicy) -> core::result::Result<Self, radroots_transport::error::Error> 523 pub fn radroots_transport::target::Target::scope(&self) -> core::option::Option<&radroots_transport::target::TargetScope> 524 pub fn radroots_transport::target::Target::uri(&self) -> &radroots_transport::target::EndpointUri 525 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::target::Target 526 pub fn radroots_transport::target::Target::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 527 pub struct radroots_transport::target::TargetFingerprint(_) 528 impl radroots_transport::target::TargetFingerprint 529 pub fn radroots_transport::target::TargetFingerprint::as_str(&self) -> &str 530 pub fn radroots_transport::target::TargetFingerprint::from_target(&radroots_transport::TransportId, &radroots_transport::target::EndpointUri, core::option::Option<&radroots_transport::target::TargetScope>) -> Self 531 pub fn radroots_transport::target::TargetFingerprint::parse(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 532 impl core::convert::AsRef<str> for radroots_transport::target::TargetFingerprint 533 pub fn radroots_transport::target::TargetFingerprint::as_ref(&self) -> &str 534 impl core::convert::TryFrom<&str> for radroots_transport::target::TargetFingerprint 535 pub type radroots_transport::target::TargetFingerprint::Error = radroots_transport::error::Error 536 pub fn radroots_transport::target::TargetFingerprint::try_from(&str) -> core::result::Result<Self, Self::Error> 537 impl core::fmt::Display for radroots_transport::target::TargetFingerprint 538 pub fn radroots_transport::target::TargetFingerprint::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 539 impl core::str::traits::FromStr for radroots_transport::target::TargetFingerprint 540 pub type radroots_transport::target::TargetFingerprint::Err = radroots_transport::error::Error 541 pub fn radroots_transport::target::TargetFingerprint::from_str(&str) -> core::result::Result<Self, Self::Err> 542 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::target::TargetFingerprint 543 pub fn radroots_transport::target::TargetFingerprint::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 544 pub struct radroots_transport::target::TargetLabel(_) 545 impl radroots_transport::target::TargetLabel 546 pub fn radroots_transport::target::TargetLabel::as_str(&self) -> &str 547 pub fn radroots_transport::target::TargetLabel::parse(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 548 impl core::convert::AsRef<str> for radroots_transport::target::TargetLabel 549 pub fn radroots_transport::target::TargetLabel::as_ref(&self) -> &str 550 impl core::convert::TryFrom<&str> for radroots_transport::target::TargetLabel 551 pub type radroots_transport::target::TargetLabel::Error = radroots_transport::error::Error 552 pub fn radroots_transport::target::TargetLabel::try_from(&str) -> core::result::Result<Self, Self::Error> 553 impl core::fmt::Display for radroots_transport::target::TargetLabel 554 pub fn radroots_transport::target::TargetLabel::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 555 impl core::str::traits::FromStr for radroots_transport::target::TargetLabel 556 pub type radroots_transport::target::TargetLabel::Err = radroots_transport::error::Error 557 pub fn radroots_transport::target::TargetLabel::from_str(&str) -> core::result::Result<Self, Self::Err> 558 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::target::TargetLabel 559 pub fn radroots_transport::target::TargetLabel::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 560 pub struct radroots_transport::target::TargetScope(_) 561 impl radroots_transport::target::TargetScope 562 pub fn radroots_transport::target::TargetScope::as_str(&self) -> &str 563 pub fn radroots_transport::target::TargetScope::parse(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 564 impl core::convert::AsRef<str> for radroots_transport::target::TargetScope 565 pub fn radroots_transport::target::TargetScope::as_ref(&self) -> &str 566 impl core::convert::TryFrom<&str> for radroots_transport::target::TargetScope 567 pub type radroots_transport::target::TargetScope::Error = radroots_transport::error::Error 568 pub fn radroots_transport::target::TargetScope::try_from(&str) -> core::result::Result<Self, Self::Error> 569 impl core::fmt::Display for radroots_transport::target::TargetScope 570 pub fn radroots_transport::target::TargetScope::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 571 impl core::str::traits::FromStr for radroots_transport::target::TargetScope 572 pub type radroots_transport::target::TargetScope::Err = radroots_transport::error::Error 573 pub fn radroots_transport::target::TargetScope::from_str(&str) -> core::result::Result<Self, Self::Err> 574 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::target::TargetScope 575 pub fn radroots_transport::target::TargetScope::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 576 pub struct radroots_transport::target::TargetSet 577 impl radroots_transport::target::TargetSet 578 pub fn radroots_transport::target::TargetSet::contains(&self, &radroots_transport::target::TargetFingerprint) -> bool 579 pub fn radroots_transport::target::TargetSet::is_empty(&self) -> bool 580 pub fn radroots_transport::target::TargetSet::len(&self) -> usize 581 pub fn radroots_transport::target::TargetSet::new(alloc::vec::Vec<radroots_transport::target::Target>) -> core::result::Result<Self, radroots_transport::error::Error> 582 pub fn radroots_transport::target::TargetSet::targets(&self) -> &[radroots_transport::target::Target] 583 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::target::TargetSet 584 pub fn radroots_transport::target::TargetSet::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 585 pub const radroots_transport::target::TARGET_SET_MAX_ITEMS: usize 586 pub enum radroots_transport::Error 587 pub radroots_transport::Error::DeliveryReceiptRequestIdMismatch 588 pub radroots_transport::Error::DeliveryReceiptTargetSetMismatch 589 pub radroots_transport::Error::DeliveryTargetReceiptAttemptMismatch 590 pub radroots_transport::Error::DeliveryTargetReceiptStatusMismatch 591 pub radroots_transport::Error::DuplicateDeliveryTargetReceipt 592 pub radroots_transport::Error::DuplicateFetchAuthor 593 pub radroots_transport::Error::DuplicateFetchKind 594 pub radroots_transport::Error::DuplicateFetchTagValue 595 pub radroots_transport::Error::DuplicateFetchTargetOutcome 596 pub radroots_transport::Error::DuplicateRequiredTargetFingerprint 597 pub radroots_transport::Error::DuplicateSubscriptionCheckpoint 598 pub radroots_transport::Error::DuplicateTargetFingerprint 599 pub radroots_transport::Error::EmptyDeliveryRequestId 600 pub radroots_transport::Error::EmptyFetchCursor 601 pub radroots_transport::Error::EmptyFetchRequestId 602 pub radroots_transport::Error::EmptyPayloadBytes 603 pub radroots_transport::Error::EmptyPayloadId 604 pub radroots_transport::Error::EmptyPayloadLabel 605 pub radroots_transport::Error::EmptyRequiredTargetSet 606 pub radroots_transport::Error::EmptySubscriptionRequestId 607 pub radroots_transport::Error::EmptyTargetLabel 608 pub radroots_transport::Error::EmptyTargetScope 609 pub radroots_transport::Error::EmptyTargetSet 610 pub radroots_transport::Error::EmptyTargetUri 611 pub radroots_transport::Error::EmptyTransportKind 612 pub radroots_transport::Error::FetchPageLimitExceeded 613 pub radroots_transport::Error::FetchPageRequestMismatch 614 pub radroots_transport::Error::FetchSelectorTooLarge 615 pub radroots_transport::Error::InvalidDeliveryDeadline 616 pub radroots_transport::Error::InvalidDeliveryOutcome 617 pub radroots_transport::Error::InvalidDeliveryRequestId 618 pub radroots_transport::Error::InvalidDeliveryTargetSelection 619 pub radroots_transport::Error::InvalidDeliveryTimestamp 620 pub radroots_transport::Error::InvalidFetchCursor 621 pub radroots_transport::Error::InvalidFetchDeadline 622 pub radroots_transport::Error::InvalidFetchLimit 623 pub radroots_transport::Error::InvalidFetchRequestId 624 pub radroots_transport::Error::InvalidFetchTagKey 625 pub radroots_transport::Error::InvalidFetchTagValue 626 pub radroots_transport::Error::InvalidFetchTimeRange 627 pub radroots_transport::Error::InvalidObservedAt 628 pub radroots_transport::Error::InvalidPayloadBytes 629 pub radroots_transport::Error::InvalidPayloadDigest 630 pub radroots_transport::Error::InvalidPayloadId 631 pub radroots_transport::Error::InvalidPayloadLabel 632 pub radroots_transport::Error::InvalidSatisfactionPolicy 633 pub radroots_transport::Error::InvalidSubscriptionDeadline 634 pub radroots_transport::Error::InvalidSubscriptionEnd 635 pub radroots_transport::Error::InvalidSubscriptionLimit 636 pub radroots_transport::Error::InvalidSubscriptionRequestId 637 pub radroots_transport::Error::InvalidTargetFingerprint 638 pub radroots_transport::Error::InvalidTargetLabel 639 pub radroots_transport::Error::InvalidTargetScope 640 pub radroots_transport::Error::InvalidTargetUri 641 pub radroots_transport::Error::InvalidTransportKind 642 pub radroots_transport::Error::MissingDeliveryTargetReceipt 643 pub radroots_transport::Error::PayloadDigestMismatch 644 pub radroots_transport::Error::RequiredTargetNotRequested 645 pub radroots_transport::Error::SubscriptionCheckpointSetTooLarge 646 pub radroots_transport::Error::SubscriptionEndLimitExceeded 647 pub radroots_transport::Error::SubscriptionEndRequestMismatch 648 pub radroots_transport::Error::SubscriptionEventCheckpointMismatch 649 pub radroots_transport::Error::SubscriptionUnavailable 650 pub radroots_transport::Error::TargetSetTooLarge 651 pub radroots_transport::Error::TransportOutcomeStatusMismatch 652 pub radroots_transport::Error::UnexpectedDeliveryTargetReceipt 653 pub radroots_transport::Error::UnexpectedFetchEvent 654 pub radroots_transport::Error::UnexpectedFetchProvenance 655 pub radroots_transport::Error::UnexpectedFetchTargetOutcome 656 pub radroots_transport::Error::UnexpectedSubscriptionCheckpoint 657 pub radroots_transport::Error::UnexpectedSubscriptionEvent 658 pub radroots_transport::Error::UnsupportedOperation 659 impl core::fmt::Display for radroots_transport::error::Error 660 pub fn radroots_transport::error::Error::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 661 pub enum radroots_transport::SubscriptionEndReason 662 pub radroots_transport::SubscriptionEndReason::Cancelled 663 pub radroots_transport::SubscriptionEndReason::Deadline 664 pub radroots_transport::SubscriptionEndReason::EventLimit 665 pub radroots_transport::SubscriptionEndReason::SourceClosed 666 pub enum radroots_transport::SubscriptionNext 667 pub radroots_transport::SubscriptionNext::End(radroots_transport::source::SubscriptionEnd) 668 pub radroots_transport::SubscriptionNext::Event(alloc::boxed::Box<radroots_transport::source::SubscriptionEvent>) 669 #[non_exhaustive] pub enum radroots_transport::TargetNetworkPolicy 670 pub radroots_transport::TargetNetworkPolicy::PrivateDevice 671 pub radroots_transport::TargetNetworkPolicy::TlsOrLoopback 672 pub struct radroots_transport::DeliveryReceipt 673 impl radroots_transport::sink::DeliveryReceipt 674 pub fn radroots_transport::sink::DeliveryReceipt::for_request(&radroots_transport::sink::DeliveryRequest, alloc::vec::Vec<radroots_transport::sink::DeliveryTargetReceipt>) -> core::result::Result<Self, radroots_transport::error::Error> 675 pub fn radroots_transport::sink::DeliveryReceipt::is_satisfied(&self, &radroots_transport::sink::DeliveryRequest) -> core::result::Result<bool, radroots_transport::error::Error> 676 pub const fn radroots_transport::sink::DeliveryReceipt::request_id(&self) -> &radroots_transport::sink::DeliveryRequestId 677 pub fn radroots_transport::sink::DeliveryReceipt::satisfaction(&self, &radroots_transport::sink::DeliveryRequest) -> core::result::Result<radroots_transport::policy::SatisfactionState, radroots_transport::error::Error> 678 pub fn radroots_transport::sink::DeliveryReceipt::target_receipts(&self) -> &[radroots_transport::sink::DeliveryTargetReceipt] 679 pub fn radroots_transport::sink::DeliveryReceipt::validate_for_request(&self, &radroots_transport::sink::DeliveryRequest) -> core::result::Result<(), radroots_transport::error::Error> 680 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::sink::DeliveryReceipt 681 pub fn radroots_transport::sink::DeliveryReceipt::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 682 pub struct radroots_transport::DeliveryRequest 683 impl radroots_transport::sink::DeliveryRequest 684 pub const fn radroots_transport::sink::DeliveryRequest::deadline_unix_ms(&self) -> u64 685 pub fn radroots_transport::sink::DeliveryRequest::new(impl core::convert::Into<alloc::string::String>, radroots_transport::sink::DeliveryPayload, radroots_transport::target::TargetSet, radroots_transport::policy::SatisfactionPolicy, u64) -> core::result::Result<Self, radroots_transport::error::Error> 686 pub const fn radroots_transport::sink::DeliveryRequest::payload(&self) -> &radroots_transport::sink::DeliveryPayload 687 pub const fn radroots_transport::sink::DeliveryRequest::request_id(&self) -> &radroots_transport::sink::DeliveryRequestId 688 pub const fn radroots_transport::sink::DeliveryRequest::satisfaction(&self) -> &radroots_transport::policy::SatisfactionPolicy 689 pub const fn radroots_transport::sink::DeliveryRequest::target_set(&self) -> &radroots_transport::target::TargetSet 690 pub fn radroots_transport::sink::DeliveryRequest::validate_target_selection(&self, &radroots_transport::target::TargetSet) -> core::result::Result<(), radroots_transport::error::Error> 691 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::sink::DeliveryRequest 692 pub fn radroots_transport::sink::DeliveryRequest::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 693 pub struct radroots_transport::FetchPage 694 impl radroots_transport::source::FetchPage 695 pub fn radroots_transport::source::FetchPage::events(&self) -> &[radroots_transport::source::ObservedEvent] 696 pub fn radroots_transport::source::FetchPage::for_request(&radroots_transport::source::FetchRequest, alloc::vec::Vec<radroots_transport::source::ObservedEvent>, alloc::vec::Vec<radroots_transport::outcome::FetchTargetOutcome>, radroots_transport::source::NextPage) -> core::result::Result<Self, radroots_transport::error::Error> 697 pub const fn radroots_transport::source::FetchPage::next_page(&self) -> &radroots_transport::source::NextPage 698 pub const fn radroots_transport::source::FetchPage::request_id(&self) -> &radroots_transport::source::FetchRequestId 699 pub fn radroots_transport::source::FetchPage::target_outcomes(&self) -> &[radroots_transport::outcome::FetchTargetOutcome] 700 pub fn radroots_transport::source::FetchPage::validate(&self) -> core::result::Result<(), radroots_transport::error::Error> 701 pub fn radroots_transport::source::FetchPage::validate_for_request(&self, &radroots_transport::source::FetchRequest) -> core::result::Result<(), radroots_transport::error::Error> 702 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::FetchPage 703 pub fn radroots_transport::source::FetchPage::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 704 pub struct radroots_transport::FetchRequest 705 impl radroots_transport::source::FetchRequest 706 pub const fn radroots_transport::source::FetchRequest::bounds(&self) -> radroots_transport::source::FetchBounds 707 pub fn radroots_transport::source::FetchRequest::cursor(&self) -> core::option::Option<&radroots_transport::source::FetchCursor> 708 pub fn radroots_transport::source::FetchRequest::new(impl core::convert::Into<alloc::string::String>, radroots_transport::target::TargetSet, radroots_transport::source::FetchBounds) -> core::result::Result<Self, radroots_transport::error::Error> 709 pub fn radroots_transport::source::FetchRequest::request_id(&self) -> &radroots_transport::source::FetchRequestId 710 pub const fn radroots_transport::source::FetchRequest::selector(&self) -> &radroots_transport::source::FetchSelector 711 pub fn radroots_transport::source::FetchRequest::target_set(&self) -> &radroots_transport::target::TargetSet 712 pub fn radroots_transport::source::FetchRequest::with_cursor(self, radroots_transport::source::FetchCursor) -> Self 713 pub fn radroots_transport::source::FetchRequest::with_selector(self, radroots_transport::source::FetchSelector) -> Self 714 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::FetchRequest 715 pub fn radroots_transport::source::FetchRequest::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 716 pub struct radroots_transport::SinkFailure 717 impl radroots_transport::sink::SinkFailure 718 pub fn radroots_transport::sink::SinkFailure::code(&self) -> &str 719 pub fn radroots_transport::sink::SinkFailure::for_request(&radroots_transport::sink::DeliveryRequest, impl core::convert::Into<alloc::string::String>, radroots_transport::outcome::Retryability, core::option::Option<u64>, core::option::Option<alloc::string::String>, alloc::vec::Vec<radroots_transport::sink::DeliveryTargetReceipt>) -> core::result::Result<Self, radroots_transport::error::Error> 720 pub fn radroots_transport::sink::SinkFailure::invalid_contract(&radroots_transport::sink::DeliveryRequest) -> Self 721 pub fn radroots_transport::sink::SinkFailure::message(&self) -> core::option::Option<&str> 722 pub fn radroots_transport::sink::SinkFailure::partial_evidence(&self) -> &[radroots_transport::sink::DeliveryTargetReceipt] 723 pub const fn radroots_transport::sink::SinkFailure::retry_after_unix_ms(&self) -> core::option::Option<u64> 724 pub const fn radroots_transport::sink::SinkFailure::retryability(&self) -> radroots_transport::outcome::Retryability 725 pub fn radroots_transport::sink::SinkFailure::validate_for_request(&self, &radroots_transport::sink::DeliveryRequest) -> core::result::Result<(), radroots_transport::error::Error> 726 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::sink::SinkFailure 727 pub fn radroots_transport::sink::SinkFailure::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 728 pub struct radroots_transport::SinkStatus 729 impl radroots_transport::SinkStatus 730 pub const fn radroots_transport::SinkStatus::availability(&self) -> radroots_transport::capability::Availability 731 pub const fn radroots_transport::SinkStatus::capabilities(&self) -> radroots_transport::capability::SinkCapabilities 732 pub fn radroots_transport::SinkStatus::from_descriptor(&radroots_protocol::capability::v1::TransportDescriptor, bool, impl core::convert::Into<alloc::string::String>) -> Self 733 pub const fn radroots_transport::SinkStatus::is_configured(&self) -> bool 734 pub const fn radroots_transport::SinkStatus::maturity(&self) -> radroots_transport::capability::Maturity 735 pub fn radroots_transport::SinkStatus::message(&self) -> &str 736 pub fn radroots_transport::SinkStatus::new(radroots_transport::TransportId, bool, radroots_transport::capability::Maturity, radroots_transport::capability::Availability, radroots_transport::capability::SinkCapabilities, impl core::convert::Into<alloc::string::String>) -> Self 737 pub const fn radroots_transport::SinkStatus::transport_id(&self) -> radroots_transport::TransportId 738 pub struct radroots_transport::SourceStatus 739 impl radroots_transport::SourceStatus 740 pub const fn radroots_transport::SourceStatus::availability(&self) -> radroots_transport::capability::Availability 741 pub const fn radroots_transport::SourceStatus::capabilities(&self) -> radroots_transport::capability::SourceCapabilities 742 pub fn radroots_transport::SourceStatus::from_descriptor(&radroots_protocol::capability::v1::TransportDescriptor, bool, impl core::convert::Into<alloc::string::String>) -> Self 743 pub const fn radroots_transport::SourceStatus::is_configured(&self) -> bool 744 pub const fn radroots_transport::SourceStatus::maturity(&self) -> radroots_transport::capability::Maturity 745 pub fn radroots_transport::SourceStatus::message(&self) -> &str 746 pub fn radroots_transport::SourceStatus::new(radroots_transport::TransportId, bool, radroots_transport::capability::Maturity, radroots_transport::capability::Availability, radroots_transport::capability::SourceCapabilities, impl core::convert::Into<alloc::string::String>) -> Self 747 pub const fn radroots_transport::SourceStatus::transport_id(&self) -> radroots_transport::TransportId 748 pub struct radroots_transport::SubscriptionEnd 749 impl radroots_transport::source::SubscriptionEnd 750 pub fn radroots_transport::source::SubscriptionEnd::checkpoints(&self) -> &[radroots_transport::source::SubscriptionCheckpoint] 751 pub const fn radroots_transport::source::SubscriptionEnd::event_count(&self) -> u16 752 pub fn radroots_transport::source::SubscriptionEnd::for_request<I>(&radroots_transport::source::SubscriptionRequest, u16, I, radroots_transport::source::SubscriptionEndReason) -> core::result::Result<Self, radroots_transport::error::Error> where I: core::iter::traits::collect::IntoIterator<Item = radroots_transport::source::SubscriptionCheckpoint> 753 pub const fn radroots_transport::source::SubscriptionEnd::reason(&self) -> radroots_transport::source::SubscriptionEndReason 754 pub const fn radroots_transport::source::SubscriptionEnd::request(&self) -> &radroots_transport::source::SubscriptionRequest 755 pub fn radroots_transport::source::SubscriptionEnd::validate_for_request(&self, &radroots_transport::source::SubscriptionRequest) -> core::result::Result<(), radroots_transport::error::Error> 756 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::SubscriptionEnd 757 pub fn radroots_transport::source::SubscriptionEnd::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 758 pub struct radroots_transport::SubscriptionEvent 759 impl radroots_transport::source::SubscriptionEvent 760 pub const fn radroots_transport::source::SubscriptionEvent::checkpoint(&self) -> &radroots_transport::source::SubscriptionCheckpoint 761 pub fn radroots_transport::source::SubscriptionEvent::for_request(&radroots_transport::source::SubscriptionRequest, radroots_transport::source::ObservedEvent, radroots_transport::source::SubscriptionCheckpoint) -> core::result::Result<Self, radroots_transport::error::Error> 762 pub const fn radroots_transport::source::SubscriptionEvent::observed(&self) -> &radroots_transport::source::ObservedEvent 763 pub const fn radroots_transport::source::SubscriptionEvent::request(&self) -> &radroots_transport::source::SubscriptionRequest 764 pub const fn radroots_transport::source::SubscriptionEvent::request_id(&self) -> &radroots_transport::source::SubscriptionRequestId 765 pub fn radroots_transport::source::SubscriptionEvent::validate_for_request(&self, &radroots_transport::source::SubscriptionRequest) -> core::result::Result<(), radroots_transport::error::Error> 766 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::SubscriptionEvent 767 pub fn radroots_transport::source::SubscriptionEvent::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 768 pub struct radroots_transport::SubscriptionRequest 769 impl radroots_transport::source::SubscriptionRequest 770 pub const fn radroots_transport::source::SubscriptionRequest::bounds(&self) -> radroots_transport::source::SubscriptionBounds 771 pub fn radroots_transport::source::SubscriptionRequest::checkpoints(&self) -> &[radroots_transport::source::SubscriptionCheckpoint] 772 pub fn radroots_transport::source::SubscriptionRequest::new(impl core::convert::AsRef<str>, radroots_transport::target::TargetSet, radroots_transport::source::SubscriptionBounds) -> core::result::Result<Self, radroots_transport::error::Error> 773 pub const fn radroots_transport::source::SubscriptionRequest::request_id(&self) -> &radroots_transport::source::SubscriptionRequestId 774 pub const fn radroots_transport::source::SubscriptionRequest::selector(&self) -> &radroots_transport::source::FetchSelector 775 pub const fn radroots_transport::source::SubscriptionRequest::target_set(&self) -> &radroots_transport::target::TargetSet 776 pub fn radroots_transport::source::SubscriptionRequest::with_checkpoints<I>(self, I) -> core::result::Result<Self, radroots_transport::error::Error> where I: core::iter::traits::collect::IntoIterator<Item = radroots_transport::source::SubscriptionCheckpoint> 777 pub fn radroots_transport::source::SubscriptionRequest::with_selector(self, radroots_transport::source::FetchSelector) -> Self 778 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::source::SubscriptionRequest 779 pub fn radroots_transport::source::SubscriptionRequest::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 780 pub struct radroots_transport::Target 781 impl radroots_transport::target::Target 782 pub fn radroots_transport::target::Target::fingerprint(&self) -> &radroots_transport::target::TargetFingerprint 783 pub fn radroots_transport::target::Target::kind(&self) -> &radroots_transport::TransportId 784 pub fn radroots_transport::target::Target::label(&self) -> core::option::Option<&radroots_transport::target::TargetLabel> 785 pub fn radroots_transport::target::Target::local(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 786 pub fn radroots_transport::target::Target::local_with_metadata(impl core::convert::AsRef<str>, core::option::Option<radroots_transport::target::TargetScope>, core::option::Option<radroots_transport::target::TargetLabel>) -> core::result::Result<Self, radroots_transport::error::Error> 787 pub fn radroots_transport::target::Target::new(radroots_transport::TransportId, impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 788 pub fn radroots_transport::target::Target::new_with_metadata(radroots_transport::TransportId, impl core::convert::AsRef<str>, core::option::Option<radroots_transport::target::TargetScope>, core::option::Option<radroots_transport::target::TargetLabel>) -> core::result::Result<Self, radroots_transport::error::Error> 789 pub fn radroots_transport::target::Target::nostr_relay(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 790 pub fn radroots_transport::target::Target::nostr_relay_with_metadata(impl core::convert::AsRef<str>, core::option::Option<radroots_transport::target::TargetScope>, core::option::Option<radroots_transport::target::TargetLabel>) -> core::result::Result<Self, radroots_transport::error::Error> 791 pub fn radroots_transport::target::Target::nostr_relay_with_policy(impl core::convert::AsRef<str>, radroots_transport::target::TargetNetworkPolicy) -> core::result::Result<Self, radroots_transport::error::Error> 792 pub fn radroots_transport::target::Target::scope(&self) -> core::option::Option<&radroots_transport::target::TargetScope> 793 pub fn radroots_transport::target::Target::uri(&self) -> &radroots_transport::target::EndpointUri 794 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::target::Target 795 pub fn radroots_transport::target::Target::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 796 pub struct radroots_transport::TargetSet 797 impl radroots_transport::target::TargetSet 798 pub fn radroots_transport::target::TargetSet::contains(&self, &radroots_transport::target::TargetFingerprint) -> bool 799 pub fn radroots_transport::target::TargetSet::is_empty(&self) -> bool 800 pub fn radroots_transport::target::TargetSet::len(&self) -> usize 801 pub fn radroots_transport::target::TargetSet::new(alloc::vec::Vec<radroots_transport::target::Target>) -> core::result::Result<Self, radroots_transport::error::Error> 802 pub fn radroots_transport::target::TargetSet::targets(&self) -> &[radroots_transport::target::Target] 803 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::target::TargetSet 804 pub fn radroots_transport::target::TargetSet::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 805 pub struct radroots_transport::TransportId(_) 806 impl radroots_transport::TransportId 807 pub const radroots_transport::TransportId::LOCAL: Self 808 pub const radroots_transport::TransportId::NOSTR: Self 809 pub const radroots_transport::TransportId::RADROOTSD: Self 810 pub const radroots_transport::TransportId::RETICULUM: Self 811 pub fn radroots_transport::TransportId::as_str(&self) -> &str 812 pub fn radroots_transport::TransportId::canonical_label(&self) -> alloc::string::String 813 pub fn radroots_transport::TransportId::parse(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 814 pub fn radroots_transport::TransportId::parse_canonical(impl core::convert::AsRef<str>) -> core::result::Result<Self, radroots_transport::error::Error> 815 impl core::convert::AsRef<str> for radroots_transport::TransportId 816 pub fn radroots_transport::TransportId::as_ref(&self) -> &str 817 impl core::convert::From<radroots_protocol::capability::v1::TransportKind> for radroots_transport::TransportId 818 pub fn radroots_transport::TransportId::from(radroots_protocol::capability::v1::TransportKind) -> Self 819 impl core::convert::From<radroots_transport::TransportId> for radroots_protocol::capability::v1::TransportKind 820 pub fn radroots_protocol::capability::v1::TransportKind::from(radroots_transport::TransportId) -> Self 821 impl core::convert::TryFrom<&str> for radroots_transport::TransportId 822 pub type radroots_transport::TransportId::Error = radroots_transport::error::Error 823 pub fn radroots_transport::TransportId::try_from(&str) -> core::result::Result<Self, Self::Error> 824 impl core::convert::TryFrom<alloc::string::String> for radroots_transport::TransportId 825 pub type radroots_transport::TransportId::Error = radroots_transport::error::Error 826 pub fn radroots_transport::TransportId::try_from(alloc::string::String) -> core::result::Result<Self, Self::Error> 827 impl core::fmt::Display for radroots_transport::TransportId 828 pub fn radroots_transport::TransportId::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result 829 impl core::str::traits::FromStr for radroots_transport::TransportId 830 pub type radroots_transport::TransportId::Err = radroots_transport::error::Error 831 pub fn radroots_transport::TransportId::from_str(&str) -> core::result::Result<Self, Self::Err> 832 impl serde_core::ser::Serialize for radroots_transport::TransportId 833 pub fn radroots_transport::TransportId::serialize<S>(&self, S) -> core::result::Result<<S as serde_core::ser::Serializer>::Ok, <S as serde_core::ser::Serializer>::Error> where S: serde_core::ser::Serializer 834 impl<'de> serde_core::de::Deserialize<'de> for radroots_transport::TransportId 835 pub fn radroots_transport::TransportId::deserialize<D>(D) -> core::result::Result<Self, <D as serde_core::de::Deserializer>::Error> where D: serde_core::de::Deserializer<'de> 836 pub const radroots_transport::TARGET_SET_MAX_ITEMS: usize 837 pub const radroots_transport::TRANSPORT_ID_MAX_BYTES: usize 838 pub trait radroots_transport::EventSink: core::marker::Send + core::marker::Sync 839 pub fn radroots_transport::EventSink::deliver(&self, radroots_transport::sink::DeliveryRequest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::sink::DeliveryReceipt, radroots_transport::sink::SinkFailure>> 840 pub fn radroots_transport::EventSink::deliver_selected(&self, radroots_transport::sink::DeliveryRequest, radroots_transport::target::TargetSet) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::sink::DeliveryReceipt, radroots_transport::sink::SinkFailure>> 841 pub fn radroots_transport::EventSink::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::SinkStatus, radroots_transport::error::Error>> 842 pub trait radroots_transport::EventSource: core::marker::Send + core::marker::Sync 843 pub fn radroots_transport::EventSource::fetch(&self, radroots_transport::source::FetchRequest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::source::FetchPage, radroots_transport::error::Error>> 844 pub fn radroots_transport::EventSource::status(&self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::SourceStatus, radroots_transport::error::Error>> 845 pub trait radroots_transport::EventSubscriber: core::marker::Send + core::marker::Sync 846 pub fn radroots_transport::EventSubscriber::subscribe(&self, radroots_transport::source::SubscriptionRequest) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::source::BoxSubscription, radroots_transport::error::Error>> 847 pub trait radroots_transport::EventSubscription: core::marker::Send 848 pub fn radroots_transport::EventSubscription::cancel(&mut self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::source::SubscriptionEnd, radroots_transport::error::Error>> 849 pub fn radroots_transport::EventSubscription::next(&mut self) -> radroots_transport::source::BoxFuture<'_, core::result::Result<radroots_transport::source::SubscriptionNext, radroots_transport::error::Error>> 850 pub fn radroots_transport::EventSubscription::request(&self) -> &radroots_transport::source::SubscriptionRequest 851 pub type radroots_transport::BoxFuture<'a, T> = core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = T> + core::marker::Send + 'a)>> 852 pub type radroots_transport::BoxSubscription = alloc::boxed::Box<dyn radroots_transport::source::EventSubscription>