[][src]Crate fluvio_socket

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