logbuffer

Documentation

Index

• type Buffer
  • func NewBuffer(maxMessageCount int, maxBufferSize int64) *Buffer
  • func (b *Buffer) Add(record slog.Record) error
  • func (b *Buffer) GetLogs(asc bool, limit int) []*runtimev1.Log
  • func (b *Buffer) WatchLogs(ctx context.Context, fn LogCallback) 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) Add

func (b *Buffer) Add(record slog.Record) error

func (*Buffer) GetLogs

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

func (*Buffer) WatchLogs

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

type LogCallback

type LogCallback func(item *runtimev1.Log)