Orchestration flows
type SomeEventType {
...
}
@KafkaSource("someAddress")
publisher SomePublisher {
@KafkaTopic("SomeTopic")
publishes SomeEventType
@KafkaTopic("AnotherTopic")
consumes TypeD
}
service SomeService {
operation DoSomething(TypeB) : TypeC
}
flow MyFlow {
trigger SomeEventType
call DoSomething
publish TypeD
}
Idea:
- Vyne should map
SomeEventType
toTypeB
(the input ofDoSomething
), including invoking transformational services if required - Similarly, the result of
DoSomething
isTypeC
, which vyne should try to map toTypeD
to publish -
publisher
/publishes
/consumes
need config blocks, which should be key/value pairs passed through to a VyneEventSource
handler.
Questions:
- How do we handle mapping? Do we try only to map the output of the previous operation? What about context from earlier steps, should these be included? Do we allow that to be configured?
Edited by Marty Pitt