Commit Graph

1171 Commits

Author SHA1 Message Date
Oleg Zhurakousky
e3b5e2b0cb GH-590 change README extension 2020-12-21 10:28:21 +01:00
Oleg Zhurakousky
ab59776fb5 GH-590 Add initial RSocket documentation 2020-12-21 10:26:55 +01:00
Oleg Zhurakousky
231e38eb85 Merge pull request #622 from amolkatdare/patch-1
fixed typo. 'dashboard'
2020-12-18 21:10:16 +01:00
Oleg Zhurakousky
dacca71cc2 Clean up AMQP/KAFKA Cloud Event sample README 2020-12-18 18:54:21 +01:00
Oleg Zhurakousky
0d0ef3350c Clean up RSocket Cloud Event sample README 2020-12-18 18:45:54 +01:00
Oleg Zhurakousky
bc4b5b3f80 Add stream (kafka, Rabbit) and Rsocket examples for Cloud Event 2020-12-18 16:44:29 +01:00
Oleg Zhurakousky
eb95e1dd78 Modify logic for header copy from input to output
This is primarily related to Cloud Events. Since we delegate to a separate class for post processing, if outpt message is Cloud Event we will not be doing anything to with regard to header copy in SimpleFunctionRegistry and unstead delegate it to CloudEventFunctionInvocationHelper
2020-12-18 16:44:19 +01:00
amolkatdare
1bf7c436fa fixed typo. 'dashboard' 2020-12-17 16:54:25 -06:00
buildmaster
7ab6cc446b Bumping versions 2020-12-15 18:56:41 +00:00
buildmaster
09611485fe Bumping versions 2020-12-14 18:56:05 +00:00
Oleg Zhurakousky
285fd66858 Fix payload extraction during output conversion
Also, restructured CloudEventsFunctionInvocationHelper's postProcessig logic
2020-12-12 13:48:47 +01:00
buildmaster
9e31994901 Going back to snapshots 2020-12-11 13:43:19 +00:00
buildmaster
794d59317a Update SNAPSHOT to 3.1.0-RC1 2020-12-11 13:41:19 +00:00
Oleg Zhurakousky
e86d397433 Cleaned up Cloud Event support around reactive functions
Added reactive tests
Restructured CloudEventsFunctionInvocationHelper
2020-12-11 14:34:32 +01:00
Oleg Zhurakousky
7403a51464 SCST-2065 Fix deserialization error when multi IO signature
Fix deserializatioin error when using complex signatures such as Function<Tuple2<Flux<Message<String>>
The issue originated from spring cloud stream https://github.com/spring-cloud/spring-cloud-stream/issues/2065
2020-12-10 15:53:05 +01:00
Oleg Zhurakousky
9edc08d97e interim 2020-12-10 07:56:15 +01:00
Oleg Zhurakousky
90c3c35f68 Polish previous commit
Add FunctionInspector dependency back to SimpleFunctionRegistry since we can't remove it yet to avoid backward comatibility issues

Resolves #617
2020-12-08 18:44:16 +01:00
Mingyuan Wu
271bc22969 Disconnect FunctionInspector from AbstractComposableFunctionRegistry and SimpleFunctionRegistry 2020-12-08 17:31:56 +01:00
Oleg Zhurakousky
555526192f GH-618 Remove dependency on FunctionInspector from AWS FunctionInvoker
Resolves #618
2020-12-08 15:00:56 +01:00
Oleg Zhurakousky
bdcb232e42 Minor improvements and clean up Cloud Event package 2020-12-03 20:31:17 +01:00
Oleg Zhurakousky
0f0c3a87e5 Update message and cloud event graphics 2020-12-03 07:40:18 +01:00
Oleg Zhurakousky
c4d1d825ea Add Cloud Event and Message graphics 2020-12-02 20:38:29 +01:00
Oleg Zhurakousky
c8d9a3bfe4 Consolidate Cloud Events attribute prefix swap logic 2020-12-02 18:56:51 +01:00
Oleg Zhurakousky
848866686e Fix Cloud Events support for Message functions
Ensured Cloud Event completness by adding assertion for required attributes as well as generation of default values for attributes such as ID and SPECVERSION
2020-12-02 18:22:17 +01:00
Oleg Zhurakousky
c07722dab3 Tidy up logic around canonicalization of attributes
Added initial test to validate builder and utils
2020-12-02 15:17:17 +01:00
Oleg Zhurakousky
a318b88da7 interim 2020-12-02 13:10:05 +01:00
Oleg Zhurakousky
4c69ca1cd6 interim 2020-12-02 12:45:45 +01:00
Oleg Zhurakousky
98c9d56442 Change canonical format of Cloud Event Message attributes to have 'ce-' prefix 2020-12-02 11:24:03 +01:00
Oleg Zhurakousky
6c506f3ae1 Minor cleanup and javadocs 2020-12-02 09:20:50 +01:00
Oleg Zhurakousky
28184039de Restructure Cloud Events support to optionally support Cloud Events SDK 2020-12-01 22:12:34 +01:00
Oleg Zhurakousky
dd6c09a4cb Revert "Add a new strategy for header enrichment"
This reverts commit 1925b490dc.
2020-11-30 15:23:42 +01:00
Dave Syer
1925b490dc Add a new strategy for header enrichment
There was a TODO in the cloud events section of the function catalog.
This extracts that into a strategy and autoconfigures it:
CloudEventOutputMessageHeaderEnricher.
2020-11-25 16:07:14 +00:00
Dave Syer
8bf2fa7e70 Refactor some lambdas to enable native image building
Without this change a function with a Tomcat wrapper cannot be compiled
to a native image (or it can but it fails at runtime) because there
are lambda$$$ methods in the byte code that refer to missing types.
2020-11-25 11:00:08 +00:00
Oleg Zhurakousky
d893be5533 GH-611 Add test to ensure there is no regression
Resolves #611
2020-11-23 20:25:18 +01:00
Oleg Zhurakousky
9d1d74cc76 GH-609 Fix support for missmatched Publishers
Given that s-c-f-web always sends input as Flux, it creates issues for Function<Mono, Mono>, so this fixes it
Resolves #609
2020-11-20 12:13:52 +01:00
Oleg Zhurakousky
2e119a3dd6 GH-608 Add test to validate there is no regression
Resolves #608
2020-11-20 11:27:03 +01:00
Dave Syer
246e96229c Move @Autowired field to lazy init method 2020-11-20 09:56:03 +00:00
Dave Syer
e6d53f000c Better test of whether webflux is present 2020-11-20 09:17:15 +00:00
Dave Syer
01be2060e6 Move class present check to static initializer
Helps with native images
2020-11-19 11:44:51 +00:00
Dave Syer
63498a46c0 Add m2e config for random plugin 2020-11-19 10:29:34 +00:00
buildmaster
48a9b7ca11 Bumping versions 2020-11-17 18:56:10 +00:00
Oleg Zhurakousky
c2ecaee098 Remove leftover comments from test 2020-11-17 17:23:05 +01:00
buildmaster
bfc4712e87 Going back to snapshots 2020-11-17 16:13:28 +00:00
buildmaster
cc56c51ddb Update SNAPSHOT to 3.1.0-M5 2020-11-17 16:11:20 +00:00
Oleg Zhurakousky
d7a0324d00 Fix spelling errors in method name 2020-11-17 16:54:29 +01:00
Oleg Zhurakousky
ac947a282b Fix docs version tag 2020-11-17 13:52:05 +01:00
Oleg Zhurakousky
5894812477 Disable web nature for cloud event function demo 2020-11-17 13:11:10 +01:00
Oleg Zhurakousky
e0a1902147 Minor cleanup 2020-11-17 10:47:45 +01:00
Oleg Zhurakousky
26329f4873 Add AMQP prefix recognition to CloudEventMessageUtils 2020-11-17 10:00:23 +01:00
Oleg Zhurakousky
1498cb4f96 Add additional Cloud Event function test 2020-11-17 08:58:53 +01:00