1. 1. JetStream
  2. 2. 📍🗺️ Distributed JetStream
  3. 3. 🆕 Changelog
  4. 4. Coverage
  5. 5. 🦀 Crates
    1. 5.1.  Crate jetstream
    2. 5.2.  Module prelude
    3. 5.3. Attribute Macro async_trait
    4. 5.4. Attribute Macro make
    5. 5.5. Attribute Macro service
    6. 5.6.  Module client
    7. 5.7.  Struct ClientCodec
    8. 5.8.  Module websocket
    9. 5.9.  Struct WebSocketTransport
    10. 5.10.  Struct WebsocketFrame
    11. 5.11. Derive Macro JetStreamWireFormat
    12. 5.12.  Enum Error
    13. 5.13.  Function initialize
    14. 5.14.  Macro lazy_static
    15. 5.15.  Module p9
    16. 5.16.  Constant DEFAULT_MSIZE
    17. 5.17.  Constant MAPPED_FLAGS
    18. 5.18.  Constant MAX_MESSAGE_SIZE
    19. 5.19.  Constant MIN_MESSAGE_SIZE
    20. 5.20.  Constant P9_APPEND
    21. 5.21.  Constant P9_CREATE
    22. 5.22.  Constant P9_DIRECT
    23. 5.23.  Constant P9_DIRECTORY
    24. 5.24.  Constant P9_DSYNC
    25. 5.25.  Constant P9_EXCL
    26. 5.26.  Constant P9_FASYNC
    27. 5.27.  Constant P9_GETATTR_BASIC
    28. 5.28.  Constant P9_LARGEFILE
    29. 5.29.  Constant P9_LOCK_SUCCESS
    30. 5.30.  Constant P9_LOCK_TYPE_UNLCK
    31. 5.31.  Constant P9_NOACCESS
    32. 5.32.  Constant P9_NOATIME
    33. 5.33.  Constant P9_NOCTTY
    34. 5.34.  Constant P9_NOFOLLOW
    35. 5.35.  Constant P9_NONBLOCK
    36. 5.36.  Constant P9_QTDIR
    37. 5.37.  Constant P9_QTFILE
    38. 5.38.  Constant P9_QTSYMLINK
    39. 5.39.  Constant P9_RDONLY
    40. 5.40.  Constant P9_RDWR
    41. 5.41.  Constant P9_SETATTR_ATIME
    42. 5.42.  Constant P9_SETATTR_ATIME_SET
    43. 5.43.  Constant P9_SETATTR_CTIME
    44. 5.44.  Constant P9_SETATTR_GID
    45. 5.45.  Constant P9_SETATTR_MODE
    46. 5.46.  Constant P9_SETATTR_MTIME
    47. 5.47.  Constant P9_SETATTR_MTIME_SET
    48. 5.48.  Constant P9_SETATTR_SIZE
    49. 5.49.  Constant P9_SETATTR_UID
    50. 5.50.  Constant P9_SYNC
    51. 5.51.  Constant P9_TRUNC
    52. 5.52.  Constant P9_WRONLY
    53. 5.53.  Constant _P9_CLOEXEC
    54. 5.54.  Constant _P9_GETATTR_ALL
    55. 5.55.  Constant _P9_GETATTR_ATIME
    56. 5.56.  Constant _P9_GETATTR_BLOCKS
    57. 5.57.  Constant _P9_GETATTR_BTIME
    58. 5.58.  Constant _P9_GETATTR_CTIME
    59. 5.59.  Constant _P9_GETATTR_DATA_VERSION
    60. 5.60.  Constant _P9_GETATTR_GEN
    61. 5.61.  Constant _P9_GETATTR_GID
    62. 5.62.  Constant _P9_GETATTR_INO
    63. 5.63.  Constant _P9_GETATTR_MODE
    64. 5.64.  Constant _P9_GETATTR_MTIME
    65. 5.65.  Constant _P9_GETATTR_NLINK
    66. 5.66.  Constant _P9_GETATTR_RDEV
    67. 5.67.  Constant _P9_GETATTR_SIZE
    68. 5.68.  Constant _P9_GETATTR_UID
    69. 5.69.  Constant _P9_LOCK_BLOCKED
    70. 5.70.  Constant _P9_LOCK_ERROR
    71. 5.71.  Constant _P9_LOCK_FLAGS_BLOCK
    72. 5.72.  Constant _P9_LOCK_FLAGS_RECLAIM
    73. 5.73.  Constant _P9_LOCK_GRACE
    74. 5.74.  Constant _P9_LOCK_TYPE_RDLCK
    75. 5.75.  Constant _P9_LOCK_TYPE_WRLCK
    76. 5.76.  Constant _P9_QTAPPEND
    77. 5.77.  Constant _P9_QTAUTH
    78. 5.78.  Constant _P9_QTEXCL
    79. 5.79.  Constant _P9_QTLINK
    80. 5.80.  Constant _P9_QTMOUNT
    81. 5.81.  Constant _P9_QTTMP
    82. 5.82.  Enum Rmessage
    83. 5.83.  Enum Tmessage
    84. 5.84.  Enum Version
    85. 5.85.  Function error_to_rmessage
    86. 5.86.  Module messages
    87. 5.87.  Enum Rmessage
    88. 5.88.  Enum Tmessage
    89. 5.89.  Struct Dirent
    90. 5.90.  Struct Qid
    91. 5.91.  Struct Rattach
    92. 5.92.  Struct Rauth
    93. 5.93.  Struct Rerror
    94. 5.94.  Struct Rframe
    95. 5.95.  Struct Rgetattr
    96. 5.96.  Struct Rgetlock
    97. 5.97.  Struct Rlcreate
    98. 5.98.  Struct Rlerror
    99. 5.99.  Struct Rlock
    100. 5.100.  Struct Rlopen
    101. 5.101.  Struct Rmkdir
    102. 5.102.  Struct Rmknod
    103. 5.103.  Struct Rread
    104. 5.104.  Struct Rreaddir
    105. 5.105.  Struct Rreadlink
    106. 5.106.  Struct Rstatfs
    107. 5.107.  Struct Rsymlink
    108. 5.108.  Struct Rversion
    109. 5.109.  Struct Rwalk
    110. 5.110.  Struct Rwrite
    111. 5.111.  Struct Rxattrwalk
    112. 5.112.  Struct Tattach
    113. 5.113.  Struct Tauth
    114. 5.114.  Struct Tclunk
    115. 5.115.  Struct Tflush
    116. 5.116.  Struct Tframe
    117. 5.117.  Struct Tfsync
    118. 5.118.  Struct Tgetattr
    119. 5.119.  Struct Tgetlock
    120. 5.120.  Struct Tlcreate
    121. 5.121.  Struct Tlink
    122. 5.122.  Struct Tlock
    123. 5.123.  Struct Tlopen
    124. 5.124.  Struct Tmkdir
    125. 5.125.  Struct Tmknod
    126. 5.126.  Struct Tread
    127. 5.127.  Struct Treaddir
    128. 5.128.  Struct Treadlink
    129. 5.129.  Struct Tremove
    130. 5.130.  Struct Trename
    131. 5.131.  Struct Trenameat
    132. 5.132.  Struct Tsetattr
    133. 5.133.  Struct Tstatfs
    134. 5.134.  Struct Tsymlink
    135. 5.135.  Struct Tunlinkat
    136. 5.136.  Struct Tversion
    137. 5.137.  Struct Twalk
    138. 5.138.  Struct Twrite
    139. 5.139.  Struct Txattrcreate
    140. 5.140.  Struct Txattrwalk
    141. 5.141.  Module ninep_2000_l
    142. 5.142.  Trait NineP200L
    143. 5.143.  Struct Dirent
    144. 5.144.  Struct Qid
    145. 5.145.  Struct Rattach
    146. 5.146.  Struct Rauth
    147. 5.147.  Struct Rerror
    148. 5.148.  Struct Rframe
    149. 5.149.  Struct Rgetattr
    150. 5.150.  Struct Rgetlock
    151. 5.151.  Struct Rlcreate
    152. 5.152.  Struct Rlerror
    153. 5.153.  Struct Rlock
    154. 5.154.  Struct Rlopen
    155. 5.155.  Struct Rmkdir
    156. 5.156.  Struct Rmknod
    157. 5.157.  Struct Rread
    158. 5.158.  Struct Rreaddir
    159. 5.159.  Struct Rreadlink
    160. 5.160.  Struct Rstatfs
    161. 5.161.  Struct Rsymlink
    162. 5.162.  Struct Rversion
    163. 5.163.  Struct Rwalk
    164. 5.164.  Struct Rwrite
    165. 5.165.  Struct Rxattrwalk
    166. 5.166.  Struct Tattach
    167. 5.167.  Struct Tauth
    168. 5.168.  Struct Tclunk
    169. 5.169.  Struct Tflush
    170. 5.170.  Struct Tframe
    171. 5.171.  Struct Tfsync
    172. 5.172.  Struct Tgetattr
    173. 5.173.  Struct Tgetlock
    174. 5.174.  Struct Tlcreate
    175. 5.175.  Struct Tlink
    176. 5.176.  Struct Tlock
    177. 5.177.  Struct Tlopen
    178. 5.178.  Struct Tmkdir
    179. 5.179.  Struct Tmknod
    180. 5.180.  Struct Tread
    181. 5.181.  Struct Treaddir
    182. 5.182.  Struct Treadlink
    183. 5.183.  Struct Tremove
    184. 5.184.  Struct Trename
    185. 5.185.  Struct Trenameat
    186. 5.186.  Struct Tsetattr
    187. 5.187.  Struct Tstatfs
    188. 5.188.  Struct Tsymlink
    189. 5.189.  Struct Tunlinkat
    190. 5.190.  Struct Tversion
    191. 5.191.  Struct Twalk
    192. 5.192.  Struct Twrite
    193. 5.193.  Struct Txattrcreate
    194. 5.194.  Struct Txattrwalk
    195. 5.195.  Module server
    196. 5.196.  Module proxy
    197. 5.197.  Module quic
    198. 5.198.  Module service
    199. 5.199.  Function run
    200. 5.200.  Struct ServerCodec
    201. 5.201.  Trait ListenerStream
    202. 5.202.  Struct Data
    203. 5.203.  Struct Frame
    204. 5.204.  Struct Framed
    205. 5.205.  Struct Tag
    206. 5.206.  Trait ClientTransport
    207. 5.207.  Trait Framer
    208. 5.208.  Trait LazyStatic
    209. 5.209.  Trait Message
    210. 5.210.  Trait Protocol
    211. 5.211.  Trait ServiceTransport
    212. 5.212.  Trait WireFormat
    213. 5.213.  Trait __Deref
    214. 5.214.  Crate jetstream_9p
    215. 5.215.  Constant DEFAULT_MSIZE
    216. 5.216.  Constant MAPPED_FLAGS
    217. 5.217.  Constant MAX_MESSAGE_SIZE
    218. 5.218.  Constant MIN_MESSAGE_SIZE
    219. 5.219.  Constant P9_APPEND
    220. 5.220.  Constant P9_CREATE
    221. 5.221.  Constant P9_DIRECT
    222. 5.222.  Constant P9_DIRECTORY
    223. 5.223.  Constant P9_DSYNC
    224. 5.224.  Constant P9_EXCL
    225. 5.225.  Constant P9_FASYNC
    226. 5.226.  Constant P9_GETATTR_BASIC
    227. 5.227.  Constant P9_LARGEFILE
    228. 5.228.  Constant P9_LOCK_SUCCESS
    229. 5.229.  Constant P9_LOCK_TYPE_UNLCK
    230. 5.230.  Constant P9_NOACCESS
    231. 5.231.  Constant P9_NOATIME
    232. 5.232.  Constant P9_NOCTTY
    233. 5.233.  Constant P9_NOFOLLOW
    234. 5.234.  Constant P9_NONBLOCK
    235. 5.235.  Constant P9_QTDIR
    236. 5.236.  Constant P9_QTFILE
    237. 5.237.  Constant P9_QTSYMLINK
    238. 5.238.  Constant P9_RDONLY
    239. 5.239.  Constant P9_RDWR
    240. 5.240.  Constant P9_SETATTR_ATIME
    241. 5.241.  Constant P9_SETATTR_ATIME_SET
    242. 5.242.  Constant P9_SETATTR_CTIME
    243. 5.243.  Constant P9_SETATTR_GID
    244. 5.244.  Constant P9_SETATTR_MODE
    245. 5.245.  Constant P9_SETATTR_MTIME
    246. 5.246.  Constant P9_SETATTR_MTIME_SET
    247. 5.247.  Constant P9_SETATTR_SIZE
    248. 5.248.  Constant P9_SETATTR_UID
    249. 5.249.  Constant P9_SYNC
    250. 5.250.  Constant P9_TRUNC
    251. 5.251.  Constant P9_WRONLY
    252. 5.252.  Constant _P9_CLOEXEC
    253. 5.253.  Constant _P9_GETATTR_ALL
    254. 5.254.  Constant _P9_GETATTR_ATIME
    255. 5.255.  Constant _P9_GETATTR_BLOCKS
    256. 5.256.  Constant _P9_GETATTR_BTIME
    257. 5.257.  Constant _P9_GETATTR_CTIME
    258. 5.258.  Constant _P9_GETATTR_DATA_VERSION
    259. 5.259.  Constant _P9_GETATTR_GEN
    260. 5.260.  Constant _P9_GETATTR_GID
    261. 5.261.  Constant _P9_GETATTR_INO
    262. 5.262.  Constant _P9_GETATTR_MODE
    263. 5.263.  Constant _P9_GETATTR_MTIME
    264. 5.264.  Constant _P9_GETATTR_NLINK
    265. 5.265.  Constant _P9_GETATTR_RDEV
    266. 5.266.  Constant _P9_GETATTR_SIZE
    267. 5.267.  Constant _P9_GETATTR_UID
    268. 5.268.  Constant _P9_LOCK_BLOCKED
    269. 5.269.  Constant _P9_LOCK_ERROR
    270. 5.270.  Constant _P9_LOCK_FLAGS_BLOCK
    271. 5.271.  Constant _P9_LOCK_FLAGS_RECLAIM
    272. 5.272.  Constant _P9_LOCK_GRACE
    273. 5.273.  Constant _P9_LOCK_TYPE_RDLCK
    274. 5.274.  Constant _P9_LOCK_TYPE_WRLCK
    275. 5.275.  Constant _P9_QTAPPEND
    276. 5.276.  Constant _P9_QTAUTH
    277. 5.277.  Constant _P9_QTEXCL
    278. 5.278.  Constant _P9_QTLINK
    279. 5.279.  Constant _P9_QTMOUNT
    280. 5.280.  Constant _P9_QTTMP
    281. 5.281.  Enum Version
    282. 5.282.  Function error_to_rmessage
    283. 5.283.  Module messages
    284. 5.284.  Enum Rmessage
    285. 5.285.  Enum Tmessage
    286. 5.286.  Struct Dirent
    287. 5.287.  Struct Qid
    288. 5.288.  Struct Rattach
    289. 5.289.  Struct Rauth
    290. 5.290.  Struct Rerror
    291. 5.291.  Struct Rframe
    292. 5.292.  Struct Rgetattr
    293. 5.293.  Struct Rgetlock
    294. 5.294.  Struct Rlcreate
    295. 5.295.  Struct Rlerror
    296. 5.296.  Struct Rlock
    297. 5.297.  Struct Rlopen
    298. 5.298.  Struct Rmkdir
    299. 5.299.  Struct Rmknod
    300. 5.300.  Struct Rread
    301. 5.301.  Struct Rreaddir
    302. 5.302.  Struct Rreadlink
    303. 5.303.  Struct Rstatfs
    304. 5.304.  Struct Rsymlink
    305. 5.305.  Struct Rversion
    306. 5.306.  Struct Rwalk
    307. 5.307.  Struct Rwrite
    308. 5.308.  Struct Rxattrwalk
    309. 5.309.  Struct Tattach
    310. 5.310.  Struct Tauth
    311. 5.311.  Struct Tclunk
    312. 5.312.  Struct Tflush
    313. 5.313.  Struct Tframe
    314. 5.314.  Struct Tfsync
    315. 5.315.  Struct Tgetattr
    316. 5.316.  Struct Tgetlock
    317. 5.317.  Struct Tlcreate
    318. 5.318.  Struct Tlink
    319. 5.319.  Struct Tlock
    320. 5.320.  Struct Tlopen
    321. 5.321.  Struct Tmkdir
    322. 5.322.  Struct Tmknod
    323. 5.323.  Struct Tread
    324. 5.324.  Struct Treaddir
    325. 5.325.  Struct Treadlink
    326. 5.326.  Struct Tremove
    327. 5.327.  Struct Trename
    328. 5.328.  Struct Trenameat
    329. 5.329.  Struct Tsetattr
    330. 5.330.  Struct Tstatfs
    331. 5.331.  Struct Tsymlink
    332. 5.332.  Struct Tunlinkat
    333. 5.333.  Struct Tversion
    334. 5.334.  Struct Twalk
    335. 5.335.  Struct Twrite
    336. 5.336.  Struct Txattrcreate
    337. 5.337.  Struct Txattrwalk
    338. 5.338.  Module ninep_2000_l
    339. 5.339.  Trait NineP200L
    340. 5.340.  Crate jetstream_client
    341. 5.341.  Struct ClientCodec
    342. 5.342.  Module websocket
    343. 5.343.  Struct WebSocketTransport
    344. 5.344.  Struct WebsocketFrame
    345. 5.345.  Crate jetstream_macros
    346. 5.346. Attribute Macro service
    347. 5.347. Derive Macro JetStreamWireFormat
    348. 5.348.  Crate jetstream_rpc
    349. 5.349.  Enum Error
    350. 5.350.  Struct Context
    351. 5.351.  Struct Frame
    352. 5.352.  Struct Framed
    353. 5.353.  Struct Tag
    354. 5.354.  Trait Channel
    355. 5.355.  Trait ClientTransport
    356. 5.356.  Trait Decoder
    357. 5.357.  Trait Encoder
    358. 5.358.  Trait Framer
    359. 5.359.  Trait FromContext
    360. 5.360.  Trait Handler
    361. 5.361.  Trait Message
    362. 5.362.  Trait Protocol
    363. 5.363.  Trait ServiceTransport
    364. 5.364.  Crate jetstream_server
    365. 5.365.  Module proxy
    366. 5.366.  Module quic
    367. 5.367.  Module service
    368. 5.368.  Function run
    369. 5.369.  Struct ServerCodec
    370. 5.370.  Trait ListenerStream
    371. 5.371.  Crate jetstream_wireformat
    372. 5.372. Derive Macro JetStreamWireFormat
    373. 5.373.  Struct Data
    374. 5.374.  Struct P9String
    375. 5.375.  Struct Wrapped
    376. 5.376.  Trait WireFormat
    377. 5.377.  Module wire_format_extensions
    378. 5.378.  Module tokio
    379. 5.379.  Trait AsyncWireFormatExt
    380. 5.380.  Trait AsyncWireFormat
    381. 5.381.  Trait ConvertWireFormat

JetStream Book

jetstream_rpc

Struct Tag

pub struct Tag(/* private fields */);

Trait Implementations

impl From for Tag

fn from(tag: u16) -> Self

Converts to this type from the input type.

impl<T: WireFormat> FromContext for Tag

fn from_context(ctx: Context) -> Self

Auto Trait Implementations

impl Freeze for Tag

impl RefUnwindSafe for Tag

impl Send for Tag

impl Sync for Tag

impl Unpin for Tag

impl UnwindSafe for Tag

Blanket Implementations

impl Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl Borrow for Twhere T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl BorrowMut for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl From for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T, U> Into for Twhere U: From,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T, U> TryFrom for Twhere U: Into,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

impl<T, U> TryInto for Twhere U: TryFrom,

type Error = <U as TryFrom>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom>::Error>

Performs the conversion.