data

Documentation

Index

• type FileReader
  • func NewFileReader(path string) (*FileReader, error)
  • func (f *FileReader) Close() error
  • func (f *FileReader) Read() (*prompb.WriteRequest, error)
• type FileWriter
  • func NewFileWriter(path string) (*FileWriter, error)
  • func (f *FileWriter) Close() error
  • func (f *FileWriter) Write(wr *prompb.WriteRequest) (int, error)
• type Metric
  • func (m *Metric) Next(timestamp time.Time) *prompb.TimeSeries
• type Set
  • func NewDataSet(opts SetOptions) *Set
  • func (s *Set) Next(timestamp time.Time) *prompb.TimeSeries
• type SetOptions

Types

type FileReader

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

func NewFileReader

func NewFileReader(path string) (*FileReader, error)

func (*FileReader) Close

func (f *FileReader) Close() error

func (*FileReader) Read

func (f *FileReader) Read() (*prompb.WriteRequest, error)

type FileWriter

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

func NewFileWriter

func NewFileWriter(path string) (*FileWriter, error)

func (*FileWriter) Close

func (f *FileWriter) Close() error

func (*FileWriter) Write

func (f *FileWriter) Write(wr *prompb.WriteRequest) (int, error)

type Metric

type Metric struct {
	Labels []*prompb.Label
	// contains filtered or unexported fields
}

func (*Metric) Next

func (m *Metric) Next(timestamp time.Time) *prompb.TimeSeries

type Set

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

func NewDataSet

func NewDataSet(opts SetOptions) *Set

func (*Set) Next

func (s *Set) Next(timestamp time.Time) *prompb.TimeSeries

type SetOptions

type SetOptions struct {
	NumMetrics  int
	Cardinality int
	Database    string
}