gostream

Mar 29, 2024

Changes in this version

type Stream

+ WriteRTP func(pkt *rtp.Packet) error

Oct 30, 2023

Changes in this version

+ var Debug = false

+ var DefaultConstraints = mediadevices.MediaStreamConstraints

+ var ErrNotFound = errors.New("failed to find the best driver that fits the constraints")

+ var ErrServerAlreadyStarted = errors.New("already started")

+ func DriverFromMediaSource(src MediaSource[T]) (driver.Driver, error)

+ func LabelsFromMediaSource(src MediaSource[T]) ([]string, error)

+ func MIMETypeHint(ctx context.Context, defaultType string) string

+ func PropertiesFromMediaSource(src MediaSource[T]) ([]prop.Media, error)

+ func QueryAudioDeviceLabels() []string

+ func QueryScreenDevicesLabels() []string

+ func QueryVideoDeviceLabels() []string

+ func ReadAudio(ctx context.Context, source AudioSource) (wave.Audio, func(), error)

+ func ReadImage(ctx context.Context, source VideoSource) (image.Image, func(), error)

+ func ReadMedia(ctx context.Context, source MediaSource[T]) (T, func(), error)

+ func StreamAudioSource(ctx context.Context, as AudioSource, stream Stream) error

+ func StreamAudioSourceWithErrorHandler(ctx context.Context, as AudioSource, stream Stream, errHandler ErrorHandler) error

+ func StreamVideoSource(ctx context.Context, vs VideoSource, stream Stream) error

+ func StreamVideoSourceWithErrorHandler(ctx context.Context, vs VideoSource, stream Stream, errHandler ErrorHandler) error

+ func WithMIMETypeHint(ctx context.Context, mimeType string) context.Context

+ type AudioPropertyProvider = MediaPropertyProvider[prop.Audio]

+ type AudioReader = MediaReader[wave.Audio]

+ type AudioReaderFunc = MediaReaderFunc[wave.Audio]

+ type AudioSource = MediaSource[wave.Audio]

+ func NewAudioSource(r AudioReader, p prop.Audio) AudioSource

+ func NewAudioSourceForDriver(d driver.Driver, r AudioReader, p prop.Audio) AudioSource

+ type AudioStream = MediaStream[wave.Audio]

+ func NewEmbeddedAudioStream(src AudioSource) AudioStream

+ func NewEmbeddedAudioStreamFromReader(reader AudioReader) AudioStream

+ type DeviceInfo struct

+ Error error

+ ID string

+ Labels []string

+ Priority driver.Priority

+ Properties []prop.Media

+ func QueryAudioDevices() []DeviceInfo

+ func QueryScreenDevices() []DeviceInfo

+ func QueryVideoDevices() []DeviceInfo

+ type DriverInUseError struct

+ func (err *DriverInUseError) Error() string

+ type ErrorHandler func(ctx context.Context, mediaErr error)

+ type HotSwappableAudioSource = HotSwappableMediaSource[wave.Audio, prop.Audio]

+ func NewHotSwappableAudioSource(src AudioSource) HotSwappableAudioSource

+ type HotSwappableMediaSource interface

+ Swap func(src MediaSource[T])

+ func NewHotSwappableMediaSource(src MediaSource[T]) HotSwappableMediaSource[T, U]

+ type HotSwappableVideoSource = HotSwappableMediaSource[image.Image, prop.Video]

+ func NewHotSwappableVideoSource(src VideoSource) HotSwappableVideoSource

+ type MediaPropertyProvider interface

+ MediaProperties func(ctx context.Context) (U, error)

+ type MediaReader interface

+ Close func(ctx context.Context) error

+ Read func(ctx context.Context) (data T, release func(), err error)

+ type MediaReaderFunc func(ctx context.Context) (T, func(), error)

+ func (mrf MediaReaderFunc[T]) Close(ctx context.Context) error

+ func (mrf MediaReaderFunc[T]) Read(ctx context.Context) (T, func(), error)

+ type MediaReleasePair struct

+ Media T

+ Release func()

+ type MediaReleasePairWithError struct

+ Err error

+ Media T

+ Release func()

+ type MediaSource interface

+ Close func(ctx context.Context) error

+ Stream func(ctx context.Context, errHandlers ...ErrorHandler) (MediaStream[T], error)

+ func GetAnyAudioSource(constraints mediadevices.MediaStreamConstraints, logger golog.Logger) (MediaSource[wave.Audio], error)

+ func GetAnyScreenSource(constraints mediadevices.MediaStreamConstraints, logger golog.Logger) (MediaSource[image.Image], error)

+ func GetAnyVideoSource(constraints mediadevices.MediaStreamConstraints, logger golog.Logger) (MediaSource[image.Image], error)

+ func GetNamedAudioSource(name string, constraints mediadevices.MediaStreamConstraints, ...) (MediaSource[wave.Audio], error)

+ func GetNamedScreenSource(name string, constraints mediadevices.MediaStreamConstraints, ...) (MediaSource[image.Image], error)

+ func GetNamedVideoSource(name string, constraints mediadevices.MediaStreamConstraints, ...) (MediaSource[image.Image], error)

+ func GetPatternedAudioSource(labelPattern *regexp.Regexp, constraints mediadevices.MediaStreamConstraints, ...) (MediaSource[wave.Audio], error)

+ func GetPatternedScreenSource(labelPattern *regexp.Regexp, constraints mediadevices.MediaStreamConstraints, ...) (MediaSource[image.Image], error)

+ func GetPatternedVideoSource(labelPattern *regexp.Regexp, constraints mediadevices.MediaStreamConstraints, ...) (MediaSource[image.Image], error)

+ type MediaStream interface

+ Close func(ctx context.Context) error

+ Next func(ctx context.Context) (T, func(), error)

+ func NewEmbeddedMediaStream(src MediaSource[T]) MediaStream[T]

+ func NewEmbeddedMediaStreamFromReader(reader MediaReader[T], p U) MediaStream[T]

+ func NewMediaStreamForChannel(ctx context.Context) (context.Context, MediaStream[T], chan<- MediaReleasePairWithError[T])

+ type StandaloneStreamServer interface

+ AddStream func(stream Stream) error

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ func NewStandaloneStreamServer(port int, logger golog.Logger, opts []StandaloneStreamServerOption, ...) (StandaloneStreamServer, error)

+ type StandaloneStreamServerOption interface

+ func WithStandaloneAllowReceive(allowReceive bool) StandaloneStreamServerOption

+ func WithStandaloneOnPeerAdded(f func(pc *webrtc.PeerConnection)) StandaloneStreamServerOption

+ func WithStandaloneOnPeerRemoved(f func(pc *webrtc.PeerConnection)) StandaloneStreamServerOption

+ type StandaloneStreamServerOptions struct

+ type Stream interface

+ InputAudioChunks func(props prop.Audio) (chan<- MediaReleasePair[wave.Audio], error)

+ InputVideoFrames func(props prop.Video) (chan<- MediaReleasePair[image.Image], error)

+ Name func() string

+ Start func()

+ Stop func()

+ StreamingReady func() (<-chan struct{}, context.Context)

+ func NewStream(config StreamConfig) (Stream, error)

+ type StreamAlreadyRegisteredError struct

+ func (e *StreamAlreadyRegisteredError) Error() string

+ type StreamConfig struct

+ AudioEncoderFactory codec.AudioEncoderFactory

+ Logger golog.Logger

+ Name string

+ TargetFrameRate int

+ VideoEncoderFactory codec.VideoEncoderFactory

+ type StreamServer interface

+ AddStream func(stream Stream) error

+ Close func() error

+ NewStream func(config StreamConfig) (Stream, error)

+ ServiceServer func() streampb.StreamServiceServer

+ func NewStreamServer(streams ...Stream) (StreamServer, error)

+ type VideoPropertyProvider = MediaPropertyProvider[prop.Video]

+ type VideoReader = MediaReader[image.Image]

+ type VideoReaderFunc = MediaReaderFunc[image.Image]

+ type VideoSource = MediaSource[image.Image]

+ func NewResizeVideoSource(src VideoSource, width, height int) VideoSource

+ func NewVideoSource(r VideoReader, p prop.Video) VideoSource

+ func NewVideoSourceForDriver(d driver.Driver, r VideoReader, p prop.Video) VideoSource

+ type VideoStream = MediaStream[image.Image]

+ func NewEmbeddedVideoStream(src VideoSource) VideoStream

+ func NewEmbeddedVideoStreamFromReader(reader VideoReader) VideoStream