p

responses

package responses

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. case class AllSubscriptions(intervals: Set[IntervalSub], events: Set[EventSub], polls: Set[PolledSub]) extends Product with Serializable
  2. class CLIHelper extends CLIHelperT
  3. trait CLIHelperT extends AnyRef
  4. class CallbackHandler extends AnyRef

    Handles sending data to callback addresses

  5. trait CancelHandler extends AnyRef
  6. case class HandleIntervals(id: Long) extends Product with Serializable

    Message for triggering handling of intervalsubscriptions

  7. case class LoadSubs(subs: Seq[(SavedSub, Option[SubData])]) extends Product with Serializable

    Used for loading subscriptions during runtime

    Used for loading subscriptions during runtime

    subs

    list of subscriptions to be added along with optional poll subscription data

  8. case class NewSubscription(subscription: SubscriptionRequest) extends Product with Serializable

    New subscription event

    New subscription event

    subscription

    Subscription to be added

  9. trait PollHandler extends Actor with ActorLogging
  10. case class PollSubscription(id: RequestID, ttl: FiniteDuration) extends Product with Serializable

    Event for polling pollable subscriptions

    Event for polling pollable subscriptions

    id

    Id of the subscription to poll

  11. case class RemoveSubscription(id: RequestID, ttl: FiniteDuration) extends Product with Serializable

    Remove subscription event

    Remove subscription event

    id

    Id of the subscription to remove

  12. class RequestHandler extends Actor with ActorLogging with SubscriptionHandler with PollHandler with CancelHandler
  13. trait SubscriptionHandler extends AnyRef
  14. class SubscriptionManager extends Actor with ActorLogging

    Class that handles event and interval based subscriptions.

    Class that handles event and interval based subscriptions. Uses Akka scheduler to schedule ttl handling and intervalhandling

  15. class SubscriptionScheduler extends AnyRef
  16. case class SubscriptionTimeout(id: Long) extends Product with Serializable

    Remove subscription event, used for removing subscrpitions when ttl is over

Ungrouped