std

Documentation

Index

• type ISdSender
• type ProxyStream
  • func NewProxyStream(category string, origin *os.File, sender ISdSender) *ProxyStream
  • func (this *ProxyStream) AddTxTag(lineLog *logsink.LineLog)
  • func (this *ProxyStream) GetWriter() *os.File
  • func (this *ProxyStream) IOCopy()
  • func (this *ProxyStream) LogFlush() *logsink.LineLog
  • func (this *ProxyStream) SetEnabled(b bool)
  • func (this *ProxyStream) Shutdown()
  • func (this *ProxyStream) Write(data []byte) (n int, err error)
• type StdErrSenderThread
  • func GetInstanceStdErr() *StdErrSenderThread
  • func (this *StdErrSenderThread) Add(lineLog *logsink.LineLog)
  • func (this *StdErrSenderThread) Flush()
  • func (this *StdErrSenderThread) GetWriter() io.Writer
  • func (this *StdErrSenderThread) Run()
• type StdOutSenderThread
  • func GetInstanceStdOut() *StdOutSenderThread
  • func (this *StdOutSenderThread) Add(lineLog *logsink.LineLog)
  • func (this *StdOutSenderThread) Flush()
  • func (this *StdOutSenderThread) GetWriter() io.Writer
  • func (this *StdOutSenderThread) Run()

Types

type ISdSender

type ISdSender interface {
	Add(lineLog *logsink.LineLog)
}

type ProxyStream

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

func NewProxyStream

func NewProxyStream(category string, origin *os.File, sender ISdSender) *ProxyStream

func (*ProxyStream) AddTxTag

func (this *ProxyStream) AddTxTag(lineLog *logsink.LineLog)

func (*ProxyStream) GetWriter

func (this *ProxyStream) GetWriter() *os.File

func (*ProxyStream) IOCopy

func (this *ProxyStream) IOCopy()

func (*ProxyStream) LogFlush

func (this *ProxyStream) LogFlush() *logsink.LineLog

func (*ProxyStream) SetEnabled

func (this *ProxyStream) SetEnabled(b bool)

func (*ProxyStream) Shutdown

func (this *ProxyStream) Shutdown()

func (*ProxyStream) Write

func (this *ProxyStream) Write(data []byte) (n int, err error)

type StdErrSenderThread

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

func GetInstanceStdErr

func GetInstanceStdErr() *StdErrSenderThread

func (*StdErrSenderThread) Add

func (this *StdErrSenderThread) Add(lineLog *logsink.LineLog)

func (*StdErrSenderThread) Flush

func (this *StdErrSenderThread) Flush()

func (*StdErrSenderThread) GetWriter

func (this *StdErrSenderThread) GetWriter() io.Writer

func (*StdErrSenderThread) Run

func (this *StdErrSenderThread) Run()

interface of lang conf observer

type StdOutSenderThread

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

func GetInstanceStdOut

func GetInstanceStdOut() *StdOutSenderThread

func (*StdOutSenderThread) Add

func (this *StdOutSenderThread) Add(lineLog *logsink.LineLog)

func (*StdOutSenderThread) Flush

func (this *StdOutSenderThread) Flush()

func (*StdOutSenderThread) GetWriter

func (this *StdOutSenderThread) GetWriter() io.Writer

func (*StdOutSenderThread) Run

func (this *StdOutSenderThread) Run()

interface of lang conf observer