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

Implement dynamodb streams connector #2

Merged
merged 30 commits into from
Jan 9, 2024
Merged

Implement dynamodb streams connector #2

merged 30 commits into from
Jan 9, 2024

Conversation

Bhashinee
Copy link
Member

@Bhashinee Bhashinee commented Jan 4, 2024

Purpose

Implement the DynamoDB Streams connector.
Fixes : ballerina-platform/ballerina-library#5801

Copy link

codecov bot commented Jan 4, 2024

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 ☂️

@Bhashinee Bhashinee marked this pull request as ready for review January 8, 2024 03:24
@Bhashinee Bhashinee requested review from daneshk and sahanHe January 8, 2024 03:24
@@ -0,0 +1,41 @@
name: GraalVM Check
Copy link
Member

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?

Copy link
Member Author

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

ballerina/client.bal Outdated Show resolved Hide resolved
ballerina/client.bal Outdated Show resolved Hide resolved

const string GENERATE_SIGNED_REQUEST_HEADERS_FAILED_MSG = "Error occurred while generating signed request headers.";

public enum AttributeType {
Copy link
Member

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.

Copy link
Member Author

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.

}

public isolated function next() returns record {| Stream value; |}|error? {
if (self.index < self.currentEntries.length()) {
Copy link
Member

Choose a reason for hiding this comment

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

Suggested change
if (self.index < self.currentEntries.length()) {
if self.index < self.currentEntries.length() {

Copy link
Member

Choose a reason for hiding this comment

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

please check other places

Copy link
Member Author

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;
Copy link
Member

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?

Copy link
Member Author

Choose a reason for hiding this comment

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

Added in 9a61dc7

@@ -0,0 +1,88 @@
// Copyright (c) 2024, WSO2 LLC. (http://www.wso2.org) All Rights Reserved.
Copy link
Member

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

Copy link
Member Author

Choose a reason for hiding this comment

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

Renamed the file.

@Bhashinee Bhashinee merged commit 74c297e into main Jan 9, 2024
4 checks passed
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.

Implement the dynamodb streams connector
2 participants