Packages

process_hub

0.5.0-beta
0.6.0 0.5.0-beta 0.4.1-beta 0.4.0-beta 0.3.3-alpha 0.3.2-alpha 0.3.1-alpha 0.3.0-alpha 0.2.10-alpha 0.2.9-alpha 0.2.8-alpha 0.2.7-alpha 0.2.6-alpha 0.2.5-alpha 0.2.4-alpha 0.2.3-alpha 0.2.2-alpha 0.2.1-alpha 0.2.0-alpha 0.1.4-alpha 0.1.3-alpha 0.1.2-alpha 0.1.1-alpha 0.1.0-alpha

Distributed processes manager and global process registry

HexDocs

Current section

Files

Jump to
Readme
24 Versions
3 Dependencies
Dependants
Files
Activity
process_hub lib process_hub request handler pids_unregister_request.ex
Raw

lib/process_hub/request/handler/pids_unregister_request.ex 

defmodule ProcessHub.Request.Handler.PidsUnregisterRequest do

  alias ProcessHub.Request.CrossNodeRequest

  alias ProcessHub.Service.ProcessRegistry



  @type t :: %__MODULE__{

          removable_cid_nodes: [

            {ProcessHub.child_id(), [node()]}

          ]

        }

  defstruct [

    :removable_cid_nodes

  ]



  def new(removable_cid_nodes) do

    %__MODULE__{

      removable_cid_nodes: removable_cid_nodes

    }

  end



  defimpl CrossNodeRequest, for: __MODULE__ do

    alias ProcessHub.Request.Handler.PidsUnregisterRequest



    @impl true

    def handle(%PidsUnregisterRequest{} = request, hub) do

      ProcessRegistry.bulk_delete(

        hub.hub_id,

        request.removable_cid_nodes,

        hook_storage: hub.storage.hook

      )

    end

  end

end