Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectionCount ¶
type ConnectionCount struct {
DestinationConnector string `db:"destination"`
SourceConnector string `db:"source"`
Status string `db:"status"`
Count uint `db:"count"`
}
ConnectionCount holds a count of Airbyte connections, grouped by destination connector, source connector and status.
type JobCount ¶
type JobCount struct {
DestinationConnector string `db:"destination"`
SourceConnector string `db:"source"`
Type string `db:"config_type"`
Status string `db:"status"`
Count uint `db:"count"`
}
JobCount holds a count of Airbyte jobs, grouped by destination connector, source connector, type and status.
type Metrics ¶
type Metrics struct {
// Airbyte connections
Connections []ConnectionCount
// Airbyte jobs
JobsCompleted []JobCount
JobsPending []JobCount
JobsRunning []JobCount
}
Metrics represents available Airbyte metrics.
type Repository ¶
type Repository struct {
// contains filtered or unexported fields
}
Repository provides an abstraction layer to perform SQL queries against the Airbyte PostgreSQL database.
func NewRepository ¶
func NewRepository(db *sqlx.DB) *Repository
NewRepository initializes and returns an Airbyte Repository.
func (*Repository) ConnectionsCount ¶
func (r *Repository) ConnectionsCount() ([]ConnectionCount, error)
ConnectionsCount returns the count of Airbyte connections, grouped by destination, source and status.
func (*Repository) JobsCompletedCount ¶
func (r *Repository) JobsCompletedCount() ([]JobCount, error)
JobsCompletedCount returns the count of completed Airbyte jobs, grouped by destination, source, type and status.
func (*Repository) JobsPendingCount ¶
func (r *Repository) JobsPendingCount() ([]JobCount, error)
JobsPendingCount returns the count of pending Airbyte jobs, grouped by destination, source and type.
func (*Repository) JobsRunningCount ¶
func (r *Repository) JobsRunningCount() ([]JobCount, error)
JobsRunningCount returns the count of running Airbyte jobs, grouped by destination, source and type.
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service handles domain operations for gathering metrics from Airbyte's PostgreSQL database.
func NewService ¶
func NewService(r *Repository) *Service
NewService initializes and returns an Airbyte Service.
func (*Service) GatherMetrics ¶
GatherMetrics gathers and returns metrics from Airbyte's PostgreSQL database.
Source Files