wasmlogs

Oct 25, 2024

Changes in this version

+ const DefaultBufferChannelLen

+ const DefaultFilePerms

+ const LogMessageDataSizeOffset

+ const LogMessageHeaderLength

+ const LogMessageStreamOffset

+ const LogMessageTimestampOffset

+ type LogManager struct

+ func NewLogManager(ctx context.Context, executionID string) (*LogManager, error)

+ func (lm *LogManager) Close()

+ func (lm *LogManager) Drain()

+ func (lm *LogManager) GetDefaultReaders(follow bool) (io.Reader, io.Reader)

+ func (lm *LogManager) GetMuxedReader(follow bool) io.ReadCloser

+ func (lm *LogManager) GetWriters() (io.WriteCloser, io.WriteCloser)

+ type LogMessage struct

+ Data []byte

+ Stream LogStreamType

+ Timestamp int64

+ func (m *LogMessage) FromReader(reader bufio.Reader) error

+ func (m *LogMessage) ToBytes() []byte

+ type LogMessageTransformer func(*LogMessage) []byte

+ type LogReader struct

+ func NewLogReader(options LogReaderOptions) *LogReader

+ func (r *LogReader) Close() error

+ func (r *LogReader) Read(b []byte) (int, error)

+ type LogReaderOptions struct

+ type LogStreamType int8

+ const LogStreamStderr

+ const LogStreamStdout

+ type LogWriter struct

+ func NewLogWriter(buffer *generic.RingBuffer[*LogMessage], transformer LogWriterTransform) *LogWriter

+ func (w *LogWriter) Close() error

+ func (w *LogWriter) Write(b []byte) (int, error)

+ type LogWriterTransform func([]byte) *LogMessage