logmux

Documentation

Index

• type Config
• type LogStream
  • func (s *LogStream) Close() string
• type Mux
  • func New(hostID, logDir string, logger log15.Logger) *Mux
  • func (m *Mux) Follow(r io.ReadCloser, buffer string, fd int, config Config) *LogStream
  • func (m *Mux) StreamLog(appID, jobID string, history, follow bool, ch chan<- *rfc5424.Message) (stream.Stream, error)
  • func (m *Mux) StreamToAggregators(s discoverd.Service) error

Types

type Config

type Config struct {
	AppID, HostID, JobID, JobType string
}

type LogStream

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

func (*LogStream) Close

func (s *LogStream) Close() string

type Mux

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

LogMux collects log lines from multiple leaders and forwards them to logaggregator instances and local files.

func New

func New(hostID, logDir string, logger log15.Logger) *Mux

func (*Mux) Follow

func (m *Mux) Follow(r io.ReadCloser, buffer string, fd int, config Config) *LogStream

Follow starts a goroutine that reads log lines from the reader into the mux. It runs until the reader is closed or an error occurs. If an error occurs, the reader may still be open.

func (*Mux) StreamLog

func (m *Mux) StreamLog(appID, jobID string, history, follow bool, ch chan<- *rfc5424.Message) (stream.Stream, error)

func (*Mux) StreamToAggregators

func (m *Mux) StreamToAggregators(s discoverd.Service) error