SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,278 Commits 22 Branches 0 Tags
004813dfd27a918fe7fa3d7a8f44858df25eebf2
Commit Graph

1278 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Oleg Zhurakousky
004813dfd2 Fix NPE possibility for ConversionService not being present in the Bean Factory 2021-04-01 13:56:35 +02:00
buildmaster
11eda96661 Bumping versions 2021-03-26 18:57:23 +00:00
Oleg Zhurakousky
b8b04eb377 GH-668 Initial NPE fix in RequestProcessor when no path argument provided 2021-03-25 14:28:18 +01:00
Oleg Zhurakousky
7d848d5de5 Revert "Polishing" 
This reverts commit 2ae8be6025.
 2021-03-24 18:50:55 +01:00
Soby Chacko
2ae8be6025 Polishing 2021-03-24 13:47:53 -04:00
Oleg Zhurakousky
a88a8be223 Simplify FunctionInvocationHelper and its CE implementation 2021-03-24 16:31:41 +01:00
Oleg Zhurakousky
106435e91c GH-675 Made KotlinFunctionWrapper public 2021-03-23 13:48:09 +01:00
Oleg Zhurakousky
c871e5722a Polishing SDK CloudEvent integration 2021-03-19 15:52:57 +01:00
Oleg Zhurakousky
675889f549 Provide initial integration with SDK CloudEvent 2021-03-19 15:00:02 +01:00
Soby Chacko
be50084118 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
2f425abb3f Minor simplification in FunctionRSocketMessageHandler 2021-03-17 14:58:35 +01:00
Oleg Zhurakousky
93ce61f5ab RSocket - Add Cbor test, fixed consumer test and minor cleanup 
polish
 2021-03-16 20:53:48 +01:00
buildmaster
dd00e15102 Bumping versions to 3.1.3-SNAPSHOT after release 2021-03-16 13:20:48 +00:00
buildmaster
395097bc63 Going back to snapshots 2021-03-16 13:20:47 +00:00
buildmaster
a27e3620a3 Update SNAPSHOT to 3.1.2 2021-03-16 13:17:55 +00:00
Oleg Zhurakousky
45dabcfd6f Update spring-cloud-deployer-resource-maven version 2021-03-16 14:07:17 +01:00
Oleg Zhurakousky
51ee613ddb Add deploy plugin to Kotlin sample 2021-03-16 14:02:37 +01:00
Oleg Zhurakousky
d5eca86217 Polish 2021-03-16 13:53:13 +01:00
Oleg Zhurakousky
6e28177bd2 Clean up kotlin sample POM 2021-03-16 13:48:56 +01:00
Oleg Zhurakousky
32c2f12e8e Fix versions 2021-03-16 13:46:26 +01:00
Oleg Zhurakousky
c80bbfa5ad Fix versions 2021-03-16 13:42:57 +01:00
Oleg Zhurakousky
d509640827 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
51dd8cf1d5 Fix encoder/decoder to return decodableMimeTypes 
This effectively fixes the Cbor exclusiion
 2021-03-15 12:23:27 +01:00
Oleg Zhurakousky
98fe5bc8eb 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
e82f54d69e 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
29ad49cbf6 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
cf7a990480 Polish JsonMapper and upgrade function dependency in azure adapter 2021-03-10 16:31:17 +01:00
Oleg Zhurakousky
ab84bb8a14 Add test assertions to validate header propagation for rsocket message 2021-03-10 15:38:13 +01:00
Oleg Zhurakousky
2dea991c3e Fix header propagation for rsocket message 2021-03-10 15:25:50 +01:00
Oleg Zhurakousky
485d6967bd Fix checkstyle 2021-03-10 06:51:01 +01:00
Oleg Zhurakousky
9f8c29a4e7 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
498a52ee84 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
c8a0cebd1f Cleanup 'handleAndReply' logic in RSocketListenerFunction 2021-03-05 09:51:59 +01:00
Oleg Zhurakousky
157949df93 Fix Message sanitizing logic in FunctionRSocketUtils 
Only sanitize headers that are not serializable
 2021-03-05 08:43:19 +01:00
Oleg Zhurakousky
fcd427ca29 GH-663 Fix how strtategies are used to register additional encoders/decoders 
Resolves #663
 2021-03-05 08:08:16 +01:00
Oleg Zhurakousky
046aa354da Merge pull request #659 from pguti778/patch-2 
AWS: Change Default environment values
 2021-03-03 16:17:30 +01:00
Oleg Zhurakousky
c798910e33 Polish documentation 2021-03-03 08:18:19 +01:00
Oleg Zhurakousky
ec2f4a2b4e Polish documentation 2021-03-03 08:17:19 +01:00
Oleg Zhurakousky
b45feef677 Polish documentation 2021-03-03 08:01:19 +01:00
Oleg Zhurakousky
0a28d57da3 Polish documentation 2021-03-03 07:59:10 +01:00
Oleg Zhurakousky
8ecf72c50e Update documentation with distributed function composition 2021-03-03 07:51:30 +01:00
Oleg Zhurakousky
201841418d GH-660 Update RSocket documentation with Messaging bits 2021-03-03 07:26:51 +01:00
Oleg Zhurakousky
2713fbb51c 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
f80d0de0a3 GH-660 Add initial suppport for sending/receiving Messages 
Resolves #660
 2021-03-03 06:38:33 +01:00
pguti778
827c7025ef 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
d82bdebc03 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
d097d960df Update copyrights 2021-03-02 08:51:22 +01:00
Adrien Poupard
a70564eb82 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
9f1c99bae8 GH-654 Update routing and RSocket routing documentation with details on 'MessageRoutingCallback' 
Resolves #654
 2021-02-24 15:48:34 +01:00
Oleg Zhurakousky
1f818dd639 GH-654 Remove FunctionProperties injection from MessageRoutingCallbackRSocketTests 2021-02-24 13:31:31 +01:00