SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,275 Commits 22 Branches 0 Tags
temp-master
Commit Graph

1275 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Soby Chacko
6b22b3a97a Revert "polish" 
This reverts commit e6a500f145.
 2021-03-24 13:45:42 -04:00
Soby Chacko
e6a500f145 polish 2021-03-24 13:44:34 -04:00
Oleg Zhurakousky
cbee6603d0 Simplify FunctionInvocationHelper and its CE implementation 2021-03-24 16:31:41 +01:00
Oleg Zhurakousky
d16d61b294 GH-675 Made KotlinFunctionWrapper public 2021-03-23 13:48:09 +01:00
Oleg Zhurakousky
6c2758e2d3 Polishing SDK CloudEvent integration 2021-03-19 15:52:57 +01:00
Oleg Zhurakousky
ecafecaecc Provide initial integration with SDK CloudEvent 2021-03-19 15:00:02 +01:00
Soby Chacko
6401697f18 Array reification error with KStream[] in Kotlin 
Exclude Kafka Streams functions with KStream[] return type as this
causes some array reification errors in Kotlin.

See this issue for more details: https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1044

Resolves https://github.com/spring-cloud/spring-cloud-function/issues/669

Resolves #670
 2021-03-18 19:58:07 +01:00
Oleg Zhurakousky
1e42e82063 Minor simplification in FunctionRSocketMessageHandler 2021-03-17 14:58:35 +01:00
Oleg Zhurakousky
835f3cc723 RSocket - Add Cbor test, fixed consumer test and minor cleanup 
polish
 2021-03-16 20:53:48 +01:00
buildmaster
85515c12f9 Bumping versions to 3.1.3-SNAPSHOT after release 2021-03-16 13:20:48 +00:00
buildmaster
6fd1b8d1c4 Going back to snapshots 2021-03-16 13:20:47 +00:00
buildmaster
255c0f67c1 Update SNAPSHOT to 3.1.2 2021-03-16 13:17:55 +00:00
Oleg Zhurakousky
9b3bbdfead Update spring-cloud-deployer-resource-maven version 2021-03-16 14:07:17 +01:00
Oleg Zhurakousky
3136e49a6a Add deploy plugin to Kotlin sample 2021-03-16 14:02:37 +01:00
Oleg Zhurakousky
c88907d4cb Polish 2021-03-16 13:53:13 +01:00
Oleg Zhurakousky
c05bb2bcd4 Clean up kotlin sample POM 2021-03-16 13:48:56 +01:00
Oleg Zhurakousky
c5148a6f71 Fix versions 2021-03-16 13:46:26 +01:00
Oleg Zhurakousky
41382538f5 Fix versions 2021-03-16 13:42:57 +01:00
Oleg Zhurakousky
39fa045880 GH-667 Ensure delegation to other available argument resolvers 
In RSocket module we provide custom argument resolver that is aware of how to create a Message if incoming data is application/json
However in the event it's anything else, this fix ensures that there is a delegation model to give other argument resolvers a chance

Resolves #667
 2021-03-16 13:00:37 +01:00
Oleg Zhurakousky
70744bb976 Fix encoder/decoder to return decodableMimeTypes 
This effectively fixes the Cbor exclusiion
 2021-03-15 12:23:27 +01:00
Oleg Zhurakousky
4e42e3631a GH-437 Refactor Azure request handler 
This approach simplifies the existing request handlers while also fixing the invocation model to ensure AC is not created multiple times and ExecutionContext is properly propagated via Message headers
The old request handlers are deprecated
Documentation updates as well as tests
Resolves #437
 2021-03-15 11:08:36 +01:00
Oleg Zhurakousky
b0ef4522d4 GH-600 Fix logic in Azure adapter to ensure proper handling of sveral functions 
This also addresses re-initialization of AC when the second function is invoked
Added second function to the azure examples

Resolves #600
 2021-03-11 15:26:06 +01:00
Oleg Zhurakousky
3c5d905eab GH-437 Pass ExecutionContext via MessageHeader 
Caching it as part of ApplicationContext was not the right idea so this changes it
 2021-03-10 18:53:25 +01:00
Oleg Zhurakousky
863bbdc3eb Polish JsonMapper and upgrade function dependency in azure adapter 2021-03-10 16:31:17 +01:00
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