Crate fluvio_socket[−][src]
Structs
| AsyncResponse | Implement async socket where response are send back async manner they are queued using channel |
| InnerExclusiveFlvSink | Multi-thread aware Sink. Only allow sending request one a time. |
| InnerFlvSink | |
| InnerFlvSocket | Socket abstract that can send and receive fluvio objects |
| InnerFlvStream | inner flv stream which is generic over stream |
| MultiplexerSocket | Socket that can multiplex connections |
| SinkPool | Pool of sinks. This is lightweight version of SocketPool where you only need to keep track of sink no attemp to keep id indexes |
| SocketPool | pooling of sockets |
Enums
| FlvSocketError |
Functions
| send_and_receive | send request and return response from calling server at socket addr |
Type Definitions
| DefaultMultiplexerSocket | |
| ExclusiveFlvSink | |
| FlvSink | |
| FlvSocket | |
| FlvStream | |
| SharedMultiplexerSocket | |
| SharedSinkPool |