[−][src]Crate fluvio_service
Macros
api_loop | |
call_service | |
wait_for_request | wait for a single request |
Structs
DefaultSocketBuilder | |
FluvioCodec | Implement Kafka codec as in https://kafka.apache.org/protocol#The_Messages_ListOffsets First 4 bytes are size of the message. Then total buffer = 4 + message content |
InnerFlvApiServer | Transform Service into Futures 01 |
Traits
FlvService | Trait for responding to kf service Request -> Response is type specific Each response is responsible for sending back to socket |
SocketBuilder |
Type Definitions
FlvApiServer |