AckOperationUpdates acknowledges an offer operation status update sent to the scheduler by the master.

AckOperationUpdatesF is a functional adapter for AckOperationUpdates, useful for cases where the caller may change over time.

AckStatusUpdates sends an acknowledgement of a task status update back to mesos and drops the event if sending the ack fails.

AckStatusUpdatesF is a functional adapter for AckStatusUpdates, useful for cases where the caller may change over time.

DefaultEventLogger logs the event via the `log` package.

LiftErrors extract the error message from a scheduler error event and returns it as an ErrEvent so that downstream rules/handlers may continue processing.

LogEvents returns a rule that logs scheduler events to the EventLogger.

Run executes a control loop that registers a framework with Mesos and processes the scheduler events that flow through the subscription.

WithContextPerSubscription results in the creation of a sub-context that is passed to all event handlers and is canceled when the associated subscription has termined (i.e.

WithEventHandler sets the consumer of scheduler events.

WithFrameworkID sets a fetcher for the current Mesos-assigned framework ID.

WithInitiallySuppressedRoles sets the "suppressed_roles" field of the SUBSCRIBE call that's issued to Mesos for each (re-)subscription attempt.

WithRegistrationTokens limits the rate at which a framework (re)registers with Mesos.

WithSubscriptionTerminated sets a handler that is invoked at the end of every subscription cycle; the given error may be nil if no error occurred.

DefaultEventLabel is, by default, logged as the first argument by DefaultEventLogger.

DefaultHandler is invoked when no other handlers have been defined for the controller.

ErrEvent errors are generated by LiftErrors upon receiving an ERROR event from Mesos.

StateError is returned when the system encounters an unresolvable state transition error and should likely exit.