Current section

Files

Jump to
dagger lib dagger gen engine.ex
Raw

lib/dagger/gen/engine.ex

# This file generated by `dagger_codegen`. Please DO NOT EDIT.
defmodule Dagger.Engine do
@moduledoc """
The Dagger engine configuration and state
"""
use Dagger.Core.Base, kind: :object, name: "Engine"
alias Dagger.Core.Client
alias Dagger.Core.QueryBuilder, as: QB
@derive Dagger.ID
defstruct [:query_builder, :client]
@type t() :: %__MODULE__{}
@doc """
The list of connected client IDs
"""
@spec clients(t()) :: {:ok, [String.t()]} | {:error, term()}
def clients(%__MODULE__{} = engine) do
query_builder =
engine.query_builder |> QB.select("clients")
Client.execute(engine.client, query_builder)
end
@doc """
A unique identifier for this Engine.
"""
@spec id(t()) :: {:ok, String.t()} | {:error, term()}
def id(%__MODULE__{} = engine) do
query_builder =
engine.query_builder |> QB.select("id")
Client.execute(engine.client, query_builder)
end
@doc """
The local engine cache state tracked by dagql
"""
@spec local_cache(t()) :: Dagger.EngineCache.t()
def local_cache(%__MODULE__{} = engine) do
query_builder =
engine.query_builder |> QB.select("localCache")
%Dagger.EngineCache{
query_builder: query_builder,
client: engine.client
}
end
@doc """
The name of the engine instance.
"""
@spec name(t()) :: {:ok, String.t()} | {:error, term()}
def name(%__MODULE__{} = engine) do
query_builder =
engine.query_builder |> QB.select("name")
Client.execute(engine.client, query_builder)
end
end
defimpl Jason.Encoder, for: Dagger.Engine do
def encode(engine, opts) do
{:ok, id} = Dagger.Engine.id(engine)
Jason.Encode.string(id, opts)
end
end
defimpl Nestru.Decoder, for: Dagger.Engine do
def decode_fields_hint(_struct, _context, id) do
alias Dagger.Core.QueryBuilder, as: QB
dag = Dagger.Global.dag()
{:ok,
%Dagger.Engine{
query_builder:
dag.query_builder
|> QB.select("node")
|> QB.put_arg("id", id)
|> QB.inline_fragment("Engine"),
client: dag.client
}}
end
end