Python client async and admin upgrade

[digikata]

Async

Add python async capable versions of the following fluvio python client capabilities.

• PartitionConsumer

  • stream
  • stream_with_config

• MultiplePartitionConsumer

  • stream
  • stream_with_config

• TopicProducer

  • send
  • flush
  • send_all

The producer and consumer capabilities should also be able to be instantiated with config options in order to run with smartmodules. See Fluvio rust examples where config structs can specify smartmodules and their parameters to execute.

• fn fluvio_producer_with_config(...)
• PartitionConsumer::stream_with_config
• MultiplePartitionConsumer::stream_with_config

The async additions should not interfere the simpler sync versions . If it makes the implementation easier, a set of async classes could be created e.g. AsyncPartitionConsumer. Though if possible a single class is preferred with methods to create sync and async produce and consume objs.

Admin

Add the ability to run the Fluvio admin commands.

Map rust crate admin methods https://docs.rs/fluvio/latest/fluvio/struct.FluvioAdmin.html

• connect
• connect_with_config

Since the create, delete, list methods are generic over various object types, they should work for combinations available to the fluvio cli:

• topics (TopicSpec)

  • create
  • delete
  • list
  • list_with_params
  • watch
  • smartmodules (SmartModuleSpec)
  • create
  • delete
  • list
  • watch

• partitions

  • list

Reference links

• fluvio rust crate docs https://docs.rs/fluvio/latest/fluvio/
• fluvio python docs https://infinyon.github.io/fluvio-client-python/fluvio.html
• PyO3 async docs https://pyo3.rs/v0.13.2/ecosystem/async-await

[sehz]

see https://pyo3.rs/v0.13.2/ecosystem/async-await

[digikata]

Merged comments as well as https://github.com/infinyon/fluvio-client-python/issues/257, closed #257

[digikata]

Merged https://github.com/infinyon/fluvio-client-python/pull/377 w/ async support from @Shylock-Hg