streamer

Documentation

Index

• type Controller
  • func NewController(conf *config.Config, updates chan provider.Provider) *Controller
  • func (c Controller) InitializeNginx(conf *config.Config)
  • func (c Controller) Validate(prov provider.Provider) error
  • func (c Controller) WatchForRtmp(shutdownChannel chan bool, waitGroup *sync.WaitGroup)
• 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
  • func (c *Process) IsRunning() bool
  • func (c *Process) Pid() (int, error)
  • func (c *Process) Reload() error
  • func (c *Process) Run() error
  • func (c *Process) Stop() error
• type RtmpTemplate
  • func (t RtmpTemplate) Templatize() (string, error)
• type Template
  • func NewNginxTemplate(nginx *config.Config) Template
  • func NewRtmpTemplate(provider *provider.Provider) Template

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