Service Implementation to create fail-over partial Siddhi apps about siddhi-operator

[BuddhiWathsala]

Here in the next release of the siddhi operator, we are planning to change the siddhi parser REST endpoint to create failover siddhi apps.

The request of the endpoint will contain a siddhi app like below.

@App:name("MonitorApp")
@App:description("Description of the plan") 

@sink(type='log', prefix='LOGGER')
@source(
    type='http',
    receiver.url='http://0.0.0.0:8080/example',
    basic.auth.enabled='false',
    @map(type='json')
)
define stream DevicePowerStream (type string, deviceID string, power int);

@sink(type='log', prefix='LOGGER')
define stream MonitorDevicesPowerStream(sumPower long);
@info(name='monitored-filter')
from DevicePowerStream#window.time(100 min)
select sum(power) as sumPower
insert all events into MonitorDevicesPowerStream;

And the parser will divide this siddhi app to partial siddhi app (passthrough and process apps).

Passthrough App

@App:name("MonitorApp-0") 
@source(type='http', receiver.url='', basic.auth.enabled='', @map(type='json'))

define stream passthroughDevicePowerStream (type string, deviceID string, power int);
@sink(type='nats',cluster.id='example-stan',destination = 'FailoverMonitorApp_DevicePowerStream', bootstrap.servers='nats://example-nats:4222',@map(type='text')) 

define stream DevicePowerStream (type string, deviceID string, power int);
from passthroughDevicePowerStream select * insert into DevicePowerStream;

Process App

@App:name("MonitorApp-1") 
@source(type='nats',cluster.id='example-stan',destination = 'FailoverMonitorApp_DevicePowerStream', bootstrap.servers='nats://example-nats:4222',@map(type='text')) 

define stream DevicePowerStream (type string, deviceID string, power int);
@info(name='monitored-filter')

from DevicePowerStream#window.lengthBatch(3)
select sum(power) as sumPower
insert all events into MonitorDevicesPowerStream;

Note that here by default siddhi operator uses NATS streaming as the messaging layer.

[mohanvive]

Fixed in #34 by Buddhi..

[pcnfernando]

Added support with #35