vlstorage

Documentation

Index

• func CanWriteData() error
• func GetFieldNames(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query) ([]string, error)
• func GetFieldValues(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query, ...) ([]string, error)
• func Init()
• func MustAddRows(lr *logstorage.LogRows)
• func RunQuery(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query, ...) error
• func Stop()

Functions

func CanWriteData

func CanWriteData() error

CanWriteData returns non-nil error if it cannot write data to vlstorage.

func GetFieldNames

func GetFieldNames(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query) ([]string, error)

GetFieldNames executes q and returns field names seen in results.

func GetFieldValues

func GetFieldValues(ctx context.Context, tenantIDs []logstorage.TenantID, q *logstorage.Query, fieldName string, limit uint64) ([]string, 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 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

func Stop

func Stop()

Stop stops vlstorage.