Deployment and lifecycle management for Nix
agent: give deploy helper func
+5
+5
apps/sower_agent/lib/sower_agent/client.ex
+5
apps/sower_agent/lib/sower_agent/client.ex
···
5
5
6
6
alias SowerAgent.Storage
7
7
8
+
def deploy(%SowerClient.Orchestration.Subscription{} = sub) do
9
+
send({:deployment_request, sub})
10
+
end
11
+
8
12
def handle_call({:deployment_request, %{sid: sid}}, _from, socket) do
9
13
{:ok, upgrade_request} =
10
14
SowerClient.Orchestration.DeploymentRequest.new(%{
···
214
218
|> Quantum.Job.set_name(:"sub_#{sid}")
215
219
|> Quantum.Job.set_schedule(cron)
216
220
|> Quantum.Job.set_task(fn ->
221
+
# TODO make this actually run a subscription check and deployment
217
222
Logger.debug(
218
223
msg: "Running subscription schedule",
219
224
subscription_sid: sid,