Packages

ex_gcloud_pubsub_puller

0.5.2
1.1.2 1.1.1 1.0.1 1.0.0 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.0 0.3.0 0.2.0 0.1.3

Cron-based & configurable gcloud pubsub subscription message puller.

HexDocs

Current section

Files

Jump to
Readme
14 Versions
4 Dependencies
Dependants
Files
Activity
ex_gcloud_pubsub_puller lib ex_gcloud_pubsub_puller subscription_health.ex
Raw

lib/ex_gcloud_pubsub_puller/subscription_health.ex 

defmodule ExGcloudPubsubPuller.SubscriptionHealth do

  alias ExGcloudPubsubPuller.MemoryStore



  @doc """

  Uses the MemoryStore to determine if a subscription could be considered `stagnant`.

  """

  @spec is_stagnant?(String.t()) :: boolean()

  def is_stagnant?(subscription_id) do

    case MemoryStore.load(subscription_id) do

      nil ->

        false



      %{last_message_at: last_message_at} ->

        Timex.before?(last_message_at, Timex.now() |> Timex.shift(seconds: -30))



      %{} ->

        false

    end

  end

end