logman

Documentation

Index

• Variables
• type Config
• type Log
  • func (ml *Log) Backup(w io.Writer) (err error)
  • func (ml *Log) NewReader(follow bool, ioMode recio.IOMode) (lr *log.LogReader, err error)
  • func (ml *Log) NewWriter(ioMode recio.IOMode) (fw *log.FaninWriter, err error)
  • func (ml *Log) Stat() (logInfo LogInfo)
  • func (ml *Log) Status() (status LogStatus)
• type LogInfo
• type LogManager
  • func NewLogManager(config Config, reporter metrics.Reporter) (lm *LogManager, err error)
  • func (lm *LogManager) Close() (err error)
  • func (lm *LogManager) CreateLog(name string, logConfig log.Config) (ml *Log, err error)
  • func (lm *LogManager) DeleteLog(name string) (err error)
  • func (lm *LogManager) GetLog(name string) (ml *Log, err error)
  • func (lm *LogManager) ListLogs() (logs []*Log)
  • func (lm *LogManager) RestoreLog(name string, r io.Reader) (err error)
  • func (lm *LogManager) TruncateLog(name string) (err error)
• type LogStatus

Variables

var (
	ErrClosed      = errors.New("logman: closed")
	ErrNotExist    = errors.New("logman: log does not exist")
	ErrUnavailable = errors.New("logman: log unavailable")
	ErrInvalidName = errors.New("logman: invalid log name")
)

var (
	DefaultConfig = Config{
		DataDirectory:   "./data",
		ReadBufferSize:  1 << 20,
		WriteBufferSize: 1 << 20,
	}
)

Types

type Config

type Config struct {
	DataDirectory   string
	ReadBufferSize  int
	WriteBufferSize int
}

type Log

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

func (*Log) Backup

func (ml *Log) Backup(w io.Writer) (err error)

func (*Log) NewReader

func (ml *Log) NewReader(follow bool, ioMode recio.IOMode) (lr *log.LogReader, err error)

func (*Log) NewWriter

func (ml *Log) NewWriter(ioMode recio.IOMode) (fw *log.FaninWriter, err error)

func (*Log) Stat

func (ml *Log) Stat() (logInfo LogInfo)

func (*Log) Status

func (ml *Log) Status() (status LogStatus)

type LogInfo

type LogInfo struct {
	Name          string
	Status        LogStatus
	RecordCount   int64
	FileSize      int64
	StartPosition int64
	EndPosition   int64
}

type LogManager

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

func NewLogManager

func NewLogManager(config Config, reporter metrics.Reporter) (lm *LogManager, err error)

func (*LogManager) Close

func (lm *LogManager) Close() (err error)

func (*LogManager) CreateLog

func (lm *LogManager) CreateLog(name string, logConfig log.Config) (ml *Log, err error)

func (*LogManager) DeleteLog

func (lm *LogManager) DeleteLog(name string) (err error)

func (*LogManager) GetLog

func (lm *LogManager) GetLog(name string) (ml *Log, err error)

func (*LogManager) ListLogs

func (lm *LogManager) ListLogs() (logs []*Log)

func (*LogManager) RestoreLog

func (lm *LogManager) RestoreLog(name string, r io.Reader) (err error)

func (*LogManager) TruncateLog

func (lm *LogManager) TruncateLog(name string) (err error)

type LogStatus

type LogStatus string

const (
	StatusOK       LogStatus = "ok"
	StatusCorrupt  LogStatus = "corrupt"
	StatusTainted  LogStatus = "tainted"
	StatusScanning LogStatus = "scanning"
	StatusUnknown  LogStatus = "unknown"
)