logsbuffer

Documentation

Index

• Variables
• type LogItem
• type LogsBuffer
  • func Create(size int) *LogsBuffer
  • func CreateLogbuffer(key string, buffSize int) *LogsBuffer
  • func (l *LogsBuffer) AddLog(t time.Time, msg string, data map[string]any)
  • func (l *LogsBuffer) ClearLog()
  • func (l *LogsBuffer) Fire(entry *logrus.Entry) error
  • func (l *LogsBuffer) GetBufferSize() int
  • func (l *LogsBuffer) GetLastLogs(logItemConvertFunc func(*LogItem) any, maxCount int) []any
  • func (l *LogsBuffer) GetLogCount() int
  • func (l *LogsBuffer) GetLogs(logItemConvertFunc func(*LogItem) any, fTimestamp int64) []any
  • func (l *LogsBuffer) GetLogsByLimit(logItemConvertFunc func(*LogItem) any, pageSize, page int) (int, []any)
  • func (l *LogsBuffer) Levels() []logrus.Level
  • func (l *LogsBuffer) SetBufferSize(size int)
  • func (l *LogsBuffer) SetFireCallback(f func(entry *logrus.Entry) error)
  • func (l *LogsBuffer) Write(p []byte) (n int, err error)

Variables

var LogsBufferStore map[string]*LogsBuffer

var LogsBufferStoreMu sync.Mutex

Types

type LogItem

type LogItem struct {
	Timestamp int64
	Content   string
	Data      map[string]any
}

type LogsBuffer

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

func Create

func Create(size int) *LogsBuffer

func CreateLogbuffer

func CreateLogbuffer(key string, buffSize int) *LogsBuffer

func (*LogsBuffer) AddLog

func (l *LogsBuffer) AddLog(t time.Time, msg string, data map[string]any)

func (*LogsBuffer) ClearLog

func (l *LogsBuffer) ClearLog()

func (*LogsBuffer) Fire

func (l *LogsBuffer) Fire(entry *logrus.Entry) error

func (*LogsBuffer) GetBufferSize

func (l *LogsBuffer) GetBufferSize() int

func (*LogsBuffer) GetLastLogs

func (l *LogsBuffer) GetLastLogs(logItemConvertFunc func(*LogItem) any, maxCount int) []any

func (*LogsBuffer) GetLogCount

func (l *LogsBuffer) GetLogCount() int

func (*LogsBuffer) GetLogs

func (l *LogsBuffer) GetLogs(logItemConvertFunc func(*LogItem) any, fTimestamp int64) []any

func (*LogsBuffer) GetLogsByLimit

func (l *LogsBuffer) GetLogsByLimit(logItemConvertFunc func(*LogItem) any, pageSize, page int) (int, []any)

func (*LogsBuffer) Levels

func (l *LogsBuffer) Levels() []logrus.Level

func (*LogsBuffer) SetBufferSize

func (l *LogsBuffer) SetBufferSize(size int)

func (*LogsBuffer) SetFireCallback

func (l *LogsBuffer) SetFireCallback(f func(entry *logrus.Entry) error)

func (*LogsBuffer) Write

func (l *LogsBuffer) Write(p []byte) (n int, err error)