@spec execute(ExecutionPlane.Kernel.DispatchPlan.t(), keyword()) ::
  {:ok, map()} | {:error, map()}

@spec protocol() :: String.t()

@spec supported_stream_modes() :: [String.t(), ...]

@spec supports_intent?(struct() | map() | keyword()) :: boolean()