tenthe commented on PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#issuecomment-2014586542
This is really amazing, thank you very much @wyyolo and @RobertIndie.
I've also started a discussion to talk about ideas on how we can integrate
the clients into our test environment
luoluoyuyu commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1524789928
##
streampipes-model/src/main/java/org/apache/streampipes/model/schema/EventProperty.java:
##
@@ -46,7 +46,6 @@ public abstract class EventProperty {
private
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1469571576
##
streampipes-client-go/streampipes/internal/api/DataLakeMeasureApi.go:
##
@@ -0,0 +1,79 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or mor
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1469576841
##
streampipes-client-go/streampipes/internal/StatuCode/code.go:
##
@@ -0,0 +1,27 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// co
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1469580033
##
streampipes-client-go/streampipes/internal/config/ClientConnectionConfig.go:
##
@@ -0,0 +1,67 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1531469907
##
streampipes-client-go/streampipes/data_lake_measure_api.go:
##
@@ -0,0 +1,194 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// con
RobertIndie commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1534000794
##
streampipes-client-go/streampipes/data_lake_measure_api.go:
##
@@ -0,0 +1,180 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1531486578
##
streampipes-client-go/streampipes/data_lake_measure_api.go:
##
@@ -0,0 +1,194 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// con
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1531486578
##
streampipes-client-go/streampipes/data_lake_measure_api.go:
##
@@ -0,0 +1,194 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// con
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1531486578
##
streampipes-client-go/streampipes/data_lake_measure_api.go:
##
@@ -0,0 +1,194 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// con
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1531486578
##
streampipes-client-go/streampipes/data_lake_measure_api.go:
##
@@ -0,0 +1,194 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// con
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1531469907
##
streampipes-client-go/streampipes/data_lake_measure_api.go:
##
@@ -0,0 +1,194 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// con
RobertIndie commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1530647910
##
streampipes-client-go/streampipes/data_lake_measure_api.go:
##
@@ -0,0 +1,194 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+
it.
+ The client provides so-called "API", each of which refers to the endpoint of
the StreamPipes API.
+ e.g. `DataLakeMeasure` provides the actual methods to interact with
StreamPipes API.
+*/
+
+type StreamPipesClient struct {
+ Config config.StreamPipesClientConfig
+}
+
+fu
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1518551715
##
streampipes-client-go/streampipes/internal/streampipes_http/delete_request.go:
##
@@ -0,0 +1,79 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under o
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1518551375
##
streampipes-client-go/streampipes/internal/statu_code/code.go:
##
@@ -0,0 +1,27 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// c
RobertIndie commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1517558722
##
streampipes-client-go/streampipes/internal/util/streampipes_api_path.go:
##
@@ -0,0 +1,66 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under o
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1517491377
##
streampipes-client-go/streampipes/internal/util/streampipes_api_path.go:
##
@@ -0,0 +1,66 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1517429107
##
streampipes-client-go/streampipes/internal/streampipes_http/delete_request.go:
##
@@ -0,0 +1,79 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under o
RobertIndie commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1516380856
##
streampipes-client-go/streampipes/internal/statu_code/code.go:
##
Review Comment:
There is a problem with the error_code design.
Do you want thes
it.
+ The client provides so-called "API", each of which refers to the endpoint of
the StreamPipes API.
+ e.g. `DataLakeMeasure` provides the actual methods to interact with
StreamPipes API.
+*/
+
+type StreamPipesClient struct {
+ Config config.StreamPipesClient
"License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is
RobertIndie commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1512943144
##
streampipes-client-go/streampipes/api/data_lake_measure_api.go:
##
@@ -0,0 +1,121 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or
RobertIndie commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1512941799
##
streampipes-client-go/streampipes/data_lake_measure_api.go:
##
@@ -0,0 +1,117 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1512088371
##
streampipes-client-go/streampipes/api/data_lake_measure_api.go:
##
@@ -0,0 +1,121 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1512084655
##
streampipes-client-go/streampipes/data_lake_measure_api.go:
##
@@ -0,0 +1,117 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// con
RobertIndie commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1511291546
##
streampipes-client-go/streampipes/streampipes_credentials.go:
##
@@ -0,0 +1,26 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
s
+
+import (
+ "errors"
+ "log"
+ "net/url"
+ "regexp"
+ "streampipes-client-go/streampipes/api"
+ "streampipes-client-go/streampipes/config"
+ "streampipes-client-go/streampipes/internal/cre
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1499397781
##
streampipes-client-go/streampipes/api/data_lake_measure_api.go:
##
@@ -0,0 +1,121 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
wy-os commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1499383964
##
streampipes-client-go/streampipes/api/data_lake_measure_api.go:
##
@@ -0,0 +1,121 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+package streampipes
+
+import (
+ "errors"
+ "log"
+ "net/url"
+ "regexp"
+
OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+package streampipes
+
+import (
+ "errors"
+ "log"
+ "net/url"
+ "regexp"
+
reampipes-client-go/streampipes/internal/util"
```
##
streampipes-client-go/streampipes/api/data_stream_api.go:
##
@@ -0,0 +1,36 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for ad
RobertIndie commented on code in PR #2437:
URL: https://github.com/apache/streampipes/pull/2437#discussion_r1481620818
##
streampipes-client-go/go.mod:
##
@@ -0,0 +1,20 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreemen
e for the specific language governing permissions and
+// limitations under the License.
+//
+
+package streampipes
+
+import (
+ "errors"
+ "streampipes-client-go/streampipes/api"
+ "streampipes-client-go/streampipes/config"
+)
+
+/*
+ This is the central
tenthe commented on issue #1101:
URL: https://github.com/apache/streampipes/issues/1101#issuecomment-1410685040
Cool, thanks. I'll have a look at it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
deexidee commented on issue #1101:
URL: https://github.com/apache/streampipes/issues/1101#issuecomment-1410135834
Sorry for missing for a while, had a busy week.
I made the PR, feel free to review :)
--
This is an automated message from the Apache Git Service.
To respond to the message,
version of the API?
I’m also adding the dev list to cc, so that everyone is up-to-date and can give
feedback.
Dominik
From: Philipp Zehnder
Sent: Thursday, January 7, 2021 12:07 PM
To: Volz, Friedrich
Cc: Branislav Jovicic ; Dominik Riemer
Subject: Re: Streampipes API
Hi
> How can users get an API Token?
>
> Philipp
>
> > On 2. Jan 2021, at 19:55, Dominik Riemer wrote:
> >
> > Hi all,
> >
> >
> >
> > first of all, happy new year to everyone!
> >
> >
> >
> > I've started to wor
>
> first of all, happy new year to everyone!
>
>
>
> I've started to work on the new StreamPipes API, which we've had on our
> roadmap for quite some time now. The API will expose some currently
> internally managed features to developers, e.g., receiving h
Hi all,
first of all, happy new year to everyone!
I've started to work on the new StreamPipes API, which we've had on our
roadmap for quite some time now. The API will expose some currently
internally managed features to developers, e.g., receiving historical and
live data
Dominik Riemer created STREAMPIPES-272:
--
Summary: StreamPipes API
Key: STREAMPIPES-272
URL: https://issues.apache.org/jira/browse/STREAMPIPES-272
Project: StreamPipes
Issue Type: New
42 matches
Mail list logo
