Crate fluvio_service[][src]

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