Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StreamInfo ¶
type StreamInfo struct {
Codec string
PacketDuration int
StreamID int
Channel string
From string
CodecHeader string
For string
SampleRate int
FrameSizeMs int
}
StreamInfo persist stream information
type StreamWorker ¶
StreamWorker stream worker
func NewStreamWorker ¶
func NewStreamWorker(workers *worker.Workers, id int, label string) *StreamWorker
NewStreamWorker create a new Streamworker
func (*StreamWorker) Label ¶ added in v0.2.0
func (w *StreamWorker) Label() string
Label return label of worker
func (*StreamWorker) Run ¶
func (w *StreamWorker) Run(wg *sync.WaitGroup, term *chan int)
Run is main function of this worker
func (*StreamWorker) Subscriptions ¶ added in v0.2.0
func (w *StreamWorker) Subscriptions() []*worker.Subscription
Subscriptions return a copy of current scubscriptions
Click to show internal directories.
Click to hide internal directories.