Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

autotee

package

Go to main page

Versions in this module

v0

v0.4.0

Aug 22, 2016

Changes in this version

+ func IsExit(errFromWait error) bool

v0.3.0

Aug 18, 2016

Changes in this version

+ var UseDefaults = func(interface{}) error

+ var Version = "devel"

+ func Catch(err error) error

+ func Main()

+ func ShowConfigMain(config *Config) error

+ func ShowIdleness(d time.Duration)

+ func ShowStreamsMain(config *Config) error

+ func TickNow(d time.Duration) <-chan time.Time

+ func WatchChannel(in <-chan *BufPoolElem, timeout time.Duration, notify func()) <-chan *BufPoolElem

+ type App struct

+ Config *Config

+ Flows map[string][]*Flow

+ func NewApp(config *Config) *App

+ func (app *App) Run() error

+ type BaseScreenService struct

+ type BufPool struct

+ C <-chan *BufPoolElem

+ func NewBufPool(nbuf, bufsize int) *BufPool

+ func (bp *BufPool) IsFull() bool

+ type BufPoolElem struct

+ func (elem *BufPoolElem) Acquire(refs int32)

+ func (elem *BufPoolElem) AcquireFirst()

+ func (elem *BufPoolElem) Free()

+ func (elem *BufPoolElem) GetBuffer() []byte

+ func (elem *BufPoolElem) GetMaxSize() int

+ func (elem *BufPoolElem) SetSize(n int)

+ type BufferConfig struct

+ BufferCount int

+ type BufferPoolConfig struct

+ BufferCount int

+ BufferSize int

+ type Cmd struct

+ func Command(name string, args ...string) *Cmd

+ func (c *Cmd) End() error

+ func (c *Cmd) EndWith(otherCmd *Cmd)

+ func (c *Cmd) KillGroup() error

+ func (c *Cmd) SetStderr(w io.Writer)

+ func (c *Cmd) SetStdin(r io.Reader)

+ func (c *Cmd) Start() error

+ func (c *Cmd) StdinPipe() (io.WriteCloser, error)

+ func (c *Cmd) StdoutPipe() (io.ReadCloser, error)

+ func (c *Cmd) WaitChannel() <-chan error

+ type CmdData struct

+ Args []string

+ Name string

+ func NewCmdData(line string) (cd CmdData, err error)

+ func (cd *CmdData) Equals(other CmdData) bool

+ func (cd *CmdData) NewCmd() *Cmd

+ func (cd *CmdData) Replace(replacements map[string]string) (result CmdData)

+ func (cd *CmdData) String() string

+ type Config struct

+ Debug bool

+ Flows map[string]FlowConfig

+ Metrics MetricsConfig

+ Misc MiscConfig

+ Server ServerConfig

+ SinkBuffer BufferConfig

+ SourceBuffer BufferPoolConfig

+ Times TimeConfig

+ func LoadConfig(path string) (*Config, error)

+ func (c *Config) Dump() ([]byte, error)

+ func (tc *Config) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type ExclusiveScreenService struct

+ func (s *ExclusiveScreenService) Done() error

+ func (s *ExclusiveScreenService) Screen() (*Screen, error)

+ func (s *ExclusiveScreenService) Stop()

+ type Flow struct

+ func NewFlow(name string, config *Config, sourceCmd CmdData, sinkCmds map[string]CmdData, ...) *Flow

+ func (f *Flow) Start()

+ func (f *Flow) Stop()

+ type FlowCmdData struct

+ type FlowConfig struct

+ Regexp *regexp.Regexp

+ Sinks map[string]CmdData

+ Source CmdData

+ func (fc *FlowConfig) UnmarshalYAML(unmarshal func(interface{}) error) (err error)

+ type Icecast struct

+ func (nr *Icecast) GetActiveStreams() (mapset.Set, error)

+ type IcecastUrls struct

+ func (iu *IcecastUrls) UnmarshalJSON(bytes []byte) error

+ type InfluxConfig struct

+ Database string

+ Host string

+ Password string

+ Username string

+ type MetricsConfig struct

+ Influx *InfluxConfig

+ type MiscConfig struct

+ RestartWhenSinkDies bool

+ ReuseScreens bool

+ func (mc *MiscConfig) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type NginxRtmp struct

+ func (nr *NginxRtmp) GetActiveStreams() (mapset.Set, error)

+ type RestartableTimer struct

+ C <-chan time.Time

+ func NewRestartableTimer(d time.Duration) RestartableTimer

+ func (st *RestartableTimer) Restart()

+ func (st *RestartableTimer) Start()

+ func (st *RestartableTimer) Stop()

+ type Screen struct

+ File *os.File

+ Name string

+ type ScreenService interface

+ Done func() error

+ Screen func() (*Screen, error)

+ Stop func()

+ func NewExclusiveScreenService(name string) ScreenService

+ func NewSharedScreenService(name string) ScreenService

+ type Server interface

+ GetActiveStreams func() (mapset.Set, error)

+ func NewIcecast(config *Config) Server

+ func NewNginxRtmp(config *Config) Server

+ func NewStaticStreamList(config *Config) Server

+ type ServerConfig struct

+ App string

+ NewServer ServerFactory

+ Streams mapset.Set

+ Url string

+ XPath *xmlpath.Path

+ func (sc *ServerConfig) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type ServerFactory func(config *Config) Server

+ type SharedScreenService struct

+ func (s *SharedScreenService) Done() error

+ func (s *SharedScreenService) Screen() (*Screen, error)

+ func (s *SharedScreenService) Stop()

+ type Sink struct

+ func NewSink(entry *log.Entry, name string, command CmdData, config *BufferConfig, ...) *Sink

+ func (s *Sink) Channel() chan<- *BufPoolElem

+ func (s *Sink) DeathBarrier() <-chan struct{}

+ func (s *Sink) Kill()

+ func (s *Sink) Start() (err error)

+ func (s *Sink) Stop()

+ type SinkCmdData struct

+ Command CmdData

+ Screens ScreenService

+ type SinkSet struct

+ func NewSinkSet(commands map[string]SinkCmdData, buffers <-chan *BufPoolElem, config *Config, ...) *SinkSet

+ func (ss *SinkSet) AnySinkDied() <-chan struct{}

+ func (ss *SinkSet) Start()

+ func (ss *SinkSet) Stop()

+ type Source struct

+ func NewSource(name string, command CmdData, config *Config, entry *log.Entry, ...) *Source

+ func (s *Source) Channel() <-chan *BufPoolElem

+ func (s *Source) DeathBarrier() <-chan struct{}

+ func (s *Source) Kill()

+ func (s *Source) Start() (err error)

+ func (s *Source) Stop()

+ type StaticStreamList struct

+ func (nr *StaticStreamList) GetActiveStreams() (mapset.Set, error)

+ type TimeConfig struct

+ IdleTime time.Duration

+ ServerPollInterval time.Duration

+ ServerRequestTimeout time.Duration

+ ServerTimeout time.Duration

+ SinkRestartDelay time.Duration

+ SourceRestartDelay time.Duration

+ SourceTimeout time.Duration

+ func (tc *TimeConfig) UnmarshalYAML(unmarshal func(interface{}) error) error

v0.2.0

Dec 28, 2015

v0.1.0

Dec 18, 2015