service

type AggregatedQuery struct {
	SQL         string  `json:"sql"`
	Table       string  `json:"table"`
	Operation   string  `json:"operation"`
	DBType      string  `json:"db_type"`
	Source      string  `json:"source"`
	Endpoint    string  `json:"endpoint"`
	Count       int     `json:"count"`
	TotalMS     float64 `json:"total_ms"`
	AvgMS       float64 `json:"avg_ms"`
	MinMS       float64 `json:"min_ms"`
	MaxMS       float64 `json:"max_ms"`
	TotalRows   int64   `json:"total_rows"`
	MaxRows     int64   `json:"max_rows"`
	MaxRespSize int     `json:"max_response_size"`
	LastError   string  `json:"last_error,omitempty"`
	Caller      string  `json:"caller"`
	LastSeenAt  string  `json:"last_seen_at"`
}

type AuditLogEntry struct {
	EntityType  string    `json:"entity_type"`
	EntityID    string    `json:"entity_id"`
	EntityName  string    `json:"entity_name"`
	CreatedAt   time.Time `json:"created_at"`
	OrgID       *string   `json:"org_id"`
	OrgName     *string   `json:"org_name"`
	AppID       *string   `json:"app_id"`
	AppName     *string   `json:"app_name"`
	Description *string   `json:"description"`
}

type CatalogQuery struct {
	ID          string `json:"id"`
	Name        string `json:"name"`
	Description string `json:"description"`
	SQL         string `json:"sql"`
	DBType      string `json:"db_type"` // "psql" or "ch"
}

type InstallUptimeEntry struct {
	InstallID   string `json:"install_id"`
	InstallName string `json:"install_name"`
	OrgID       string `json:"org_id"`
	OrgName     string `json:"org_name"`

	RunnerCreatedAt string `json:"runner_created_at,omitempty"`

	InstallProcesses []ProcessUptime `json:"install_processes"`
	MngProcesses     []ProcessUptime `json:"mng_processes"`

	InstallMetrics UptimeMetrics `json:"install_metrics"`
	MngMetrics     UptimeMetrics `json:"mng_metrics"`

	Jobs JobSummary `json:"jobs"`
}

type JobSummary struct {
	Total     int64 `json:"total"`
	Finished  int64 `json:"finished"`
	Failed    int64 `json:"failed"`
	TimedOut  int64 `json:"timed_out"`
	Cancelled int64 `json:"cancelled"`
	Other     int64 `json:"other"`
}

type LabelSearchResult = views.LabelSearchResult

type Params struct {
	fx.In
	V   *validator.Validate
	Cfg *internal.Config
	DB  *gorm.DB `name:"psql"`
	// optional because non-admin-dashboard binaries instantiate this service
	// via sharedServices but don't provide a replica.
	ReplicaDB      *gorm.DB `name:"psql-replica" optional:"true"`
	CHDB           *gorm.DB `name:"ch"`
	MW             metrics.Writer
	L              *zap.Logger
	AppsHelpers    *appshelpers.Helpers
	AcctClient     *account.Client
	AuthzClient    *authz.Client
	OrgsHelpers    *orgshelpers.Helpers
	TemporalClient temporalclient.Client
	QueueClient    *queueclient.Client
	EmitterClient  *emitterclient.Client

	TemporalCodecGzip         converter.PayloadCodec `name:"gzip"`
	TemporalCodecLargePayload converter.PayloadCodec `name:"largepayload"`
	TemporalCodecS3Payload    converter.PayloadCodec `name:"s3payload"`

	QueryCollector *querycollector.Collector
}

type ProcessUptime struct {
	ProcessID       string  `json:"process_id"`
	RunnerID        string  `json:"runner_id"`
	Type            string  `json:"type"`
	Status          string  `json:"status"`
	Version         string  `json:"version"`
	StartedAt       string  `json:"started_at,omitempty"`
	LastHeartbeat   string  `json:"last_heartbeat,omitempty"`
	UptimeMS        float64 `json:"uptime_ms"`
	UptimeStr       string  `json:"uptime_str"`
	Heartbeats      int64   `json:"heartbeats"`
	HealthChecks    int64   `json:"health_checks"`
	HealthyChecks   int64   `json:"healthy_checks"`
	UnhealthyChecks int64   `json:"unhealthy_checks"`
}

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

type SignalGraphNode struct {
	Signal       *app.QueueSignal    `json:"signal"`
	WorkflowInfo *views.WorkflowInfo `json:"workflow_info,omitempty"`
	Children     []SignalGraphNode   `json:"children,omitempty"` // awaited signals, recursively resolved
}

type UptimeMetrics struct {
	// Effective window (adjusted if runner created after window start).
	EffectiveWindowMS float64 `json:"effective_window_ms"`
	TotalUptimeMS     float64 `json:"total_uptime_ms"`
	TotalProcs        int     `json:"total_procs"`
	Restarts          int     `json:"restarts"`

	TotalHeartbeats      int64 `json:"total_heartbeats"`
	ExpectedHeartbeats   int64 `json:"expected_heartbeats"`
	TotalHealthChecks    int64 `json:"total_health_checks"`
	HealthyChecks        int64 `json:"healthy_checks"`
	UnhealthyChecks      int64 `json:"unhealthy_checks"`
	ExpectedHealthChecks int64 `json:"expected_health_checks"`
}