Commit Graph

21 Commits

Author SHA1 Message Date
Marius Bogoevici
e117cfd5bd Tentatively fix streaming issues
* Assume that the Function returned by FunctionCatalog
  is already wrapped as Function<Flux<?>,Flux<?>>
2017-04-27 07:34:24 +01:00
Marius Bogoevici
4a1972dcf1 Add conversion support for Stream 2017-04-25 08:28:38 +01:00
Marius Bogoevici
70dff6bb6b Enable JSON conversion for non-Flux functions
- use ProxyWrapper around a FluxConsumer as well
  making it consistent with the behaviour of Flux
  functions
- Enable introspection for scanned beans
- Fix failing tests by passing JSON string as input messages
  (marshalled form expected from the binder)
2017-04-06 08:24:51 +01:00
Dave Syer
d1cf9b47a4 Add some failing tests 2017-04-05 13:40:24 +01:00
Marius Bogoevici
82e19894b2 Add stream-function tests 2017-04-04 00:25:12 -04:00
markfisher
d208b5e0f3 stream consumer invoker target now expects Flux 2017-03-31 12:09:04 -04:00
Dave Syer
da013c1015 Purge warnings in IDE 2017-03-14 18:21:41 +00:00
markfisher
2ae7789cd1 add interval for non-Flux stream Suppliers 2017-03-02 11:13:01 -05:00
markfisher
19fd056a5e add support for simple (non-Flux) types
add objectToStringHttpMessageConverter

CompilerController accepts parameterized types
2017-02-24 12:14:57 -05:00
markfisher
5939f96016 renaming stream function property 2017-02-13 09:23:41 -05:00
markfisher
0a6dce951b add support for function composition 2017-02-06 15:55:53 -05:00
markfisher
94a78bdc7f add Function compiling webapp and update scripts 2017-01-19 15:55:49 -05:00
markfisher
8205c579f2 added Supplier and Consumer support 2017-01-11 14:48:21 -05:00
Dave Syer
9321dc7311 Remove function composition from the catalog interface
Should be easy enoug hto add back later, but it was causing issues
with type conversion where we are npot yet sophisticated enough
to chain functions together and keep track of the types being
passed between them.
2017-01-10 12:37:29 -05:00
Dave Syer
4ad01be090 Add support for server-side events and tests
User can POST to web endpoint in SSE style, i.e:

HTTP/1.1
Content-Type: text/event-stream

data:foo

data:bar

Will be converted to a Flux with values foo and bar
2017-01-06 12:43:38 +00:00
Dave Syer
c6736f959b Add a sample app with just beans that are Functions
Make it deployable via its maven coordinates in
spring-cloud-function-deployer (it is deployed by default on start
up right now, but that's just a demo)
2017-01-03 15:16:13 +00:00
markfisher
4e7de96dc9 function invoker is conditional on input 2016-12-05 10:08:02 -05:00
markfisher
b0db0233be add support for Supplier and Consumer 2016-10-14 20:40:48 -04:00
markfisher
8e5d631db9 support function composition for web and stream 2016-10-01 16:52:59 -04:00
markfisher
309993f0d4 file-based registry for serialized functions 2016-10-01 15:30:25 -04:00
markfisher
bdd39b74ff initial commit 2016-09-21 22:33:06 -04:00