<div dir="ltr">Hi, Winson,<div><br></div><div>This is great! </div><div><br></div><div>But I have a question: </div><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left-width:1px;border-left-color:rgb(204,204,204);border-left-style:solid;padding-left:1ex">9. Operation in python-mistralclient to re-publish events for a given workflow execution (in case where client applications was downed and need the data to recover).</blockquote><div>How does Mistral know about all the events which it has already sent to subscriber? </div><div><br></div><div>I guess you propose to store this data in EventSubscriber object. Correct me if I mistaked.</div><div class="gmail_extra"><br><div class="gmail_quote">On Tue, Nov 11, 2014 at 11:28 PM, W Chan <span dir="ltr"><<a href="mailto:m4d.coder@gmail.com" target="_blank">m4d.coder@gmail.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left-width:1px;border-left-color:rgb(204,204,204);border-left-style:solid;padding-left:1ex"><div dir="ltr">Regarding blueprint to register event listeners to notify client applications on state changes (<a href="https://blueprints.launchpad.net/mistral/+spec/mistral-event-listeners-http" target="_blank">https://blueprints.launchpad.net/mistral/+spec/mistral-event-listeners-http</a>), I want to propose the following.<div><br></div><div>1. Refer this feature as event subscription instead of callback</div><div>2. Event subscription supports only HTTP web hooks with retry policy in this first attempt</div><div>3. Event subscription can be defined for a list of specific events, workflows, projects, domains, or any combinations (all if list is empty).</div><div>4. Decorator to publish event (similar to logging) and place decorators at Engine and TaskPolicy methods @ <a href="https://github.com/stackforge/mistral/blob/master/mistral/engine1/base.py" target="_blank">https://github.com/stackforge/mistral/blob/master/mistral/engine1/base.py</a>. <br></div><div>5. Events should be published to a queue and then processed by a worker so not to disrupt actual workflow/task executions.</div><div>6. API controller to register event subscriber</div><div> a. New resource type named EventSubscriber</div><div> b. New REST controller named EventSubscribersController and CRUD operations</div><div>7. DB v2 sqlalchemy model named EventSubscriber and appropriate CRUD methods</div><div><div>8. Operations in python-mistralclient to manage CRUD for subscribers.</div><div>9. Operation in python-mistralclient to re-publish events for a given workflow execution (in case where client applications was downed and need the data to recover).</div></div><div><br></div></div>
<br>_______________________________________________<br>
OpenStack-dev mailing list<br>
<a href="mailto:OpenStack-dev@lists.openstack.org">OpenStack-dev@lists.openstack.org</a><br>
<a href="http://lists.openstack.org/cgi-bin/mailman/listinfo/openstack-dev" target="_blank">http://lists.openstack.org/cgi-bin/mailman/listinfo/openstack-dev</a><br>
<br></blockquote></div><br><br clear="all"><div><br></div>-- <br><div class="gmail_signature"><div dir="ltr"><div><font>Best Regards,</font></div><div><font>Nikolay</font></div></div></div>
</div></div>