cluster-spec Pub

Cluster specifics and tests

Routing annotations <route.xx> are:

  • local
  • singleton
  • lb
  • other

msg route.other testdiesel.cluster.spawn.other 

msg route.local testdiesel.cluster.spawn.local 

msg route.lb testdiesel.cluster.spawn.lb 

msg route.singleton testdiesel.cluster.spawn.singleton 

trace:: diesel.before
   diesel.engine.set (collectCount:Number=100=100, collectGroup="all"="all")

$when:: testdiesel.cluster.spawn.*
   . (payload="42")

Stream cluster tests

The route.other below will spawn the sub-flow on a different node.

$when:: testdiesel.please.streamremoteputdone (streamRef)
   testdiesel.streamremoteputdone (streamRef)

msg route.other testdiesel.streamremoteputdone  (streamRef)

$when:: testdiesel.streamremoteputdone (streamRef)
   ctx.echo (msg="putting "="putting ")
   diesel.stream.put (streamRef, data=diesel[="s...)
   diesel.stream.done (streamRef)


Was this useful?    

By: Razie | 2023-02-16 .. 2023-06-05 | Tags: spec , dsl


Viewed 165 times ( | History | Print ) this page.

You need to log in to post a comment!

© Copyright DieselApps, 2012-2024, all rights reserved.