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.