trino

type MetricsStrategy func(ctx context.Context, db *sqlx.DB, tableRow *scrapper.TableRow, tableMetricsRow *scrapper.TableMetricsRow) error

type TrinoCatalog struct {
	CatalogName   string `db:"catalog_name"   json:"catalog_name"`
	ConnectorId   string `db:"connector_id"   json:"connector_id"`
	ConnectorName string `db:"connector_name" json:"connector_name"`
	IsAccepted    bool   `db:"-"              json:"is_accepted"`
}

type TrinoQueryLogSchema struct {
	QueryId         string                `db:"query_id"`
	State           *string               `db:"state"`
	User            *string               `db:"user"`
	Source          *string               `db:"source"`
	Query           *string               `db:"query"`
	ResourceGroupId trino.NullSliceString `db:"resource_group_id"`
	QueuedTimeMs    *int64                `db:"queued_time_ms"`
	AnalysisTimeMs  *int64                `db:"analysis_time_ms"`
	PlanningTimeMs  *int64                `db:"planning_time_ms"`
	Created         *time.Time            `db:"created"`
	Started         *time.Time            `db:"started"`
	LastHeartbeat   *time.Time            `db:"last_heartbeat"`
	End             *time.Time            `db:"end"`
	ErrorType       *string               `db:"error_type"`
	ErrorCode       *string               `db:"error_code"`
}

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

type TrinoScrapperConf struct {
	*dwhexectrino.TrinoConf
	Catalogs               []string
	UseShowCreateView      bool
	UseShowCreateTable     bool
	FetchMaterializedViews bool
	FetchTableComments     bool
}