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

Add support for decoding event streams #686

Merged
merged 7 commits into from
Jul 20, 2023
Merged

Add support for decoding event streams #686

merged 7 commits into from
Jul 20, 2023

Conversation

adam-fowler
Copy link
Member

@adam-fowler adam-fowler commented Jul 19, 2023

  • Generated code for event stream parsing
  • Removed custom S3 selectObjectContent as this is now support by the generic implementation in SotoCore

Related PRs soto-project/soto-core#566, soto-project/soto-codegenerator#74

@adam-fowler adam-fowler requested a review from 0xTim July 19, 2023 15:18
Copy link
Member

@0xTim 0xTim left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Query around the flipping of max values for an Int64 - unsure if this was intentional or not but it doesn't feel like it

@@ -1378,7 +1378,7 @@ extension IoTEventsData {
}

public func validate(name: String) throws {
try self.validate(self.timeInMillis, name: "timeInMillis", parent: name, max: 9223372036854775807)
try self.validate(self.timeInMillis, name: "timeInMillis", parent: name, max: -9223372036854775808)
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Was this meant to switch to the minimum value for an Int64?

@@ -583,7 +583,7 @@ extension KafkaConnect {
}

public func validate(name: String) throws {
try self.validate(self.revision, name: "revision", parent: name, max: 9223372036854775807)
try self.validate(self.revision, name: "revision", parent: name, max: -9223372036854775808)
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

As above

@@ -1630,7 +1630,7 @@ extension KafkaConnect {
}

public func validate(name: String) throws {
try self.validate(self.revision, name: "revision", parent: name, max: 9223372036854775807)
try self.validate(self.revision, name: "revision", parent: name, max: -9223372036854775808)
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

As above

@adam-fowler adam-fowler merged commit f699448 into 7.x.x Jul 20, 2023
@adam-fowler adam-fowler deleted the event-stream branch July 20, 2023 09:19
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.

2 participants