insertutil

type BenchmarkLogMessageProcessor struct{}

type CommonParams struct {
	TenantID         logstorage.TenantID
	TimeFields       []string
	MsgFields        []string
	StreamFields     []string
	IgnoreFields     []string
	DecolorizeFields []string
	ExtraFields      []logstorage.Field

	// IsTimeFieldSet means whether the TimeFields is set **manually**.
	// The TimeFields has default value `_time`. It's not empty even if the IsTimeFieldSet is false.
	IsTimeFieldSet bool

	Debug           bool
	DebugRequestURI string
	DebugRemoteAddr string
}

type InsertRowProcessor interface {
	// AddInsertRow must add r to the underlying storage.
	AddInsertRow(r *logstorage.InsertRow)
}

type LineReader struct {
	// Line contains the next line read after the call to NextLine
	//
	// The Line contents is valid until the next call to NextLine.
	Line []byte
	// contains filtered or unexported fields
}

type LogMessageProcessor interface {
	// AddRow must add row to the LogMessageProcessor with the given timestamp and fields.
	//
	// If streamFieldsLen >= 0, then the given number of initial fields must be used as log stream fields instead of pre-configured fields.
	//
	// The LogMessageProcessor implementation cannot hold references to fields, since the caller can reuse them.
	AddRow(timestamp int64, fields []logstorage.Field, streamFieldsLen int)

	// MustClose() must flush all the remaining fields and free up resources occupied by LogMessageProcessor.
	MustClose()
}

type LogRowsStorage interface {
	// MustAddRows must add lr to the underlying storage.
	MustAddRows(lr *logstorage.LogRows)

	// CanWriteData must returns non-nil error if logs cannot be added to the underlying storage.
	CanWriteData() error
}

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