streams

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 10, 2019 License: MIT Imports: 10 Imported by: 0

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

type StreamWorker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

StreamWorker stream worker

func NewStreamWorker

func NewStreamWorker(workers *worker.Workers, id int, label string) *StreamWorker

NewStreamWorker create a new Streamworker

func (*StreamWorker) Command

func (w *StreamWorker) Command(c int)

Command sent to this worker

func (*StreamWorker) ID added in v0.2.0

func (w *StreamWorker) ID() int

ID return label of worker

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

func (*StreamWorker) Terminate

func (w *StreamWorker) Terminate()

Terminate the worker

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL