Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Native improvements 4 - Renaming and event signature changes #39

Merged
merged 17 commits into from
Feb 22, 2023

Conversation

peter-quix
Copy link
Contributor

@peter-quix peter-quix commented Feb 21, 2023

Breaking changes

  • Added input_topic to all stream events (such as parameters.on_read, on_raw_read, definitions change, same for events and properties).
  • Renamed ParameterData -> TimeseriesData and ParameterBuffer -> TimeseriesBuffer and related classes
  • Renamed IOutput, IInput to IConsumer and IProducer in Transport layer.
  • Renamed ExceptionOccurred to OnExceptionOccurred
  • Renamed KafkaReader/Writer to TelemetryKafkaConsumer/Producer
  • Renamed Input/OutputTopic to TopicConsumer/Producer.
  • Renamed StartReading to Subscribe
  • Renamed Write/Send to Publish
  • Renamed SDK -> Streams and Quix Streams depending on context
  • Default consumer group is no longer "Default" and AutoOffsetReset is set to Latest rather than Earliest

Other:

  • Docs updated to reflect changes above
  • Apply renaming of variables where needed
  • Deleted some invalid/outdated docs regarding local setup
  • Moved Quix topic/consumer logic from KafkaStreamingClient to QuixStreamingClient
  • Now handling exceptions in callbacks when a user doesn't do exception handling. Helps to detect bad callback signatures and similar
  • Handle no partition info by throwing exception rather than silently failing when no consumer group is in use
  • Cleanup Usings in C# and imports in Python

* Apply renaming of variables where needed
* Rename ExceptionOccurred to OnExceptionOccurred
* rename SubscriberConfiguration to ConsumerConfiguration
* Rename StartReading to Subscribe
* Rename Write/Send to Publish
* Handle no partition info by throwing exception
* Properly (well hackily) implement no consumer group for QuixStreamingClient
* Fix python integration tests
@peter-quix peter-quix marked this pull request as ready for review February 21, 2023 23:30
@SteveRosam SteveRosam merged commit fb82bac into main Feb 22, 2023
peter-quix added a commit that referenced this pull request Feb 22, 2023
Breaking changes
* Added input_topic to all stream events (such as parameters.on_read, on_raw_read, definitions change, same for events and properties).
* Renamed ParameterData -> TimeseriesData and ParameterBuffer -> TimeseriesBuffer and related classes
* Renamed IOutput, IInput to IConsumer and IProducer in Transport layer.
* Renamed ExceptionOccurred to OnExceptionOccurred
* Renamed KafkaReader/Writer to TelemetryKafkaConsumer/Producer
* Renamed Input/OutputTopic to TopicConsumer/Producer.
* Renamed StartReading to Subscribe
* Renamed Write/Send to Publish
* Renamed SDK -> Streams and Quix Streams depending on context
* Default consumer group is no longer "Default" and AutoOffsetReset is set to Latest rather than Earliest

Other:
* Docs updated to reflect changes above
* Apply renaming of variables where needed
* Deleted some invalid/outdated docs regarding local setup
* Moved Quix topic/consumer logic from KafkaStreamingClient to QuixStreamingClient
* Now handling exceptions in callbacks when a user doesn't do exception handling. Helps to detect bad callback signatures and similar
* Handle no partition info by throwing exception rather than silently failing when no consumer group is in use
* Cleanup Usings in C# and imports in Python
@peter-quix peter-quix deleted the feature/native-improvements-4 branch July 19, 2023 11:44
tim-quix pushed a commit that referenced this pull request Nov 14, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants