streamer

type IProcess interface {
	Spawn(path, URI string) *exec.Cmd
}

type IStream interface {
	Start() *sync.WaitGroup
	Restart() *sync.WaitGroup
	Stop() error
}

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

type ProcessLoggingOpts struct {
	Enabled    bool   // Option to set logging for transcoding processes
	Directory  string // Directory for the logs
	MaxSize    int    // Maximum size of kept logging files in megabytes
	MaxBackups int    // Maximum number of old log files to retain
	MaxAge     int    // Maximum number of days to retain an old log file.
	Compress   bool   // Indicates if the log rotation should compress the log files
}

type Stream struct {
	ID          string               `json:"id"`
	Path        string               `json:"path"`
	Running     bool                 `json:"running"`
	CMD         *exec.Cmd            `json:"-"`
	Process     IProcess             `json:"-"`
	Mux         *sync.Mutex          `json:"-"`
	Streak      *hotstreak.Hotstreak `json:"-"`
	OriginalURI string               `json:"-"`
	StorePath   string               `json:"-"`
	KeepFiles   bool                 `json:"-"`
	LoggingOpts *ProcessLoggingOpts  `json:"-"`
	Logger      *lumberjack.Logger   `json:"-"`
	WaitTimeOut time.Duration        `json:"-"`
}