pclog

Documentation

Index

• func GenerateUniqueID(length int) string
• type Connector
  • func NewConnector(mlHandler multiLineHandler, slHandler lineHandler, tail int) *Connector
  • func (c *Connector) GetTailLength() int
  • func (c *Connector) GetUniqueID() string
  • func (c *Connector) SetLines(lines []string)
  • func (c *Connector) WriteString(s string) (n int, err error)
• type LogObserver
• type PCLog
  • func NewLogger() *PCLog
  • func (l *PCLog) Close()
  • func (l *PCLog) Error(message string, process string, replica int)
  • func (l *PCLog) Info(message string, process string, replica int)
  • func (l *PCLog) Open(filePath string)
• type PcLogger
• type PcNilLog
  • func NewNilLogger() *PcNilLog
  • func (l *PcNilLog) Close()
  • func (l *PcNilLog) Error(message string, process string, replica int)
  • func (l *PcNilLog) Info(message string, process string, replica int)
  • func (l *PcNilLog) Open(_ string)
  • func (l *PcNilLog) Sync()
• type ProcessLogBuffer
  • func NewLogBuffer(size int) *ProcessLogBuffer
  • func (b *ProcessLogBuffer) Close()
  • func (b *ProcessLogBuffer) GetLogLength() int
  • func (b *ProcessLogBuffer) GetLogRange(offsetFromEnd, limit int) []string
  • func (b *ProcessLogBuffer) GetLogsAndSubscribe(observer LogObserver)
  • func (b *ProcessLogBuffer) Subscribe(observer LogObserver)
  • func (b *ProcessLogBuffer) UnSubscribe(observer LogObserver)
  • func (b *ProcessLogBuffer) Write(message string)

Functions

func GenerateUniqueID

func GenerateUniqueID(length int) string

Types

type Connector

type Connector struct {
	LogObserver
	// contains filtered or unexported fields
}

func NewConnector

func NewConnector(mlHandler multiLineHandler, slHandler lineHandler, tail int) *Connector

func (*Connector) GetTailLength

func (c *Connector) GetTailLength() int

func (*Connector) GetUniqueID

func (c *Connector) GetUniqueID() string

func (*Connector) SetLines

func (c *Connector) SetLines(lines []string)

func (*Connector) WriteString

func (c *Connector) WriteString(s string) (n int, err error)

type LogObserver

type LogObserver interface {
	WriteString(line string) (n int, err error)
	SetLines(lines []string)
	GetTailLength() int
	GetUniqueID() string
}

type PCLog

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

func NewLogger

func NewLogger() *PCLog

func (*PCLog) Close

func (l *PCLog) Close()

func (*PCLog) Error

func (l *PCLog) Error(message string, process string, replica int)

func (*PCLog) Info

func (l *PCLog) Info(message string, process string, replica int)

func (*PCLog) Open

func (l *PCLog) Open(filePath string)

type PcLogger

type PcLogger interface {
	Open(filePath string)
	Info(message string, process string, replica int)
	Error(message string, process string, replica int)
	Close()
}

type PcNilLog

type PcNilLog struct {
}

func NewNilLogger

func NewNilLogger() *PcNilLog

func (*PcNilLog) Close

func (l *PcNilLog) Close()

func (*PcNilLog) Error

func (l *PcNilLog) Error(message string, process string, replica int)

func (*PcNilLog) Info

func (l *PcNilLog) Info(message string, process string, replica int)

func (*PcNilLog) Open

func (l *PcNilLog) Open(_ string)

func (*PcNilLog) Sync

func (l *PcNilLog) Sync()

type ProcessLogBuffer

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

func NewLogBuffer

func NewLogBuffer(size int) *ProcessLogBuffer

func (*ProcessLogBuffer) Close

func (b *ProcessLogBuffer) Close()

func (*ProcessLogBuffer) GetLogLength

func (b *ProcessLogBuffer) GetLogLength() int

func (*ProcessLogBuffer) GetLogRange

func (b *ProcessLogBuffer) GetLogRange(offsetFromEnd, limit int) []string

func (*ProcessLogBuffer) GetLogsAndSubscribe

func (b *ProcessLogBuffer) GetLogsAndSubscribe(observer LogObserver)

func (*ProcessLogBuffer) Subscribe

func (b *ProcessLogBuffer) Subscribe(observer LogObserver)

func (*ProcessLogBuffer) UnSubscribe

func (b *ProcessLogBuffer) UnSubscribe(observer LogObserver)

func (*ProcessLogBuffer) Write

func (b *ProcessLogBuffer) Write(message string)