Documentation
¶
Index ¶
- func CanWriteData() error
- func GetFieldNames(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query) ([]logstorage.ValueWithHits, error)
- func GetFieldValues(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query, ...) ([]logstorage.ValueWithHits, error)
- func GetStreamFieldNames(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query) ([]logstorage.ValueWithHits, error)
- func GetStreamFieldValues(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query, ...) ([]logstorage.ValueWithHits, error)
- func GetStreams(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query, ...) ([]logstorage.ValueWithHits, error)
- func Init()
- func MustAddRows(lr *logstorage.LogRows)
- func RunQuery(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query, ...) error
- func Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CanWriteData ¶ added in v1.94.0
func CanWriteData() error
CanWriteData returns non-nil error if it cannot write data to vlstorage.
func GetFieldNames ¶ added in v1.97.7
func GetFieldNames(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query) ([]logstorage.ValueWithHits, error)
GetFieldNames executes q and returns field names seen in results.
func GetFieldValues ¶ added in v1.97.7
func GetFieldValues(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query, fieldName string, limit uint64) ([]logstorage.ValueWithHits, error)
GetFieldValues executes q and returns unique values for the fieldName seen in results.
If limit > 0, then up to limit unique values are returned.
func GetStreamFieldNames ¶ added in v1.97.7
func GetStreamFieldNames(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query) ([]logstorage.ValueWithHits, error)
GetStreamFieldNames executes q and returns stream field names seen in results.
func GetStreamFieldValues ¶ added in v1.97.7
func GetStreamFieldValues(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query, fieldName string, limit uint64) ([]logstorage.ValueWithHits, error)
GetStreamFieldValues executes q and returns stream field values for the given fieldName seen in results.
If limit > 0, then up to limit unique stream field values are returned.
func GetStreams ¶ added in v1.97.7
func GetStreams(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query, limit uint64) ([]logstorage.ValueWithHits, error)
GetStreams executes q and returns streams seen in query results.
If limit > 0, then up to limit unique streams are returned.
func Init ¶
func Init()
Init initializes vlstorage.
Stop must be called when vlstorage is no longer needed
func MustAddRows ¶
func MustAddRows(lr *logstorage.LogRows)
MustAddRows adds lr to vlstorage
It is advised to call CanWriteData() before calling MustAddRows()
func RunQuery ¶
func RunQuery(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query, writeBlock logstorage.WriteBlockFunc) error
RunQuery runs the given q and calls writeBlock for the returned data blocks
Types ¶
This section is empty.
Source Files