Implement streams

[adrianopol]

We need to implement StreamManager. See USAGE#streams for more details.

Stream:

• Is a virtual object that maps (connects) some Device (by UID) -- reader -- to a list of peers -- writers (each peer has 1 to 3 interfaces). On diagram below, it is a sender-to-recerver part of the pipeline.
• In MVP Stream may be implemented as a goroutine that manages a number of subprocesses: roc-send, roc-recv.
• Should be stored persistently and restored on daemon start.
• Should be able to be updated through API. The payload accepts a subset of parameters that are being updated.
• StreamManager should handle situations when subprocesses are crashed. (This should be analyzed.)
• There are 2 Stream types:
  • sending Stream: is has from_device and to_address paarameters
  • receiving Stream: is has from_address and to_device paarameters
• Initially there are no Streams.

graph LR
  microphone --> input
  subgraph roc_sender
    input --> sender1
    input --> sender2
  end
  sender1 -- AU_SRC --> receiver1
  sender1 -- AU_RPR --> receiver1
  sender1 <-- AU_CTL --> receiver1

  sender2 -- AU_SRC --> receiver2
  sender2 -- AU_RPR --> receiver2
  sender2 <-- AU_CTL --> receiver2

  subgraph roc_receiver1
    receiver1 --> output1
  end
  subgraph roc_receiver2
    receiver2 --> output2
  end

  output1 --> speaker1
  output2 --> speaker2

Loading

Steps

• Implement StreamManager methods.
• ...

Out of scope

• Choose storage format for Streams.

Docs

• https://roc-streaming.org/toolkit/docs/tools/command_line_tools.html
• https://roc-streaming.org/toolkit/docs/api/examples.html
• https://roc-streaming.org/toolkit/docs/api/reference.html