Crate fluvio_socket

Structs

Implement async socket where response are send back async manner they are queued using channel

Low level configuration option to directly connect to Fluvio This can bypass higher level validation required for CLI and end user application

Multi-thread aware Sink. Only allow sending request one a time.

Socket abstract that can send and receive fluvio objects

inner flv stream which is generic over stream

Socket that can multiplex connections

Connection that perform request/response

This sockets knows about support versions Version information are automatically insert into request

wrap around versions

Frame with request and response

send request and return response from calling server at socket addr