Implement transit for cluster

upmaru · Jun 21, 2024 · a3d7ca7 · a3d7ca7
1 parent 31191a2
commit a3d7ca7
Showing 1 changed file with 15 additions and 0 deletions.
diff --git a/lib/polar/machines/cluster/transit.ex b/lib/polar/machines/cluster/transit.ex
@@ -0,0 +1,15 @@
+defimpl Eventful.Transit, for: Polar.Machines.Cluster do
+  def perform(cluster, user, event_name, options \\ []) do
+    comment = Keyword.get(options, :comment)
+    domain = Keyword.get(options, :domain, "transitions")
+    parameters = Keyword.get(options, :parameters, %{})
+
+    cluster
+    |> Event.handle(user, %{
+      domain: domain,
+      name: event_name,
+      comment: comment,
+      parameters: parameters
+    })
+  end
+end