SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,251 Commits 22 Branches 0 Tags
778672e6eadc2d56caa78dfb82abd5ddfcc0de80
Commit Graph

1251 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Oleg Zhurakousky
778672e6ea Add test assertions to validate header propagation for rsocket message 2021-03-10 15:38:13 +01:00
Oleg Zhurakousky
3255ae7455 Fix header propagation for rsocket message 2021-03-10 15:25:50 +01:00
Oleg Zhurakousky
73164beb68 Fix checkstyle 2021-03-10 06:51:01 +01:00
Oleg Zhurakousky
6f90410dda Remove dependency on web classes from new Encoder/Decoder implementation 
The web dependency still need to be there since it appears that spring-rsocket requires it
 2021-03-05 15:08:25 +01:00
Oleg Zhurakousky
5a43e94ebe GH-661 Fix KafkaNull as input type conversion 
Basically KafkaNull gets a special treatement where if we see it as Message payload and input type of the function is Message we give it as is and if the input type is POJO then we simply return null

Resolves #661
 2021-03-05 12:20:29 +01:00
Oleg Zhurakousky
e4cdd9b7a4 Cleanup 'handleAndReply' logic in RSocketListenerFunction 2021-03-05 09:51:59 +01:00
Oleg Zhurakousky
1ba0315460 Fix Message sanitizing logic in FunctionRSocketUtils 
Only sanitize headers that are not serializable
 2021-03-05 08:43:19 +01:00
Oleg Zhurakousky
e5c7452933 GH-663 Fix how strtategies are used to register additional encoders/decoders 
Resolves #663
 2021-03-05 08:08:16 +01:00
Oleg Zhurakousky
840b0c9001 Merge pull request #659 from pguti778/patch-2 
AWS: Change Default environment values
 2021-03-03 16:17:30 +01:00
Oleg Zhurakousky
c67d43c30e Polish documentation 2021-03-03 08:18:19 +01:00
Oleg Zhurakousky
51aabf9aa8 Polish documentation 2021-03-03 08:17:19 +01:00
Oleg Zhurakousky
f7f61645fc Polish documentation 2021-03-03 08:01:19 +01:00
Oleg Zhurakousky
f8c60e7ab6 Polish documentation 2021-03-03 07:59:10 +01:00
Oleg Zhurakousky
2bbd34c07f Update documentation with distributed function composition 2021-03-03 07:51:30 +01:00
Oleg Zhurakousky
b8d04c2448 GH-660 Update RSocket documentation with Messaging bits 2021-03-03 07:26:51 +01:00
Oleg Zhurakousky
0e3a27a392 Merge pull request #658 from KSVarun/patch-1 
Corrected grammatical mistake in the Note section of Message Headers
 2021-03-03 06:40:11 +01:00
Oleg Zhurakousky
694d831adf GH-660 Add initial suppport for sending/receiving Messages 
Resolves #660
 2021-03-03 06:38:33 +01:00
pguti778
d8d41cbdcd AWS: Change Default environment values 
I've faced the "The key must start with a letter and can only contain letters, numbers, and underscores." issue in the AWS lambda. So both _HANDLER and spring.cloud.function.definition were not enabled to be added as environment variables. Let me know your thoughts.
 2021-03-02 22:09:41 -03:00
Varun
4064cfafaa Corrected grammatical mistake in the Note section of Message Headers 
This is the current statement
>SpEL evaluation context’s root object is the actual input argument, so in he case of Message<?> you can construct expression that has access to both payload and headers (e.g., spring.cloud.function.routing-expression=headers.function_name).

This is the corrected one
>SpEL evaluation context’s root object is the actual input argument, so in the case of Message<?> you can construct expression that has access to both payload and headers (e.g., spring.cloud.function.routing-expression=headers.function_name).

```diff
-so in he case...
+so in the case...
```
 2021-03-02 17:22:25 +05:30
Oleg Zhurakousky
ebc7bbd692 Update copyrights 2021-03-02 08:51:22 +01:00
Adrien Poupard
e30a091f82 Add Kotlin suspend function support 
Use suspendCoroutineUninterceptedOrReturn to avoid using not fully implemented Function2.reflect()

Mapping of Function, Consumer and Supplier to kotlin suspend flow lambda

Fix MR review

Resolves #655
 2021-03-02 08:51:00 +01:00
Oleg Zhurakousky
3c16efc6a4 GH-654 Update routing and RSocket routing documentation with details on 'MessageRoutingCallback' 
Resolves #654
 2021-02-24 15:48:34 +01:00
Oleg Zhurakousky
1f43bbce28 GH-654 Remove FunctionProperties injection from MessageRoutingCallbackRSocketTests 2021-02-24 13:31:31 +01:00
Oleg Zhurakousky
410d494467 GH-654 Add more tests, cleanup and initial javadoc 2021-02-24 08:49:53 +01:00
Oleg Zhurakousky
a838f31be6 GH-654 remove route(Publisher) from MessageRoutingCallback 2021-02-23 17:26:08 +01:00
Oleg Zhurakousky
26c11b4463 GH-654 Fix how RoutingFunction is treated by RSocketListenerFunction 2021-02-23 16:58:37 +01:00
Oleg Zhurakousky
29115aeb64 GH-654 Initial support for non-SpEL based routing mechanism 2021-02-23 06:19:45 +01:00
Oleg Zhurakousky
c01b25f2fa SCST-GH-2115 Ensure that in a case of KafkaNull we just return a payload 2021-02-22 16:10:05 +01:00
Oleg Zhurakousky
71c0d6d71e Fix spelling error in constant name 2021-02-22 14:11:27 +01:00
Oleg Zhurakousky
3821e5745c GH-653 Retain original 'lookupDestination' while adding 'reconsiledLookupDestination' 
This is necessary to retain user provided information while also prpviding a way to reconsile the actual destination/function
 2021-02-22 14:08:02 +01:00
Oleg Zhurakousky
0abce5a2b8 GH-652 Improve error messaging and function exist check 
FunctionRSocketUtils looks up function by a bean name hen it attempts  to determine if there is a remote routing. That is not correct since bean name may not exist if function was manually registered. Also, the error message 'Must only contain one output redirect' was not clear as it was not showing the actual function name for propper debugging

Resolves #651
 2021-02-22 12:19:57 +01:00
Oleg Zhurakousky
54eedc6713 GH-653 Add documentation and additional test to validate function definition order for RSocket 
Resolves #653
 2021-02-22 11:41:06 +01:00
Oleg Zhurakousky
57776c6b0c GH-653 Make consistent priority order of function definition in RSocket 
With this commit spring.cloud.function.routing-expression property takes precedence over all, then route(<function.definition>) and then spring.cloud.function.definition property
 2021-02-22 11:11:55 +01:00
buildmaster
1f2c3d8017 Bumping versions 2021-02-18 18:56:53 +00:00
Oleg Zhurakousky
7c216847b2 Simplified RoutingFunction configuration 
If routing-expression is provided there is no need to explicitely set function.definition to 'functionRouter'
 2021-02-18 15:35:26 +01:00
Oleg Zhurakousky
81d6998635 Add initial RSocket test with RoutingFunction 2021-02-18 14:42:14 +01:00
buildmaster
286a6c0a07 Bumping versions 2021-02-15 18:56:40 +00:00
Oleg Zhurakousky
16dacb750f GH-645 Add Kotlin Web example 2021-02-15 18:06:40 +01:00
Oleg Zhurakousky
73bd787c8d GH-649 Ignire factory bean names during discovery of a function 
Resolves #649
 2021-02-15 17:53:12 +01:00
Oleg Zhurakousky
9b62f6e3f8 GH-648 Fix Kotlin functions bootstrap 
Resolves #648
 2021-02-15 16:12:12 +01:00
Oleg Zhurakousky
1453957a26 Upgrade Kotlin lib 2021-02-11 05:35:52 +01:00
Oleg Zhurakousky
5485cc33ca GH-639 Fix NPE for when using Supplier with AWS API Gateway 
Resolves #639
 2021-02-08 10:36:00 +01:00
Oleg Zhurakousky
c4dfffe0ba GH-640 Fix NPE with non-Message json conversion 
Resolves #640

Added test
 2021-02-05 16:12:31 +01:00
buildmaster
315ed4612d Bumping versions 2021-02-01 18:56:47 +00:00
Oleg Zhurakousky
b9d3681edd GH-638 Enhance the lifecycle of function deployemnt in s-c-f-deployer 
Resolves #638
 2021-02-01 13:35:59 +01:00
buildmaster
aa01b6ab33 Bumping versions 2021-01-28 18:56:43 +00:00
buildmaster
06872f573a Bumping versions 2021-01-27 18:56:44 +00:00
buildmaster
043668db4b Bumping versions to 3.1.2-SNAPSHOT after release 2021-01-27 17:16:38 +00:00
buildmaster
0b8d00b1df Going back to snapshots 2021-01-27 17:16:37 +00:00
buildmaster
ea03395bb3 Update SNAPSHOT to 3.1.1 2021-01-27 17:11:29 +00:00