airbyte

Jan 16, 2024

Changes in this version

type ConnectionSyncAge

+ ScheduleType string

type JobCount

+ ScheduleType string

Jun 19, 2023

Changes in this version

+ type ActorCount struct

+ ActorConnector string

+ Count uint

+ Tombstone bool

+ type ConnectionSyncAge struct

+ DestinationConnector string

+ Hours float64

+ ID string

+ SourceConnector string

+ func (csa *ConnectionSyncAge) Age() (time.Duration, error)

type Metrics

+ ConnectionsLastSuccessfulSyncAges []ConnectionSyncAge

+ Destinations []ActorCount

+ Sources []ActorCount

type Repository

+ func (r *Repository) ConnectionsLastSuccessfulSyncAge() ([]ConnectionSyncAge, error)

+ func (r *Repository) DestinationsCount() ([]ActorCount, error)

+ func (r *Repository) SourcesCount() ([]ActorCount, error)

Jun 12, 2023

Changes in this version

+ type ConnectionCount struct

+ Count uint

+ DestinationConnector string

+ SourceConnector string

+ Status string

+ type JobCount struct

+ Count uint

+ DestinationConnector string

+ SourceConnector string

+ Status string

+ Type string

+ type Metrics struct

+ Connections []ConnectionCount

+ JobsCompleted []JobCount

+ JobsPending []JobCount

+ JobsRunning []JobCount

+ type Repository struct

+ func NewRepository(db *sqlx.DB) *Repository

+ func (r *Repository) ConnectionsCount() ([]ConnectionCount, error)

+ func (r *Repository) JobsCompletedCount() ([]JobCount, error)

+ func (r *Repository) JobsPendingCount() ([]JobCount, error)

+ func (r *Repository) JobsRunningCount() ([]JobCount, error)

+ type Service struct

+ func NewService(r *Repository) *Service

+ func (s *Service) GatherMetrics() (*Metrics, error)