Help us shape the future of Go! Take the 2026 Go Developer Survey

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