statsreader

Documentation

Index

• type CompositeReader
• type DatabaseReader
  • func NewDatabaseReader(ctx context.Context, parsedMetadata []*metadata.MetricsMetadata, ...) (*DatabaseReader, error)
  • func (databaseReader *DatabaseReader) Name() string
  • func (databaseReader *DatabaseReader) Read(ctx context.Context) ([]*metadata.MetricsDataPoint, error)
  • func (databaseReader *DatabaseReader) Shutdown()
• type ProjectReader
  • func NewProjectReader(databaseReaders []CompositeReader, logger *zap.Logger) *ProjectReader
  • func (projectReader *ProjectReader) Name() string
  • func (projectReader *ProjectReader) Read(ctx context.Context) ([]*metadata.MetricsDataPoint, error)
  • func (projectReader *ProjectReader) Shutdown()
• type Reader
• type ReaderConfig

Types

type CompositeReader

type CompositeReader interface {
	Reader
	// Shutdown Use this method to perform any additional cleanup of underlying components.
	Shutdown()
}

CompositeReader - this interface is used for the composition of multiple Reader(s). Main difference between it and Reader - this interface also has Shutdown method for performing some additional cleanup necessary for each Reader instance.

type DatabaseReader

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

func NewDatabaseReader

func NewDatabaseReader(ctx context.Context,
	parsedMetadata []*metadata.MetricsMetadata,
	databaseID *datasource.DatabaseID,
	serviceAccountPath string,
	readerConfig ReaderConfig,
	logger *zap.Logger,
) (*DatabaseReader, error)

func (*DatabaseReader) Name

func (databaseReader *DatabaseReader) Name() string

func (*DatabaseReader) Read

func (databaseReader *DatabaseReader) Read(ctx context.Context) ([]*metadata.MetricsDataPoint, error)

func (*DatabaseReader) Shutdown

func (databaseReader *DatabaseReader) Shutdown()

type ProjectReader

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

func NewProjectReader

func NewProjectReader(databaseReaders []CompositeReader, logger *zap.Logger) *ProjectReader

func (*ProjectReader) Name

func (projectReader *ProjectReader) Name() string

func (*ProjectReader) Read

func (projectReader *ProjectReader) Read(ctx context.Context) ([]*metadata.MetricsDataPoint, error)

func (*ProjectReader) Shutdown

func (projectReader *ProjectReader) Shutdown()

type Reader

type Reader interface {
	Name() string
	Read(ctx context.Context) ([]*metadata.MetricsDataPoint, error)
}

type ReaderConfig

type ReaderConfig struct {
	TopMetricsQueryMaxRows            int
	BackfillEnabled                   bool
	HideTopnLockstatsRowrangestartkey bool
	TruncateText                      bool
}