Remote controlled pipeline

CHANGELOG.md

@@ -2,12 +2,15 @@
 
 ## 0.10.0
  * Remove all deprecated stuff [#399](https://github.com/membraneframework/membrane_core/pull/399)
+ * Add `Membrane.RemoteControlled.Pipeline` - a basic implementation of a `Membrane.Pipeline` that </br> 
+   can be spawned and controlled by an external process [#366](https://github.com/membraneframework/membrane_core/pull/366)  
  * Disallow sending buffers without sending caps first [#341](https://github.com/membraneframework/membrane_core/issues/341)
-
 ## 0.9.0
  * Automatic demands [#313](https://github.com/membraneframework/membrane_core/pull/313)
  * Stop forwarding notifications by default in bins [#358](https://github.com/membraneframework/membrane_core/pull/358)
  * More fine-grained control over emitted metrics [#365](https://github.com/membraneframework/membrane_core/pull/365)
+
+ ### PRs not influencing public API:
  * Added log metadata when reporting init in telemetry [#376](https://github.com/membraneframework/membrane_core/pull/376)
  * Fix generation of pad documentation inside an element [#377](https://github.com/membraneframework/membrane_core/pull/377)
  * Leaving static pads unlinked and transiting to a playback state other than `:stopped` will result

lib/membrane/remote_controlled/message.ex

@@ -0,0 +1,65 @@
+defmodule Membrane.RemoteControlled.Message do
+  @moduledoc false
+
+  defmodule PlaybackState do
+    @moduledoc """
+    Message sent when the pipeline changes its playback state
+    """
+    @type t :: %__MODULE__{from: pid(), state: Membrane.PlaybackState.t()}
+
+    @enforce_keys [:from, :state]
+    defstruct @enforce_keys
+  end
+
+  defmodule StartOfStream do
+    @moduledoc """
+    Message sent when some element of the pipeline receives the start of stream event on some pad.
+    """
+    @type t :: %__MODULE__{
+            from: pid(),
+            element: Membrane.Element.name_t(),
+            pad: Membrane.Pad.name_t()
+          }
+
+    @enforce_keys [:from, :element, :pad]
+    defstruct @enforce_keys
+  end
+
+  defmodule EndOfStream do
+    @moduledoc """
+    Message sent when some element of the pipeline receives the start of stream event on some pad.
+    """
+    @type t :: %__MODULE__{
+            from: pid(),
+            element: Membrane.Element.name_t(),
+            pad: Membrane.Pad.name_t()
+          }
+
+    @enforce_keys [:from, :element, :pad]
+    defstruct @enforce_keys
+  end
+
+  defmodule Notification do
+    @moduledoc """
+    Message sent when the some element of the pipeline receives a notification.
+    """
+    @type t :: %__MODULE__{
+            from: pid(),
+            element: Membrane.Element.name_t(),
+            data: Membrane.Notification.t()
+          }
+
+    @enforce_keys [:from, :element, :data]
+    defstruct @enforce_keys
+  end
+
+  defmodule Terminated do
+    @moduledoc """
+    Message sent when the pipeline is terminated.
+    """
+    @type t :: %__MODULE__{from: pid(), reason: :normal | :shutdown | {:shutdown, any()} | term()}
+
+    @enforce_keys [:from, :reason]
+    defstruct @enforce_keys
+  end
+end