Add optional connector connect success and failure callbacks

[tim-quix]

What

Provides the ability to add an optional callback for a connection attempt with a connector.

NOTE: There are defaults that use our desired Quix Cloud log output.

A setup_client method is now an additional requirement when constructing a new connector template.

How to Use

This feature is fully backwards compatible: usage does not change for users who do not wish to use the callback.

To use it, the pattern is the same across all sources and sinks:

from quixstreams.sinks.core.influxdb3 import InfluxDB3Sink

def client_connect_success_cb():
    print(f"CONNECTED!")

def client_connect_failure_cb(error):
    print(f"ERROR!")
    raise error

influxdb_sink = InfluxDB3Sink(
    token="BAD TOKEN",
    host="my host",
    ...,
    client_connect_success_cb=client_connect_success_cb,
    client_connect_failure_cb=client_connect_failure_cb,
)

Other things:

• standardized some things like attributes across sources and sinks
• added minor things in order to test connections as expected (some client setups do not connect it immediately)
• fixed a few bugs here n' there

[gwaramadze]

A fistful of comments.

[gwaramadze]

I like the change😉

I'm still rather against locking on the "client" word, but it's just a name, not a big blocker.

A separate problem I see here is the fact that we don't really test community connectors and I see a ton of changes. A tad too much to be confident that everything will click 🙈

[gwaramadze]

This is defined twice. I just realized we don't have a place for a common source/sink code 🤔
Not sure where to put it. Did you think about it?

[tim-quix]

Yeah, I was thinking we could maybe put something in our quixstreams/utils, or maybe a new file or folder in root like quixstreams/connector-utils,

Maybe right now we aren't at the tipping point for common code quite yet, but it did cross my mind for sure.

We also run into similar things with the various connection patterns across all the sources/sinks. Lots of duplicated code here n' there.