webstream

Documentation

Overview

Package webstream provides controls for streaming from the web server.

Index

• func StreamAudioSource(ctx context.Context, source gostream.AudioSource, stream gostream.Stream, ...) error
• func StreamVideoSource(ctx context.Context, source gostream.VideoSource, stream gostream.Stream, ...) error
• type BackoffTuningOptions
  • func (opts *BackoffTuningOptions) GetSleepTimeFromErrorCount(errorCount int) time.Duration

Functions

func StreamAudioSource

func StreamAudioSource(
	ctx context.Context,
	source gostream.AudioSource,
	stream gostream.Stream,
	backoffOpts *BackoffTuningOptions,
	logger logging.Logger,
) error

StreamAudioSource starts a stream from an audio source with a throttled error handler.

func StreamVideoSource

func StreamVideoSource(
	ctx context.Context,
	source gostream.VideoSource,
	stream gostream.Stream,
	backoffOpts *BackoffTuningOptions,
	logger logging.Logger,
) error

StreamVideoSource starts a stream from a video source with a throttled error handler.

Types

type BackoffTuningOptions

type BackoffTuningOptions struct {
	// BaseSleep sets the initial amount of time to wait after an error.
	BaseSleep time.Duration
	// MaxSleep determines the maximum amount of time that streamSource is
	// permitted to a sleep after receiving a single error.
	MaxSleep time.Duration
	// Cooldown sets how long since the last error that we can reset our backoff. This
	// should be greater than MaxSleep. This prevents a scenario where we haven't made
	// a call to read for a long time and the error may go away sooner.
	Cooldown time.Duration
}

BackoffTuningOptions represents a set of parameters for determining exponential backoff when receiving multiple simultaneous errors.

BaseSleep is the duration to wait after receiving a new error. After that, the wait time doubles for every subsequent, consecutive error of the same type, until the wait duration reaches the MaxSleep duration.

func (*BackoffTuningOptions) GetSleepTimeFromErrorCount

func (opts *BackoffTuningOptions) GetSleepTimeFromErrorCount(errorCount int) time.Duration

GetSleepTimeFromErrorCount returns a sleep time from an error count.