streamer

package

v0.0.0-...-1ce205e Latest Latest Go to latest Published: Nov 25, 2019 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/VEVO/fraser

Documentation ¶

Index ¶

type Controller
- func NewController(conf *config.Config, updates chan provider.Provider) *Controller
type GenericProcess
- func NewProcess(binary string, args []string) GenericProcess
type NginxService
- func NewNginxService(conf *config.Config) *NginxService
- func (n *NginxService) ConfigureServer() error
- func (n *NginxService) RunServer(shutdownChannel chan bool, waitGroup *sync.WaitGroup, controller *Controller, ...)
type NginxTemplate
- func (t NginxTemplate) Templatize() (string, error)
type Process
type RtmpTemplate
- func (t RtmpTemplate) Templatize() (string, error)
type Template
- func NewNginxTemplate(nginx *config.Config) Template
- func NewRtmpTemplate(provider *provider.Provider) Template

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Controller ¶

type Controller struct {
	Config  *config.Config
	Updates chan provider.Provider
}

func NewController ¶

func NewController(conf *config.Config, updates chan provider.Provider) *Controller

func (Controller) InitializeNginx ¶

func (c Controller) InitializeNginx(conf *config.Config)

func (Controller) Validate ¶

func (c Controller) Validate(prov provider.Provider) error

func (Controller) WatchForRtmp ¶

func (c Controller) WatchForRtmp(shutdownChannel chan bool, waitGroup *sync.WaitGroup)

type GenericProcess ¶

type GenericProcess interface {
	Run() error
	IsRunning() bool
	Stop() error
	Reload() error
	Pid() (int, error)
}

func NewProcess ¶

func NewProcess(binary string, args []string) GenericProcess

type NginxService ¶

type NginxService struct {
	Config  *config.Config
	Process GenericProcess
	Status  string
}

func NewNginxService ¶

func NewNginxService(conf *config.Config) *NginxService

func (*NginxService) ConfigureServer ¶

func (n *NginxService) ConfigureServer() error

func (*NginxService) RunServer ¶

func (n *NginxService) RunServer(shutdownChannel chan bool, waitGroup *sync.WaitGroup, controller *Controller, stat stats.StatsProvider, errorChannel chan bool)

type NginxTemplate ¶

type NginxTemplate struct {
	Config *config.Config
}

func (NginxTemplate) Templatize ¶

func (t NginxTemplate) Templatize() (string, error)

type Process ¶

type Process struct {
	Binary string
	Args   []string
	State  *exec.Cmd
}

func (*Process) IsRunning ¶

func (c *Process) IsRunning() bool

func (*Process) Pid ¶

func (c *Process) Pid() (int, error)

func (*Process) Reload ¶

func (c *Process) Reload() error

func (*Process) Run ¶

func (c *Process) Run() error

func (*Process) Stop ¶

func (c *Process) Stop() error

type RtmpTemplate ¶

type RtmpTemplate struct {
	Provider *provider.Provider
}

func (RtmpTemplate) Templatize ¶

func (t RtmpTemplate) Templatize() (string, error)

type Template ¶

type Template interface {
	Templatize() (string, error)
}

func NewNginxTemplate ¶

func NewNginxTemplate(nginx *config.Config) Template

func NewRtmpTemplate ¶

func NewRtmpTemplate(provider *provider.Provider) Template

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL