testhelpers

Documentation

Index

• func AssertErrorContainsErrorMsgs(t *testing.T, err error, errMsgArr []string)
• func AssertReportResultsEqual(t *testing.T, expected, actual []map[string]interface{}, ...)
• func NewPrestoTable(name, namespace, catalog, schema string, columns []presto.Column) *metering.PrestoTable
• func NewReport(name, namespace, testQueryName string, reportStart, reportEnd *time.Time, ...) *metering.Report
• func NewReportDataSource(name, namespace string) *metering.ReportDataSource
• func NewReportQuery(name, namespace string, columns []metering.ReportQueryColumn) *metering.ReportQuery
• func PtrToBool(val bool) *bool
• func SetupLogger(logLevelStr string) logrus.FieldLogger
• type ReportDataSourceStore
  • func NewReportDataSourceStore(datasources []*metering.ReportDataSource) (store *ReportDataSourceStore)
  • func (store *ReportDataSourceStore) GetReportDataSource(namespace, name string) (*metering.ReportDataSource, error)
• type ReportQueryStore
  • func NewReportQueryStore(queries []*metering.ReportQuery) (store *ReportQueryStore)
  • func (store *ReportQueryStore) GetReportQuery(namespace, name string) (*metering.ReportQuery, error)
• type ReportStore
  • func NewReportStore(reports []*metering.Report) (store *ReportStore)
  • func (store *ReportStore) GetReport(namespace, name string) (*metering.Report, error)

Functions

func AssertErrorContainsErrorMsgs

func AssertErrorContainsErrorMsgs(t *testing.T, err error, errMsgArr []string)

func AssertReportResultsEqual

func AssertReportResultsEqual(t *testing.T, expected, actual []map[string]interface{}, comparisonColumnNames []string)

func NewPrestoTable

func NewPrestoTable(name, namespace, catalog, schema string, columns []presto.Column) *metering.PrestoTable

func NewReport

func NewReport(name, namespace, testQueryName string, reportStart, reportEnd *time.Time, status metering.ReportStatus, schedule *metering.ReportSchedule, runImmediately bool) *metering.Report

NewReport creates a mock report used for testing purposes.

func NewReportDataSource

func NewReportDataSource(name, namespace string) *metering.ReportDataSource

func NewReportQuery

func NewReportQuery(name, namespace string, columns []metering.ReportQueryColumn) *metering.ReportQuery

func PtrToBool

func PtrToBool(val bool) *bool

func SetupLogger

func SetupLogger(logLevelStr string) logrus.FieldLogger

Types

type ReportDataSourceStore

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

func NewReportDataSourceStore

func NewReportDataSourceStore(datasources []*metering.ReportDataSource) (store *ReportDataSourceStore)

func (*ReportDataSourceStore) GetReportDataSource

func (store *ReportDataSourceStore) GetReportDataSource(namespace, name string) (*metering.ReportDataSource, error)

type ReportQueryStore

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

func NewReportQueryStore

func NewReportQueryStore(queries []*metering.ReportQuery) (store *ReportQueryStore)

func (*ReportQueryStore) GetReportQuery

func (store *ReportQueryStore) GetReportQuery(namespace, name string) (*metering.ReportQuery, error)

type ReportStore

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

func NewReportStore

func NewReportStore(reports []*metering.Report) (store *ReportStore)

func (*ReportStore) GetReport

func (store *ReportStore) GetReport(namespace, name string) (*metering.Report, error)