Upload uploads a TSDB block to the object storage. It verifies basic features of Thanos block.

Wait blocks until the aggregation finishes. The block duration never exceeds aggregation period.

WithResolverMaxNodes specifies the desired maximum number of nodes the resulting profile should include.

IsValid returns true if the version is valid.

AssignJob is called on behalf of the worker to request a new job.

GetIndex returns the bucket index for the given user. It returns the in-memory cached index if available, or load it from the bucket otherwise.

EmptyRowNumber creates an empty invalid row number.

Compact enqueues a new block for compaction

ExpandPostings returns the postings expanded as a slice.

New generates a FlamebearerTimeline, backfilling any missing data with zeros. If startMs or endMs are in the middle of its durationDeltaSec bucket, th

NewFileReader returns a new index reader against the given index file.

NewScheduler creates a scheduler with the given lease duration. Typically, callers should update jobs at the interval not exceeding the half of the le

Next advances the iterator and returns true if another value was found.

UpdateIndex generates the bucket index and returns it, without storing it to the storage. If the old index is not passed in input, then the bucket ind

Dec decrements the counter and calls the release function, if this is the last reference.

Equal compares two protobuf messages ignoring extra generated proto fields.

Flush the store to disk.

Matches reports whether the given set of labels matches the matchers. Note that at least one labels set must satisfy matchers to return true. For nega

NewTenantBucketClient returns a bucket client to use to access the storage on behalf of the provided user. The cfgProvider can be nil.

WriteIndex uploads the provided index to the storage.