Commit Graph

1073 Commits

Author SHA1 Message Date
Oleg Zhurakousky
ee0559caac Fix comment 2020-10-22 10:02:21 +02:00
Oleg Zhurakousky
b61e357144 Add function type discovery method to FunctionTypeUtils 2020-10-22 09:58:34 +02:00
Oleg Zhurakousky
222aac77cc GH-596 Add support for handling conversion of complex types
Resolves #596
2020-10-21 14:36:50 +02:00
Oleg Zhurakousky
b0b2fc3554 Add integration profiles for ContainerTests 2020-10-21 10:04:31 +02:00
Oleg Zhurakousky
7061ae39cc Add FunctionInspector back to SimpleFunctionRegistry
Even though it is deprecated and SimpleFunctionRegistry will throw UnsupportedOperationException in case getRegistration() methid is called we need to re-enable it temporarily to mitigate breaking API changes
2020-10-20 15:39:57 +02:00
Oleg Zhurakousky
14ab5ac1b3 Disconnect FunctionInspector from adapter request handlers and Kotlin module 2020-10-20 13:58:51 +02:00
buildmaster
cc9a550bde Bumping versions 2020-10-19 18:56:00 +00:00
Oleg Zhurakousky
818cda144c Deprecate and remove all usages of FunctionInspector 2020-10-19 18:11:11 +02:00
Oleg Zhurakousky
3f1315c523 Consolidate isMessage() operation 2020-10-19 14:57:55 +02:00
Oleg Zhurakousky
e58643c032 Clean up FunctionTypeUtils 2020-10-19 14:44:37 +02:00
Oleg Zhurakousky
b61b24a9b2 Deprecate Flux* function interfaces 2020-10-19 13:20:51 +02:00
Oleg Zhurakousky
89466b5cdc Refactor FunctionCatalog implementation 2020-10-16 17:59:06 +02:00
Oleg Zhurakousky
edd42aa0ac GH-594 Added rsocket to dependencies module
Resolves #594
2020-10-06 14:02:27 +02:00
buildmaster
349f084bd0 Going back to snapshots 2020-10-02 09:22:55 +00:00
buildmaster
9a6a2abb3d Update SNAPSHOT to 3.1.0-M4 2020-10-02 09:20:53 +00:00
Oleg Zhurakousky
a90d11672e Merge pull request #593 from spring-cloud/spencergibb-rsocket-routing-version-0-1-0
Updates rsocket-routing.version to 0.1.0
2020-10-02 08:57:57 +02:00
Spencer Gibb
214bafabcc Updates rsocket-routing.version to 0.1.0 2020-09-30 13:52:47 -04:00
buildmaster
262c3533a1 Bumping versions 2020-09-29 18:56:52 +00:00
David Turanski
22a9733eb4 Fix get() conditional return
Resolves #591
2020-09-28 11:18:56 +02:00
Oleg Zhurakousky
3b26ca1282 Revert "Temporarily disable rsocket-routing-broker integration"
This reverts commit c3d6b48e92.
2020-09-23 17:12:46 +02:00
buildmaster
d7a302133e Going back to snapshots 2020-09-23 14:34:33 +00:00
buildmaster
80b62f5ebe Update SNAPSHOT to 3.1.0-M3 2020-09-23 14:32:21 +00:00
Oleg Zhurakousky
c3d6b48e92 Temporarily disable rsocket-routing-broker integration 2020-09-23 16:24:01 +02:00
Oleg Zhurakousky
1b6bfef3b9 Fix new ContainerTest assertion 2020-09-23 13:31:05 +02:00
Dave Syer
92e7167c99 Add test containers integration test to another sample 2020-09-22 12:55:41 +01:00
Mike Eltsufin
ea5da87731 Add GCP Adapter to intro text
Fixes: #484.
2020-09-21 17:26:46 +02:00
Oleg Zhurakousky
612d54ba53 Remove commented code 2020-09-21 17:24:52 +02:00
Oleg Zhurakousky
43290cc529 GH-568 Add support for casting resulting function as Runnable
Resolves #568
2020-09-21 17:22:38 +02:00
Oleg Zhurakousky
9f700bf2f2 GH-578 Fix FunctionRegistration lookup
The root of the issue was in implementation of  equals() and hashCode() of FunctionInvocationWrapper

Resolves #578
2020-09-21 15:22:21 +02:00
Oleg Zhurakousky
c8ae76d536 polishing
Resolves #589
2020-09-21 13:23:36 +02:00
Dave Syer
935ba1ce84 Replace integration test with test containers 2020-09-21 10:38:19 +01:00
Oleg Zhurakousky
186c0b7a26 GH-588 Fix dropped headers during input conversion
This addresses the issue of dropped Message headers in the event where input is a Message but input conversion is not necessary
while Message contains headers that require explicit propagation (e.g., scf-sink-url, scf-func-name)

Resolves #588
2020-09-18 18:46:52 +02:00
Oleg Zhurakousky
6c6f98fa1d Re-enable routing broker tests after fixes in routing broker 2020-09-17 11:43:54 +02:00
Oleg Zhurakousky
d3afd1fea4 GH-587 Add support for inferring 'accept' content type for simple types
This fix also introduces new Function property 'accept' with no default value which implicitely would default to application/json unless the output type of the function is String at which point it would default to text/plain. However, if it was explicitely set in FunctionProperties it will be used regardless of the function output type.
Resolves #587
2020-09-16 18:14:40 +02:00
Oleg Zhurakousky
e1adb011ab Inject LOOKUP_DESTINATION_HEADER if definition property is not used 2020-09-15 13:51:49 +02:00
Oleg Zhurakousky
368ac59655 Change log level for default function discovery 2020-09-02 14:45:33 +02:00
Oleg Zhurakousky
584d238b9e Remove dead code from FunctionRSocketMessageHandler
Add and clean up tests
2020-09-02 08:27:51 +02:00
Artem Bilan
271171e233 Fix typo in spring-cloud-function-samples/pom.xml
Resolves #577

Co-authored-by: Mike Eltsufin <meltsufin@google.com>
2020-09-01 13:58:50 +02:00
Artem Bilan
6c8554d980 Fix SI sample for compatibility with latest SI
* Fix test `FunctionSampleSpringIntegrationApplicationTests` to use AssertJ
2020-09-01 13:22:44 +02:00
Oleg Zhurakousky
b053761be7 GH-585 Add initial support for passing/parsing Message headers
This woudl allow Message headers to be passed as JSON string via rsocket metadata

Resolves #585
2020-09-01 13:21:58 +02:00
Oleg Zhurakousky
eb3595e780 Merge pull request #583 from spring-cloud/spencergibb-routing-tcp
Updates to new routing client broker tcp properties
2020-09-01 07:20:24 +02:00
Spencer Gibb
f0ad6bf8ac Updates to new routing client broker tcp properties 2020-08-31 19:14:58 -04:00
Oleg Zhurakousky
85b591cb89 Add special handling for JSON Strings
Added support to JsonMessageConverter to pass string as is if input type is String
Added guard condition to RSocketListenerFunction to avoid NPE if target function can not be discovered
2020-08-31 16:35:18 +02:00
Oleg Zhurakousky
6a13436723 Annotate FunctionRSocketMessageHandler @Primary 2020-08-31 13:58:23 +02:00
Oleg Zhurakousky
81e35490ea Code cleanup for rsocket module 2020-08-28 17:47:54 +02:00
Oleg Zhurakousky
5332dc72f8 Merge pull request #582 from spring-cloud/spencergibb-reenable-routingbrokertests
Re-enables RoutingBrokerTests
2020-08-28 16:47:51 +02:00
Spencer Gibb
87187692ae Re-enables RoutingBrokerTests
Also updates comments on `.route("uppercase")` as this is now required for `FunctionRSocketMessageHandler`
2020-08-28 10:45:59 -04:00
Oleg Zhurakousky
8801efa445 Temporary disabling of RoutingBrokerTests 2020-08-28 09:16:05 +02:00
Oleg Zhurakousky
353fd2e8d0 Fix distributed composition test
Added override of handleMessage(..) to FunctionRSocketMessageHandler to be able to register functions on demand instead of pre-registering all of them during the init
2020-08-28 09:14:57 +02:00
Oleg Zhurakousky
41b6818f79 Merge pull request #581 from spring-cloud/spencergibb-patch-1
Updates property based metadata to use uppercase function name
2020-08-28 08:07:11 +02:00