Documentation
¶
Overview ¶
Package logs provides utilities for managing and manipulating log in Arrow format.
Index ¶
- type Iterator
- func (it *Iterator) Attributes(fn func(key, value string))
- func (it *Iterator) EventName() string
- func (it *Iterator) HasNext() bool
- func (it *Iterator) Level() string
- func (it *Iterator) Message() string
- func (it *Iterator) SpanID() []byte
- func (it *Iterator) TimestampNS() int64
- func (it *Iterator) TraceID() []byte
- type LogsBuilder
- func (lb *LogsBuilder) AppendAttributes(nunOfItems int) (appender func(k, v string))
- func (lb *LogsBuilder) AppendEventName(eventName string)
- func (lb *LogsBuilder) AppendLevel(level string)
- func (lb *LogsBuilder) AppendMessage(message string)
- func (lb *LogsBuilder) AppendSpanID(spanID []byte)
- func (lb *LogsBuilder) AppendTimestampNS(timestamp int64)
- func (lb *LogsBuilder) AppendTraceID(traceID []byte)
- func (lb *LogsBuilder) Build() (attributes, logs arrow.RecordBatch)
- func (lb *LogsBuilder) EndLog()
- func (lb *LogsBuilder) NumOfRows() int
- func (lb *LogsBuilder) Release()
- type Reader
- func (r *Reader) Attributes(row int, fn func(key, value string))
- func (r *Reader) EventName(row int) string
- func (r *Reader) Iterator() *Iterator
- func (r *Reader) Level(row int) string
- func (r *Reader) Message(row int) string
- func (r *Reader) NumRows() int
- func (r *Reader) SpanID(row int) []byte
- func (r *Reader) TimestampNS(row int) int64
- func (r *Reader) TraceID(row int) []byte
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Iterator ¶
type Iterator struct {
// contains filtered or unexported fields
}
func NewIterator ¶
func (*Iterator) Attributes ¶
func (*Iterator) TimestampNS ¶
type LogsBuilder ¶
type LogsBuilder struct {
// contains filtered or unexported fields
}
LogsBuilder represents a builder for log entries.
func NewLogsBuilder ¶
func NewLogsBuilder(allocator memory.Allocator) *LogsBuilder
NewLogsBuilder creates a new LogsBuilder with the given memory allocator.
func (*LogsBuilder) AppendAttributes ¶
func (lb *LogsBuilder) AppendAttributes(nunOfItems int) (appender func(k, v string))
AppendAttributes reserves space for the specified number of attributes. It returns a function that can be used to append key-value pairs to the attributes list.
func (*LogsBuilder) AppendEventName ¶
func (lb *LogsBuilder) AppendEventName(eventName string)
AppendEventName appends an event name string to the logs builder.
func (*LogsBuilder) AppendLevel ¶
func (lb *LogsBuilder) AppendLevel(level string)
AppendLevel appends a level string to the logs builder.
func (*LogsBuilder) AppendMessage ¶
func (lb *LogsBuilder) AppendMessage(message string)
AppendMessage appends a message string to the logs builder.
func (*LogsBuilder) AppendSpanID ¶
func (lb *LogsBuilder) AppendSpanID(spanID []byte)
AppendSpanID appends a span ID byte slice to the logs builder.
func (*LogsBuilder) AppendTimestampNS ¶
func (lb *LogsBuilder) AppendTimestampNS(timestamp int64)
AppendTimestampNS appends a timestamp in nanoseconds to the logs builder.
func (*LogsBuilder) AppendTraceID ¶
func (lb *LogsBuilder) AppendTraceID(traceID []byte)
AppendTraceID appends a trace ID byte slice to the logs builder.
func (*LogsBuilder) Build ¶
func (lb *LogsBuilder) Build() (attributes, logs arrow.RecordBatch)
func (*LogsBuilder) EndLog ¶
func (lb *LogsBuilder) EndLog()
EndLog finalizes the current log entry and aligns all columns. NOTE: must be called after appending fields for a log entry.
func (*LogsBuilder) NumOfRows ¶
func (lb *LogsBuilder) NumOfRows() int
NumOfRows returns the number of log entries appended so far.
func (*LogsBuilder) Release ¶
func (lb *LogsBuilder) Release()
Release releases the resources held by the LogsBuilder.
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
func NewReader ¶
func NewReader(logs, attrs arrow.RecordBatch) *Reader
Source Files
Directories