streaming

Documentation

Index

• Variables
• func GetURIDirectory(URI string) (string, error)
• func ValidateURL(URL *url.URL) error
• type IProcessor
• type Processor
  • func NewProcessor(storeDir string, keepFiles bool, loggingOpts config.ProcessLogging) *Processor
  • func (p Processor) NewProcess(URI string) *exec.Cmd
  • func (p Processor) NewStream(URI string) (*Stream, string)
  • func (p Processor) Restart(strm *Stream, path string) error
• type Stream
  • func (strm *Stream) CleanProcess() error

Variables

var ErrInvalidHost = errors.New("Invalid hostname")

ErrInvalidHost describes an error for a hostname that is considered invalid if it's empty

var ErrUnparsedURL = errors.New("URL is not parsed correctly")

ErrUnparsedURL describes an error that occours when the parsing process cannot be deemed as successful

Functions

func GetURIDirectory

func GetURIDirectory(URI string) (string, error)

GetURIDirectory is a function to create a directory string from an URI

func ValidateURL

func ValidateURL(URL *url.URL) error

ValidateURL checks if everything is present for the given URL

Types

type IProcessor

type IProcessor interface {
	NewProcess(URI string) *exec.Cmd
	NewStream(URI string) (*Stream, string)
	Restart(stream *Stream, path string) error
}

IProcessor is an interface describing a processor service

type Processor

type Processor struct {
	// contains filtered or unexported fields
}

Processor is the main type for creating new processes

func NewProcessor

func NewProcessor(
	storeDir string,
	keepFiles bool,
	loggingOpts config.ProcessLogging,
) *Processor

NewProcessor creates a new instance of a processor

func (Processor) NewProcess

func (p Processor) NewProcess(URI string) *exec.Cmd

NewProcess creates only the process for the stream

func (Processor) NewStream

func (p Processor) NewStream(URI string) (*Stream, string)

NewStream creates a new transcoding process for ffmpeg

func (Processor) Restart

func (p Processor) Restart(strm *Stream, path string) error

Restart uses the processor to restart a given stream

type Stream

type Stream struct {
	CMD         *exec.Cmd            `json:"-"`
	Mux         *sync.RWMutex        `json:"-"`
	Path        string               `json:"path"`
	Streak      *hotstreak.Hotstreak `json:"-"`
	OriginalURI string               `json:"-"`
	StorePath   string               `json:"-"`
	KeepFiles   bool                 `json:"-"`
	Logger      *lumberjack.Logger   `json:"-"`
}

Stream describes a given host's streaming

func (*Stream) CleanProcess

func (strm *Stream) CleanProcess() error

CleanProcess makes sure that the transcoding process is killed correctly