querycheck

type AddQueryRequest struct {
	Name       string `json:"name"`
	Query      string `json:"query"`
	CheckEvery int64  `json:"check_every_ms"`
}

type JIT struct {
	Functions int     `json:"Functions"`
	Options   Options `json:"Options"`
	Timing    Timing  `json:"Timing"`
}

type Options struct {
	Inlining     bool `json:"Inlining"`
	Optimization bool `json:"Optimization"`
	Expressions  bool `json:"Expressions"`
	Deforming    bool `json:"Deforming"`
}

type Plan struct {
	NodeType            string   `json:"Node Type"`
	ParallelAware       bool     `json:"Parallel Aware"`
	AsyncCapable        bool     `json:"Async Capable"`
	StartupCost         float64  `json:"Startup Cost"`
	TotalCost           float64  `json:"Total Cost"`
	PlanRows            int      `json:"Plan Rows"`
	PlanWidth           int      `json:"Plan Width"`
	ActualStartupTime   float64  `json:"Actual Startup Time"`
	ActualTotalTime     float64  `json:"Actual Total Time"`
	ActualRows          int      `json:"Actual Rows"`
	ActualLoops         int      `json:"Actual Loops"`
	Output              []string `json:"Output"`
	SharedHitBlocks     int      `json:"Shared Hit Blocks"`
	SharedReadBlocks    int      `json:"Shared Read Blocks"`
	SharedDirtiedBlocks int      `json:"Shared Dirtied Blocks"`
	SharedWrittenBlocks int      `json:"Shared Written Blocks"`
	LocalHitBlocks      int      `json:"Local Hit Blocks"`
	LocalReadBlocks     int      `json:"Local Read Blocks"`
	LocalDirtiedBlocks  int      `json:"Local Dirtied Blocks"`
	LocalWrittenBlocks  int      `json:"Local Written Blocks"`
	TempReadBlocks      int      `json:"Temp Read Blocks"`
	TempWrittenBlocks   int      `json:"Temp Written Blocks"`
	IOReadTime          float64  `json:"I/O Read Time"`
	IOWriteTime         float64  `json:"I/O Write Time"`
	Plans               []Plan   `json:"Plans,omitempty"`
	ParentRelationship  string   `json:"Parent Relationship,omitempty"`
	SortKey             []string `json:"Sort Key,omitempty"`
	SortMethod          string   `json:"Sort Method,omitempty"`
	SortSpaceUsed       int      `json:"Sort Space Used,omitempty"`
	SortSpaceType       string   `json:"Sort Space Type,omitempty"`
	WorkersPlanned      int      `json:"Workers Planned,omitempty"`
	WorkersLaunched     int      `json:"Workers Launched,omitempty"`
	SingleCopy          bool     `json:"Single Copy,omitempty"`
	RelationName        string   `json:"Relation Name,omitempty"`
	Schema              string   `json:"Schema,omitempty"`
	Alias               string   `json:"Alias,omitempty"`
	Filter              string   `json:"Filter,omitempty"`
	RowsRemovedByFilter int      `json:"Rows Removed by Filter,omitempty"`
	Workers             []Worker `json:"Workers,omitempty"`
}

type Planning struct {
	SharedHitBlocks     int     `json:"Shared Hit Blocks"`
	SharedReadBlocks    int     `json:"Shared Read Blocks"`
	SharedDirtiedBlocks int     `json:"Shared Dirtied Blocks"`
	SharedWrittenBlocks int     `json:"Shared Written Blocks"`
	LocalHitBlocks      int     `json:"Local Hit Blocks"`
	LocalReadBlocks     int     `json:"Local Read Blocks"`
	LocalDirtiedBlocks  int     `json:"Local Dirtied Blocks"`
	LocalWrittenBlocks  int     `json:"Local Written Blocks"`
	TempReadBlocks      int     `json:"Temp Read Blocks"`
	TempWrittenBlocks   int     `json:"Temp Written Blocks"`
	IOReadTime          float64 `json:"I/O Read Time"`
	IOWriteTime         float64 `json:"I/O Write Time"`
}

type Query struct {
	Name         string
	Query        string
	LatestPlan   *QueryPlan
	PreviousPlan *QueryPlan
	LastChecked  time.Time
	LastError    error
	CheckEvery   time.Duration
	// contains filtered or unexported fields
}

type QueryPlan struct {
	Plan            Plan     `json:"Plan"`
	QueryIdentifier int64    `json:"Query Identifier"`
	Planning        Planning `json:"Planning"`
	PlanningTime    float64  `json:"Planning Time"`
	Triggers        []string `json:"Triggers"`
	JIT             JIT      `json:"JIT"`
	ExecutionTime   float64  `json:"Execution Time"`
}

type QueryPlans []QueryPlan

type Querychecker struct {
	Queries []*Query
	Logger  *slog.Logger
	// contains filtered or unexported fields
}

type RetQuery struct {
	Name         string     `json:"name"`
	Query        string     `json:"query"`
	LatestPlan   *QueryPlan `json:"latest_plan"`
	PreviousPlan *QueryPlan `json:"previous_plan"`
	LastChecked  time.Time  `json:"last_checked"`
	LastError    error      `json:"last_error"`
	CheckEvery   string     `json:"check_every"`
}

type Timing struct {
	Generation   float64 `json:"Generation"`
	Inlining     float64 `json:"Inlining"`
	Optimization float64 `json:"Optimization"`
	Emission     float64 `json:"Emission"`
	Total        float64 `json:"Total"`
}

type UpdateQueryRequest struct {
	Query      string `json:"query"`
	CheckEvery int64  `json:"check_every_ms"`
}

type Worker struct {
	WorkerNumber        int     `json:"Worker Number"`
	ActualStartupTime   float64 `json:"Actual Startup Time"`
	ActualTotalTime     float64 `json:"Actual Total Time"`
	ActualRows          int     `json:"Actual Rows"`
	ActualLoops         int     `json:"Actual Loops"`
	JIT                 JIT     `json:"JIT"`
	SharedHitBlocks     int     `json:"Shared Hit Blocks"`
	SharedReadBlocks    int     `json:"Shared Read Blocks"`
	SharedDirtiedBlocks int     `json:"Shared Dirtied Blocks"`
	SharedWrittenBlocks int     `json:"Shared Written Blocks"`
	LocalHitBlocks      int     `json:"Local Hit Blocks"`
	LocalReadBlocks     int     `json:"Local Read Blocks"`
	LocalDirtiedBlocks  int     `json:"Local Dirtied Blocks"`
	LocalWrittenBlocks  int     `json:"Local Written Blocks"`
	TempReadBlocks      int     `json:"Temp Read Blocks"`
	TempWrittenBlocks   int     `json:"Temp Written Blocks"`
	IOReadTime          float64 `json:"I/O Read Time"`
	IOWriteTime         float64 `json:"I/O Write Time"`
}