View Source PipelineRunServer.Server.Controller (Datapio OpenCore v0.1.0)

Observe PipelineRunServer resources.

Link to this section Summary

Functions

Return a specification to run the controller under a supervisor

Run a Kubernetes operation using this controller's connection

Run many Kubernetes operations in parallel using this controller's connection

Return the schema configured for this controller

Start a controller linked to the current process with no options

Start a controller linked to the current process

Validate a resource against this controller's schema

Run a function with resource only if the resource is validated

Link to this section Types

Link to this section Functions

Specs

Return a specification to run the controller under a supervisor

Link to this function

run_operation(operation)

View Source

Specs

run_operation(K8s.Operation.t()) :: {:ok, any()} | {:error, term()}

Run a Kubernetes operation using this controller's connection

Link to this function

run_operations(operations)

View Source

Specs

run_operations([K8s.Operation.t(), ...]) :: [ok: any(), error: term()]

Run many Kubernetes operations in parallel using this controller's connection

Specs

schema() :: schema()

Return the schema configured for this controller

Specs

start_link() :: GenServer.on_start()

Start a controller linked to the current process with no options

Specs

Start a controller linked to the current process

Link to this function

validate_resource(resource)

View Source

Specs

validate_resource(resource()) :: :ok | {:error, term()}

Validate a resource against this controller's schema

Link to this function

with_resource(resource, func)

View Source

Specs

with_resource(resource(), (resource() -> any())) ::
  {:ok, any()} | {:error, term()}

Run a function with resource only if the resource is validated