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

543 Commits

Author SHA1 Message Date
Oleg Zhurakousky
f22561ed47 GH-917 Fix regression with sanitizing headers 
Resolves #917
 2022-08-16 16:43:38 +02:00
Oleg Zhurakousky
392a1f6103 GH-915 Make Kotlin initialization 'lazy' 
This way just like with any other function, Kotlin initialization, type discovery etc will be performed on function lookup
This will also ensure that order of various post processors doesn't get in the way.

Resolves #915
 2022-08-11 16:59:09 +02:00
Oleg Zhurakousky
4d18d3b7d6 GH-909 Fix spelling of the method 
Resolves #909
 2022-08-08 15:32:57 +02:00
Oleg Zhurakousky
e0f156b407 GH-905 Relax handling of incompatible BiFunctions 
Resolves #905
 2022-08-03 18:02:38 +02:00
Oleg Zhurakousky
342c2bb533 GH-901 add more logging around failed conversion of input messages 
Resolves #901
 2022-07-26 17:36:12 +02:00
Maciej Walkowiak
14266d14d8 Fix typo. 
Fix typo.
 2022-07-26 11:50:04 +02:00
Oleg Zhurakousky
02e9adf0c6 Relax logging in SimpleFunctionRegistry 2022-07-25 15:46:13 +02:00
Oleg Zhurakousky
7cd0266628 Remove reflection usage to accomodate AOT 2022-07-25 15:14:45 +02:00
Oleg Zhurakousky
7d262d894f GH-895 Remove reflection usage form CloudEventMessageUtils 2022-07-13 13:53:29 +02:00
Oleg Zhurakousky
10244a044b Fix function eligibility filtering 2022-06-17 15:49:44 +02:00
Oleg Zhurakousky
d5666792d6 GH-884 Add initial support for BiConsumer 2022-06-15 16:17:19 +02:00
Oleg Zhurakousky
9bd83402e4 GH-884 Add initial support for BiFunction 
Resolves #884
 2022-06-14 09:08:31 +02:00
Oleg Zhurakousky
37a81f3a02 GH-883 Add support for filtering out ineligible functions 
Resolves #883
 2022-06-13 15:47:29 +02:00
Oleg Zhurakousky
24abaa7f87 Add author 2022-06-09 15:03:44 +02:00
Oleg Zhurakousky
3b693304dd checkstyle 2022-06-09 14:51:45 +02:00
Oleg Zhurakousky
eeafa09b68 SCST-GH-2355 Add support for batch processing of collections with different types 
Specifically KafkaNull. But this commit effectively paves a path for any type
 2022-06-09 14:51:35 +02:00
Oleg Zhurakousky
808fb28f5c Initial commit of KafkaNull changes to SmartCompositeMessageConverter 2022-06-09 14:51:24 +02:00
Oleg Zhurakousky
83901cf16d KafkaNull batch attempt 2022-06-09 14:51:14 +02:00
Oleg Zhurakousky
630dcf2267 Back-port of https://github.com/spring-cloud/spring-cloud-function/pull/871 2022-06-07 16:51:51 +02:00
Oleg Zhurakousky
6ecb261487 GH-873 Fix JsonNode conversion 
Resolves #873
 2022-05-30 14:38:34 +02:00
Oleg Zhurakousky
0576b6c6ce GH-878 Fix concurrency issue during registration and lookup of functions 
Resolves #878
 2022-05-30 12:10:58 +02:00
Oleg Zhurakousky
080be7f40c GH-739 Add DEBUG log statement for when type conversion fails 
Resolves #739
 2022-05-04 15:09:57 +02:00
Oleg Zhurakousky
63ad1dead6 GH-791 Add support for propagating input headers 
Resolves #791
 2022-05-04 13:20:01 +02:00
Oleg Zhurakousky
684942e680 GH-856 Fix logic in determining Cloud Event prefix 
Resolves #856
 2022-04-26 08:39:48 +02:00
REMY David
a2b87854d8 Change OffsetTime to OffsetDateTime in CloudEventMessageUtils 
Resolves #855
 2022-04-21 11:02:38 +02:00
Oleg Zhurakousky
17dda179bc Fix compilation error in test 2022-03-25 14:44:04 +01:00
Oleg Zhurakousky
281c5baa61 Fix conversion logic in SmartCompositeMessageConverter 2022-03-25 14:25:05 +01:00
Oleg Zhurakousky
03db9baee6 GH-828 Add support for configuring additional routers 
Resolves #828
 2022-03-24 18:27:28 +01:00
Oleg Zhurakousky
4eb4f741a5 GH-830 Fix conversioin exception for custom converters 
Resolves #830
 2022-03-23 17:17:24 +01:00
Oleg Zhurakousky
986c0a09d8 GH-832 Change OffsetTime to OffsetDateTime in CloudEventMessageBuilder 
Resolves #832
 2022-03-23 13:18:04 +01:00
Oleg Zhurakousky
e1f2820fd1 Fix typo 2022-03-22 16:39:18 +01:00
Oleg Zhurakousky
ca9e816a8f Polishing 2022-03-22 15:56:26 +01:00
Oleg Zhurakousky
d15d42894a Perf improvement 2022-03-22 15:45:13 +01:00
Oleg Zhurakousky
61b7023610 Performance improvements related to SCST-2303 2022-03-22 13:54:26 +01:00
Oleg Zhurakousky
1f54dbf036 Clean up code 2022-03-08 14:38:34 +01:00
onobc
d20f084208 Improve ContextFunctionCatalogAutoConfiguration conditional loading 
- Allow custom AvroSchemaServiceManager to be used
- Make AvroSchemaMessageConverter bean method specifically typed
- Make CloudEventsMessageConverter bean method specifically typed
- Add tests focusing on the conditional loading aspects of the auto configuration

Fixes gh-797
Resolves #814
 2022-02-23 15:44:27 +01:00
Oleg Zhurakousky
cddb60cda3 GH-816 Enhance test validating collection output 2022-02-23 15:17:08 +01:00
Oleg Zhurakousky
f217cc0aab Revert "GH-816 Fix support for function that returns Iterable with target-protocol set" 
This reverts commit f1800a7bd2.
 2022-02-23 15:16:55 +01:00
Oleg Zhurakousky
f1800a7bd2 GH-816 Fix support for function that returns Iterable with target-protocol set 
Resolves #816
 2022-02-21 14:51:32 +01:00
Roman S Samarev
3fa021b4fa SimpleFunctionRegistry: Fixed: compose of supplier...consumer pipeline produces a supplier type. This fix allows testing of composed pipelines without input and output 
SimpleFunctionRegistry: added info. No functional changes

Resolves #809
 2022-02-15 20:40:46 +01:00
Soby Chacko
30ba6fd238 Revert "Remove skipConversion in FunctionAroundWrapper" 
This reverts commit 80305e630b.
 2022-02-11 12:41:36 -05:00
Soby Chacko
0cbd5e8fbf Revert "* Simplify functionalTracingEnabled variable logic" 
This reverts commit 49e027a0ee.
 2022-02-11 12:41:27 -05:00
Soby Chacko
a8ac826254 Revert "fix checkstyle" 
This reverts commit e1713929e5.
 2022-02-11 12:41:18 -05:00
Oleg Zhurakousky
f99b900885 Merge cleanup 2022-02-09 14:41:40 +01:00
Oleg Zhurakousky
7a6e43fc3d GH-804 Add support for case-insensitive Cloud Event determination 
Resolves #804
 2022-02-09 14:25:47 +01:00
Oleg Zhurakousky
32e88693d0 GH-804 Add support for case-insensitive routing 2022-02-09 14:24:05 +01:00
Oleg Zhurakousky
ea47a37611 GH-796 Fix error handling for reactive input/ouput conversion 
Resolves #796
 2022-02-07 18:56:44 +01:00
Oleg Zhurakousky
e1713929e5 fix checkstyle 2022-02-07 15:21:28 +01:00
Artem Bilan
49e027a0ee * Simplify functionalTracingEnabled variable logic 
* Add `BeanFactoryAwareFunctionRegistryTests.testWrappedWithAroundAdviseNotMessageReturnConfiguration()`
to verify that non-Message return from the target function is wrapped to the `Message` before return
to the `FunctionAroundWrapper`
 2022-02-07 15:21:19 +01:00
Artem Bilan
80305e630b Remove skipConversion in FunctionAroundWrapper 
Currently, the `FunctionAroundWrapper` set `targetFunction.setSkipOutputConversion(true);`
which is not what expected by the `TraceFunctionAroundWrapper`.
This one has a logic based on the `Message` as an output from the target function
and its headers to correlate tracing headers.

* Remove the `setSkipOutputConversion(true)` from the `FunctionAroundWrapper`
to satisfy `TraceFunctionAroundWrapper` expectation - we cannot enforce
all the end-user function to always return a `Message<?>` for us.
* Some other refactoring in the `FunctionAroundWrapper` for cleaner code

**Cherry-pick to `3.2.x`**
 2022-02-07 15:21:04 +01:00