d2iq-archive / serenity

Intel:Mesosphere oversubscription technologies for Apache Mesos
Other
69 stars 21 forks source link

Added Event Bus for pipeline interconnection messages and integrated it with ValveFilter #94

Closed bwplotka closed 9 years ago

bwplotka commented 9 years ago

Notes about the bus (from doc)

message SomeEventEnvelope {
    message SomeEvent {
        optional bool first_event_param = 1;
        optional bool second_event_param = 2;
        (...)
     }
     optional SomeEvent message = 1;
 }
  1. Create subscriber. Derive from ProtobufProcess.
  2. Install endpoint and handler for SomeEventEnvelope in Subscriber.
  3. Register subscriber: EventBus::subscribe(subscriberPID)
  4. When event is ready just do EventBus::publish(msg)
    • Publisher does not need to be an libprocess actor!

Based on Szymon's bus: https://github.com/mesosphere/serenity/pull/91

This PR includes: https://github.com/mesosphere/serenity/pull/93

Also this PR includes integration with ValveFilter.

bwplotka commented 9 years ago

Updated version: https://github.com/mesosphere/serenity/pull/98