SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,452 Commits 22 Branches 0 Tags
90cec8e350c5e1cd5ced9c3fec3c80486c18dc65
Commit Graph

469 Commits

Author SHA1 Message Date
Oleg Zhurakousky
eeb5448a7d GH-751 Ensure RoutingFunction can be applied when function input type is AWS type 2021-11-02 12:15:08 +01:00
Oleg Zhurakousky
037f1b8bfe GH-758 Change kotlinToFunctionTransformer to SmartInitializingSingleton 
Resolves #758
 2021-10-28 08:45:15 +02:00
Oleg Zhurakousky
cd9b117415 GH-760 Cleanup FunctionAroundWrapper 
Resolves #760
 2021-10-27 15:59:25 +02:00
Oleg Zhurakousky
82e68d4221 Minor cleanup 2021-10-26 15:25:59 +02:00
Oleg Zhurakousky
27734c7f6e Fix FunctionTypeUtils outout type logic for Supplier 2021-10-26 12:01:35 +02:00
Oleg Zhurakousky
40fe70d44c Polishing related to merginng the previous commit as well as upgrade of Kotlin libs 2021-10-25 13:28:31 +02:00
Marcin Grzejszczak
4b96b36a09 Changes for consumer 2021-10-25 12:07:13 +02:00
Marcin Grzejszczak
fade29b33b WIP 2021-10-25 12:06:14 +02:00
Oleg Zhurakousky
f7112d1ef5 GH-SCST-2235 Fix Partitioning issue with FunctionAroundWrapper" 2021-10-19 18:26:37 +02:00
Oleg Zhurakousky
1466c58207 Fixing poms 2021-10-18 16:22:11 +02:00
Oleg Zhurakousky
7fc755e157 GH-750 Add support for pluggable protobufs 
This initial support adds plugin extension to support CloudEvent proto as well as the example
Additional plugins could be provided in the same ay as CloudEvent plugin extension

Resolves #750
 2021-10-11 14:03:24 +02:00
Oleg Zhurakousky
150f140196 GH-752 Add support to stop caching functions in FunctionCatalog 
Resolves #752
 2021-10-07 15:03:17 +02:00
Oleg Zhurakousky
9c95129fef Polishing 2021-10-01 10:25:47 +02:00
Oleg Zhurakousky
c7ffb1cd49 GH-747 Fix Kotlin function bootstrapping in AWS adapter 
Resolves #747
 2021-10-01 10:16:52 +02:00
Oleg Zhurakousky
ed50d7c252 GH-746 Fix support for Cloud Event properly enriching Function<Mono, Mono> 
Resolves #746
 2021-09-27 18:03:32 +02:00
Oleg Zhurakousky
03babc429d GH-567 Add KotlinModule when present to jacksonObjectMapperBuilder 
Resolves #567
 2021-09-27 17:01:35 +02:00
Oleg Zhurakousky
731e99a384 GH-744 Add initial biStreaming support for Function<Flux, Flux> in gRPC module 2021-09-22 17:53:00 +02:00
Oleg Zhurakousky
d7ef882ca5 GH-745 Ensure RSocket support is ready to receive non-Message 2021-09-22 17:24:37 +02:00
Oleg Zhurakousky
ef6a092b91 GH-741 Fix race condition while composing functions 
Resolves #741
 2021-09-14 14:23:04 +02:00
Oleg Zhurakousky
9e5b937d2a GH-731 Add support for SDK CloudEvent type 
The type itself comes form cloud event sdk. And while s-c-function provides native support for cloud events, this is necessary for cases when user uses CloudEvent type in the signature of a function

Resolves #731
 2021-08-31 17:15:51 +02:00
Soby Chacko
e5c335dc5f Migrate Avro message converter artifacts 
Migrate Avro message converter (non-schema-registry) artifacts
from Spring Cloud Schema Registry to Spring Cloud Function.

Resolves https://github.com/spring-cloud/spring-cloud-function/issues/732
Resolves #733
 2021-08-30 14:54:23 +02:00
Oleg Zhurakousky
af6710da36 Add ordering to ContextFunctionCatalogAutoConfiguration to bootstrap after function deployer 2021-08-17 08:51:45 +02:00
Oleg Zhurakousky
71bf766c99 Don't wrap collection of messages into Message 2021-07-30 18:32:52 +02:00
Oleg Zhurakousky
b02f9ae744 Re-enable FunctionAroundWrapper 2021-07-28 11:26:23 +02:00
Oleg Zhurakousky
406ef528cc Temporarily disabled calls to FunctionAroundWrapper 2021-07-26 17:18:31 +02:00
Oleg Zhurakousky
bdbd33efc3 GH-717 Change List to Collection 2021-07-26 13:48:01 +02:00
Oleg Zhurakousky
6ce3a22cbf GH-717 Add support for adding MessageConverters to FunctionCatalog 
Resolves #717
 2021-07-26 13:10:52 +02:00
Oleg Zhurakousky
2f8cd6c0c0 GH-713 Add support for default function for HTTP 
Resolves #713
 2021-07-14 14:46:21 +02:00
Oleg Zhurakousky
4d0452a5dc Put guard to make sure reactve supplier is not instrumented by sleuth 2021-07-09 16:20:15 +02:00
Oleg Zhurakousky
3b244ea0a5 GH-711 Add initial support for source/target types determination 
Resoves #711
 2021-07-01 17:06:15 +02:00
Oleg Zhurakousky
c86890806e GH-710 Fix output conversion logic for when Function is wrapped in around advice 2021-06-28 19:02:34 +02:00
Oleg Zhurakousky
7d1144ffbb GH-710 Set skipOutputConversion flag is FunctionAroundWrapper is present 
Resolves #710
 2021-06-28 17:13:26 +02:00
Oleg Zhurakousky
293ccd7425 Add support for handling Supplier to FunctionAroundWrapper 2021-06-17 10:42:39 +02:00
Oleg Zhurakousky
4cc88f1124 GH-708 Initial refactoring and consolidation of s-c-function-web MVC part. 2021-06-15 15:15:26 +02:00
Oleg Zhurakousky
cebd1fde67 GH-707 Fix Concurrent Modification exception on lookup 
Rare condition but it appears that in some runtimes there could be multiple threads invoking lookup operation
Added test to validate

Resolves #707
 2021-06-08 14:07:32 +02:00
Oleg Zhurakousky
db6e8ce7b4 GH-676 Fix mixed (index and not) input-header-mapping-expression 2021-05-26 15:21:12 +02:00
Oleg Zhurakousky
ef696a64a2 Temporary fix for s-c-stream GH-2178 
This removes 'spring.cloud.stream.sendto.destination' headers from each incoming message
 2021-05-26 14:09:42 +02:00
Oleg Zhurakousky
3b9343df2c GH-676 Add javadoc and minor polishing 2021-05-25 11:50:13 +02:00
Oleg Zhurakousky
3611716dd3 GH-676 Relax SpEL evaluation failures for input header enrichment 
Add documentation

Resolves #676
 2021-05-24 15:18:28 +02:00
Tsypov Dmitriy
dc2076c77a Fixed a bug where the consumer function could not subscribe to the incoming flow 
Resolves #701
Resolves #702
 2021-05-24 13:59:19 +02:00
Oleg Zhurakousky
9ad2788183 GH-676 Add split condition test for header enrichment 2021-05-20 07:32:49 +02:00
Tsypov Dmitriy
fe2edeef38 GH-699 Fixed a bug where Kotlin Lambda was incorrectly converted to a consumer function 
Fixed consumer type

Fixed tests

Added javadoc @author tag

Resolves #699
Resolves #700
 2021-05-20 06:58:10 +02:00
Oleg Zhurakousky
b14c86a3d1 GH-676 Improvements to header enrichment 2021-05-19 16:52:50 +02:00
Oleg Zhurakousky
280b8844c7 GH-676 Add initial support for mapping/re-mapping input headers 
Add BeanResolver
 2021-05-14 10:16:41 +02:00
Oleg Zhurakousky
ea6d15e0aa Change deprecate json mapper property 
Resolves #693
 2021-05-11 15:51:09 +02:00
Oleg Zhurakousky
7d053862ce Add javadoc on new public method 
Resolves #690
 2021-04-26 15:16:47 +02:00
Soby Chacko
007d1f06ea GH-689: Native compilation related changes 
Provide mutator/accessor for enhancer filed in FunctionInvocationWrapper
in SimpleFunctionRegistry. This is required by graalvm native compilation in
Spring Cloud Stream applications.

Resolves https://github.com/spring-cloud/spring-cloud-function/issues/689
 2021-04-22 19:57:50 -04:00
Oleg Zhurakousky
8f8e5172ba polishing 2021-04-15 16:52:04 +02:00
Oleg Zhurakousky
c5ce314032 GH-680 Add additional DEBUG logging to CloudEventsFunctionInvocationHelper 2021-04-14 20:01:54 +02:00
Oleg Zhurakousky
15c58fd63f GH-680 Add support for strict (or not) dependency on target-protocol header for CE 
Resolves #680
 2021-04-14 18:49:01 +02:00