testutil

package

v2.4.3 Latest Latest Go to latest Published: Feb 9, 2022 License: AGPL-3.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/frelon/loki

Links

Open Source Insights

Documentation ¶

Index ¶

func AddRecordsToBatch(batch chunk.WriteBatch, tableName string, start, numRecords int)
func AddRecordsToDB(t *testing.T, path string, dbClient *local.BoltIndexClient, ...)
func BuildUserID(id int) string
func CompareDBs(t *testing.T, db1, db2 *bbolt.DB)
func DecompressFile(t *testing.T, src, dest string)
func SetupDBsAtPath(t *testing.T, path string, dbs map[string]DBConfig, bucketName []byte) string
func SetupTable(t *testing.T, path string, commonDBsConfig DBsConfig, ...)
func TestMultiTableQuery(t *testing.T, userID string, queries []chunk.IndexQuery, ...)
func TestSingleDBQuery(t *testing.T, query chunk.IndexQuery, db *bbolt.DB, bucketName []byte, ...)
func TestSingleTableQuery(t *testing.T, userID string, queries []chunk.IndexQuery, ...)
type DBConfig
type DBRecords
type DBsConfig
- func (c DBsConfig) String() string
type MultiTableQuerier
type PerUserDBsConfig
- func (c PerUserDBsConfig) String() string
type SingleDBQuerier
type SingleTableQuerier

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddRecordsToBatch ¶

func AddRecordsToBatch(batch chunk.WriteBatch, tableName string, start, numRecords int)

func AddRecordsToDB ¶

func AddRecordsToDB(t *testing.T, path string, dbClient *local.BoltIndexClient, start, numRecords int, bucketName []byte)

func BuildUserID ¶

func BuildUserID(id int) string

func CompareDBs ¶

func CompareDBs(t *testing.T, db1, db2 *bbolt.DB)

func DecompressFile ¶

func DecompressFile(t *testing.T, src, dest string)

func SetupDBsAtPath ¶

func SetupDBsAtPath(t *testing.T, path string, dbs map[string]DBConfig, bucketName []byte) string

func SetupTable ¶

func SetupTable(t *testing.T, path string, commonDBsConfig DBsConfig, perUserDBsConfig PerUserDBsConfig)

func TestMultiTableQuery ¶

func TestMultiTableQuery(t *testing.T, userID string, queries []chunk.IndexQuery, querier MultiTableQuerier, start, numRecords int)

func TestSingleDBQuery ¶

func TestSingleDBQuery(t *testing.T, query chunk.IndexQuery, db *bbolt.DB, bucketName []byte, querier SingleDBQuerier, start, numRecords int)

func TestSingleTableQuery ¶

func TestSingleTableQuery(t *testing.T, userID string, queries []chunk.IndexQuery, querier SingleTableQuerier, start, numRecords int)

Types ¶

type DBConfig ¶

type DBConfig struct {
	CompressFile bool
	DBRecords
}

type DBRecords ¶

type DBRecords struct {
	Start, NumRecords int
}

type DBsConfig ¶

type DBsConfig struct {
	DBRecordsStart                     int
	NumUnCompactedDBs, NumCompactedDBs int
}

func (DBsConfig) String ¶

func (c DBsConfig) String() string

type MultiTableQuerier ¶

type MultiTableQuerier interface {
	QueryPages(ctx context.Context, queries []chunk.IndexQuery, callback chunk_util.Callback) error
}

type PerUserDBsConfig ¶

type PerUserDBsConfig struct {
	DBsConfig
	NumUsers int
}

func (PerUserDBsConfig) String ¶

func (c PerUserDBsConfig) String() string

type SingleDBQuerier ¶

type SingleDBQuerier interface {
	QueryDB(ctx context.Context, db *bbolt.DB, bucketName []byte, query chunk.IndexQuery, callback func(chunk.IndexQuery, chunk.ReadBatch) (shouldContinue bool)) error
}

type SingleTableQuerier ¶

type SingleTableQuerier interface {
	MultiQueries(ctx context.Context, queries []chunk.IndexQuery, callback chunk_util.Callback) error
}

Source Files ¶

View all Source files

testutil.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL