-
Notifications
You must be signed in to change notification settings - Fork 5
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
Implement dynamodb streams connector #2
Conversation
Implement DynamoDB streams connector
Welcome to Codecov 🎉Once merged to your default branch, Codecov will compare your coverage reports and display the results in this comment. Thanks for integrating Codecov - We've got you covered ☂️ |
Update docs
Update test cases
Remove unused imports
Refactor the code
Refactor the code
@@ -0,0 +1,41 @@ | |||
name: GraalVM Check |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Do we need both native and graalvm workflows?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We don't need it. Removed with 2cc8a76
Address review suggestions
ballerina/constatnts.bal
Outdated
|
||
const string GENERATE_SIGNED_REQUEST_HEADERS_FAILED_MSG = "Error occurred while generating signed request headers."; | ||
|
||
public enum AttributeType { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Shall we add API docs for public enums. This will appear in API Docs.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Added docs for enum types.
ballerina/stream_implementor.bal
Outdated
} | ||
|
||
public isolated function next() returns record {| Stream value; |}|error? { | ||
if (self.index < self.currentEntries.length()) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
if (self.index < self.currentEntries.length()) { | |
if self.index < self.currentEntries.length() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
please check other places
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Fixed in 9a61dc7
@@ -0,0 +1,43 @@ | |||
import ballerina/io; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
shall we add license headers?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Added in 9a61dc7
ballerina/constatnts.bal
Outdated
@@ -0,0 +1,88 @@ | |||
// Copyright (c) 2024, WSO2 LLC. (http://www.wso2.org) All Rights Reserved. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
typo in the filename constants.bal
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Renamed the file.
Address review suggestions
Co-authored-by: Danesh Kuruppu <daneshk@users.noreply.github.com>
Add the removed constants.bal
Add shard iterator type
Purpose
Implement the DynamoDB Streams connector.
Fixes : ballerina-platform/ballerina-library#5801