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
- type ReportQueryStore
- type ReportStore
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 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)
Source Files
Click to show internal directories.
Click to hide internal directories.