-
Notifications
You must be signed in to change notification settings - Fork 193
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
feat: add streampipes go client #2437
Conversation
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.
Good work.
The overall code structure framework looks good to me.
I think it's better to discuss the go client API first. We would better make a consensus on this before we merge this PR.
Could you describe your go client API design in the PR description or in the discussion
here?
And is it possible to write some integration tests for the go client? We would also need to run the tests in the CI.
streampipes-client-go/streampipes/internal/config/ClientConnectionConfig.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/StatuCode/ErrorCode.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/StreamPipesHttp/DeleteRequest.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/api/DataLakeMeasureApi.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/model/DataConversion/DataLakeConversion.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/api/DataLakeMeasureApi.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/api/DataStreamApi.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/model/DataLake/DataLakeMeasure.go
Outdated
Show resolved
Hide resolved
At present, some unit tests have been implemented, and data from the Streampipes API can be received normally by connecting to Streampipes. You can refer to the usage of streams client go/streams/examples/main. go |
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.
Could you test the example and put the test result on the PR description?
streampipes-client-go/streampipes/config/client_connection_config.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/config/client_connection_config.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/util/streampipes_apiPath.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/config/client_connection_config.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/serializer/deserializer.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/serializer/deserializer.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/streampipes_http/delete_request.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/util/streampipes_api_path.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/util/streampipes_api_path.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/util/streampipes_api_path.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/util/streampipes_api_path_test.go
Outdated
Show resolved
Hide resolved
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.
Victory is coming!
streampipes-client-go/streampipes/internal/serializer/deserializer.go
Outdated
Show resolved
Hide resolved
streampipes-client-go/streampipes/internal/serializer/deserializer.go
Outdated
Show resolved
Hide resolved
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.
Awesome work @WY-OS @RobertIndie !
streampipes-model/src/main/java/org/apache/streampipes/model/schema/EventProperty.java
Outdated
Show resolved
Hide resolved
This is really amazing, thank you very much @wyyolo and @RobertIndie. |
Purpose
Remarks
PR introduces (a) breaking change(s): <yes/no>
PR introduces (a) deprecation(s): <yes/no>