ExecutionPlane.Runtime.Client behaviour (execution_plane v0.1.0)

Copy Markdown View Source

Consumer-to-node runtime client behaviour.

Summary

Callbacks

admit(t, keyword)

cancel(t, keyword)

@callback cancel(
  ExecutionPlane.ExecutionRef.t(),
  keyword()
) :: :ok | {:error, term()}

describe(keyword)

@callback describe(keyword()) ::
  {:ok, ExecutionPlane.Runtime.NodeDescriptor.t()} | {:error, term()}

execute(t, keyword)

stream(t, keyword)