common

package

v3.1.1 Latest Latest Go to latest Published: Aug 8, 2024 License: AGPL-3.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/grafana/loki

Links

Open Source Insights

Documentation ¶

Index ¶

func NewTSDBSeriesIter(ctx context.Context, user string, f sharding.ForSeries, ...) (v1.Iterator[*v1.Series], error)
type BloomTSDBStore
- func NewBloomTSDBStore(storage storage.Client, logger log.Logger) *BloomTSDBStore
type TSDBStore
type TSDBStores
- func NewTSDBStores(schemaCfg config.SchemaConfig, storeCfg baseStore.Config, ...) (*TSDBStores, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewTSDBSeriesIter ¶

func NewTSDBSeriesIter(ctx context.Context, user string, f sharding.ForSeries, bounds v1.FingerprintBounds) (v1.Iterator[*v1.Series], error)

Types ¶

type BloomTSDBStore ¶

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

BloomTSDBStore is a wrapper around the storage.Client interface which implements the TSDBStore interface for this pkg.

func NewBloomTSDBStore ¶

func NewBloomTSDBStore(storage storage.Client, logger log.Logger) *BloomTSDBStore

func (*BloomTSDBStore) LoadTSDB ¶

func (b *BloomTSDBStore) LoadTSDB(
	ctx context.Context,
	table config.DayTable,
	tenant string,
	id tsdb.Identifier,
	bounds v1.FingerprintBounds,
) (v1.Iterator[*v1.Series], error)

func (*BloomTSDBStore) ResolveTSDBs ¶

func (b *BloomTSDBStore) ResolveTSDBs(ctx context.Context, table config.DayTable, tenant string) ([]tsdb.SingleTenantTSDBIdentifier, error)

func (*BloomTSDBStore) UsersForPeriod ¶

func (b *BloomTSDBStore) UsersForPeriod(ctx context.Context, table config.DayTable) ([]string, error)

type TSDBStore ¶

type TSDBStore interface {
	UsersForPeriod(ctx context.Context, table config.DayTable) ([]string, error)
	ResolveTSDBs(ctx context.Context, table config.DayTable, tenant string) ([]tsdb.SingleTenantTSDBIdentifier, error)
	LoadTSDB(
		ctx context.Context,
		table config.DayTable,
		tenant string,
		id tsdb.Identifier,
		bounds v1.FingerprintBounds,
	) (v1.Iterator[*v1.Series], error)
}

type TSDBStores ¶

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

func NewTSDBStores ¶

func NewTSDBStores(
	schemaCfg config.SchemaConfig,
	storeCfg baseStore.Config,
	clientMetrics baseStore.ClientMetrics,
	logger log.Logger,
) (*TSDBStores, error)

func (*TSDBStores) LoadTSDB ¶

func (s *TSDBStores) LoadTSDB(
	ctx context.Context,
	table config.DayTable,
	tenant string,
	id tsdb.Identifier,
	bounds v1.FingerprintBounds,
) (v1.Iterator[*v1.Series], error)

func (*TSDBStores) ResolveTSDBs ¶

func (s *TSDBStores) ResolveTSDBs(ctx context.Context, table config.DayTable, tenant string) ([]tsdb.SingleTenantTSDBIdentifier, error)

func (*TSDBStores) UsersForPeriod ¶

func (s *TSDBStores) UsersForPeriod(ctx context.Context, table config.DayTable) ([]string, error)

Source Files ¶

View all Source files

tsdb.go

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