logbuffer

Documentation

Index

• type Buffer
  • func NewBuffer(maxMessageCount int, maxBufferSize int64) *Buffer
  • func (b *Buffer) AddEntry(lvl runtimev1.LogLevel, t time.Time, msg, payload string) error
  • func (b *Buffer) GetLogs(asc bool, limit int, minLvl runtimev1.LogLevel) []*runtimev1.Log
  • func (b *Buffer) WatchLogs(ctx context.Context, fn LogCallback, minLvl runtimev1.LogLevel) error
• type LogCallback

Types

type Buffer

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

func NewBuffer

func NewBuffer(maxMessageCount int, maxBufferSize int64) *Buffer

func (*Buffer) AddEntry

func (b *Buffer) AddEntry(lvl runtimev1.LogLevel, t time.Time, msg, payload string) error

func (*Buffer) GetLogs

func (b *Buffer) GetLogs(asc bool, limit int, minLvl runtimev1.LogLevel) []*runtimev1.Log

func (*Buffer) WatchLogs

func (b *Buffer) WatchLogs(ctx context.Context, fn LogCallback, minLvl runtimev1.LogLevel) error

type LogCallback

type LogCallback func(item *runtimev1.Log)