Documentation
¶
Index ¶
- type Metastore
- type ObjectMetastore
- func (m *ObjectMetastore) DataObjects(ctx context.Context, start, end time.Time, _ ...*labels.Matcher) ([]string, error)
- func (m *ObjectMetastore) Labels(ctx context.Context, start, end time.Time, matchers ...*labels.Matcher) ([]string, error)
- func (m *ObjectMetastore) Streams(ctx context.Context, start, end time.Time, matchers ...*labels.Matcher) ([]*labels.Labels, error)
- func (m *ObjectMetastore) Values(ctx context.Context, start, end time.Time, matchers ...*labels.Matcher) ([]string, error)
- type Updater
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Metastore ¶
type Metastore interface {
// Streams returns all streams corresponding to the given matchers between [start,end]
Streams(ctx context.Context, start, end time.Time, matchers ...*labels.Matcher) ([]*labels.Labels, error)
// DataObjects returns paths to all matching the given matchers between [start,end]
DataObjects(ctx context.Context, start, end time.Time, matchers ...*labels.Matcher) ([]string, error)
// Labels returns all possible labels from matching streams between [start,end]
Labels(ctx context.Context, start, end time.Time, matchers ...*labels.Matcher) ([]string, error) // Used to get possible labels for a given stream
// Values returns all possible values for the given label matchers between [start,end]
Values(ctx context.Context, start, end time.Time, matchers ...*labels.Matcher) ([]string, error) // Used to get all values for a given set of label matchers
}
type ObjectMetastore ¶
type ObjectMetastore struct {
// contains filtered or unexported fields
}
func NewObjectMetastore ¶
func NewObjectMetastore(bucket objstore.Bucket) *ObjectMetastore
func (*ObjectMetastore) DataObjects ¶
type Updater ¶
type Updater struct {
// contains filtered or unexported fields
}
func NewUpdater ¶
func (*Updater) RegisterMetrics ¶
func (m *Updater) RegisterMetrics(reg prometheus.Registerer) error
func (*Updater) UnregisterMetrics ¶
func (m *Updater) UnregisterMetrics(reg prometheus.Registerer)
Click to show internal directories.
Click to hide internal directories.