Oleg Zhurakousky
41043479f5
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
7c8d32246a
GH-752 Add support to stop caching functions in FunctionCatalog
...
Resolves #752
2021-10-07 15:03:17 +02:00
Oleg Zhurakousky
ab9422907e
GH-746 Fix support for Cloud Event properly enriching Function<Mono, Mono>
...
Resolves #746
2021-09-27 18:03:32 +02:00
Soby Chacko
0e2663bd55
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
eca03a49d8
Re-enable FunctionAroundWrapper
2021-07-28 11:26:23 +02:00
Oleg Zhurakousky
166937cdab
Temporarily disabled calls to FunctionAroundWrapper
2021-07-26 17:18:31 +02:00
Oleg Zhurakousky
5a625b4ad0
GH-708 Initial refactoring and consolidation of s-c-function-web MVC part.
2021-06-15 15:15:26 +02:00
Oleg Zhurakousky
378f0d33ab
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
e419b41968
GH-676 Fix mixed (index and not) input-header-mapping-expression
2021-05-26 15:21:12 +02:00
Oleg Zhurakousky
22e945009a
GH-676 Relax SpEL evaluation failures for input header enrichment
...
Add documentation
Resolves #676
2021-05-24 15:18:28 +02:00
Oleg Zhurakousky
79f4540130
GH-676 Add split condition test for header enrichment
2021-05-20 07:32:49 +02:00
Oleg Zhurakousky
238ac301df
GH-676 Improvements to header enrichment
2021-05-19 16:52:50 +02:00
Oleg Zhurakousky
03de819c4a
GH-676 Add initial support for mapping/re-mapping input headers
...
Add BeanResolver
2021-05-14 10:16:41 +02:00
Oleg Zhurakousky
727322b1f0
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
Oleg Zhurakousky
ee0bc4e28f
Merge additional test to ensure propper type conversion
2021-04-10 08:10:23 +02:00
Taras Danylchuk
5afbd25d1c
gh-608 issue
2021-04-10 07:59:38 +02:00
Oleg Zhurakousky
2e133f9e9a
Add test for FunctionAroundWrapper
2021-04-08 17:10:17 +02:00
Oleg Zhurakousky
b2f36936ac
GH-662 Fix support for reactive functions in AWS
...
This commit also includes other minor fixes around CustomRuntime which was getting in the way of this specific issue
Added lookup for _HANDLER env variable
Added few tests (will need more)
Added support for Iterable for reactive functions
Resolves #662
2021-04-08 15:57:14 +02:00
Oleg Zhurakousky
c0ed41f9c7
GH-679 Add test to validate output conversion for composed functions
...
Resolves #679
2021-04-07 11:53:17 +02:00
Oleg Zhurakousky
b96b834cdd
GH-640 Fix NPE with non-Message json conversion
...
Resolves #640
Added test
2021-02-05 16:12:31 +01:00
Oleg Zhurakousky
da7f21d9e8
GH-635 Fix support for returning empty Collections
...
Resolves #635
2021-01-22 16:43:55 +01:00
Oleg Zhurakousky
ad1bd31ead
GH-620 Add BeanResolver support for RoutingFunction
...
Resolves #620
polish
2021-01-22 14:52:04 +01:00
ncheema
88f2d8ed11
method already has a condition to retrieve immediateGenericType for a message
...
This condition was meant to be removed as part of #543
Resolves #624
2021-01-11 10:43:09 +01:00
Oleg Zhurakousky
8ece3d3083
Add stream (kafka, Rabbit) and Rsocket examples for Cloud Event
2020-12-18 16:44:29 +01:00
Oleg Zhurakousky
30febe6bce
Cleaned up Cloud Event support around reactive functions
...
Added reactive tests
Restructured CloudEventsFunctionInvocationHelper
2020-12-11 14:34:32 +01:00
Oleg Zhurakousky
aede56dfc6
Fix Cloud Events support for Message functions
...
Ensured Cloud Event completness by adding assertion for required attributes as well as generation of default values for attributes such as ID and SPECVERSION
2020-12-02 18:22:17 +01:00
Oleg Zhurakousky
923d5204e4
Tidy up logic around canonicalization of attributes
...
Added initial test to validate builder and utils
2020-12-02 15:17:17 +01:00
Oleg Zhurakousky
753d6369a2
interim
2020-12-02 13:10:05 +01:00
Oleg Zhurakousky
523cd1023f
Change canonical format of Cloud Event Message attributes to have 'ce-' prefix
2020-12-02 11:24:03 +01:00
Oleg Zhurakousky
306da4248a
Restructure Cloud Events support to optionally support Cloud Events SDK
2020-12-01 22:12:34 +01:00
Oleg Zhurakousky
e2788fbab0
GH-611 Add test to ensure there is no regression
...
Resolves #611
2020-11-23 20:25:18 +01:00
Oleg Zhurakousky
e4242388fb
GH-609 Fix support for missmatched Publishers
...
Given that s-c-f-web always sends input as Flux, it creates issues for Function<Mono, Mono>, so this fixes it
Resolves #609
2020-11-20 12:13:52 +01:00
Oleg Zhurakousky
e112b6c9dc
GH-608 Add test to validate there is no regression
...
Resolves #608
2020-11-20 11:27:03 +01:00
Oleg Zhurakousky
cd2d84d382
Fix spelling errors in method name
2020-11-17 16:54:29 +01:00
Oleg Zhurakousky
53addc50c8
Add additional Cloud Event function test
2020-11-17 08:58:53 +01:00
Oleg Zhurakousky
ac54a83e09
Clean up and simplifications around CloudEvent processing
...
This commit effectively a merge of work with #607 and simplifies the following
- CloudEventAttributesProvider now provides CloudEventAttributes initialized with defaults to be set by the user
- In HTTP RequestProcessor the logic of sanitizing headers was improved to ensure that correct prefix is applied
Resolves #607
2020-11-16 13:40:53 +01:00
Oleg Zhurakousky
ada16079ca
GH-422 GH-606 Add support for normalizing structure-mode CE message
...
Normalizing in this context means converting it to binary-mode so the rest of the processing logic is the same.
Added support for canonical attribute names. Now, internally any attribute can be set as 'ce_' regardless where it came from are where it goes to as the frameork will be able to recognize both
Removed CloudEventMessageConverter
Renamed CloudEventAttributes to CloudEventAttributesHelperas it is better suited to what it actually does
2020-11-16 12:06:33 +01:00
Oleg Zhurakousky
c31b7f1f20
Make CloudEventAttributesProvider a FunctionalInterface
...
Related to #422 and #606
2020-11-16 08:41:42 +01:00
Oleg Zhurakousky
311649c312
Fix CloudEvent prefix and fix the name of CloudEventAttributesProvider.java
2020-11-13 16:07:33 +01:00
Oleg Zhurakousky
9c58e6d64b
GH-422 GH-606 Add support for simplifying message headers to attribute mapping
...
Added CloudEventAttributesProvider and default implementation
Added CloudEventMessageUtils
2020-11-13 10:24:27 +01:00
Oleg Zhurakousky
f999cdd787
GH-422 Formalize Cloud Event conversion strategy to consistently handle binary-mode and structured-mode cloud events
...
Moved CloudEvent related artifacts to ‘cloud events’ package with hopes to eventually donating it to CNCF SDK
Created CloudEventUtils identifying necessary constants and utility methods
2020-11-12 17:01:42 +01:00
Oleg Zhurakousky
a39476561a
GH-422 Add RabbitMQ instructions for Cloud Events interaction
2020-11-11 11:53:39 +01:00
Oleg Zhurakousky
3cea0343df
PR-605 less formatting
...
Resolves #605
2020-11-09 16:16:23 +01:00
Oleg Zhurakousky
8774383dc8
GH-601 add test to validate the issue is fixed
...
Resolves #601
2020-11-09 15:35:35 +01:00
Oleg Zhurakousky
9b325ce7e6
GH-602 Ensure collections with converted items are not converted again
...
Resolves #602
2020-11-09 14:07:20 +01:00
Oleg Zhurakousky
1209fa1053
Additional clean up and polishing
2020-11-04 10:43:29 +01:00
Oleg Zhurakousky
7c860eb334
Re-enable support for around advise
2020-10-26 08:29:16 +01:00
Oleg Zhurakousky
dc8d51b873
Consolidate mechanisms around retaining headers and skipping input/output conversion
2020-10-23 13:19:03 +02:00
Oleg Zhurakousky
544e35335a
GH-596 Add support for handling conversion of complex types
...
Resolves #596
2020-10-21 14:36:50 +02:00
Oleg Zhurakousky
b8d462678a
Deprecate and remove all usages of FunctionInspector
2020-10-19 18:11:11 +02:00