server

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

type AsyncQueryResponse struct {
	QueryID string `json:"query_id"`
	State   string `json:"state"`
	Plan    string `json:"plan,omitempty"`
}

type Config struct {
	Addr                string
	Catalog             *catalog.Catalog
	Coordinator         *coordinator.Coordinator       // nil = local execution only
	DLQ                 *coordinator.DLQ               // nil = no DLQ (standalone mode)
	Auth                *auth.Authenticator            // nil = no authentication (static mode)
	Authz               *auth.Authorizer               // nil = no authorization (static mode)
	Policies            *auth.PolicySet                // nil = no cell-level policies (static mode)
	Provider            *auth.Provider                 // nil = use static Auth/Authz/Policies above
	Metrics             *metrics.Metrics               // nil = no metrics collection
	TLSConfig           *tls.Config                    // nil = plain HTTP
	MaxConnections      int                            // 0 = unlimited
	SlowQueryThreshold  time.Duration                  // 0 = disabled, log queries exceeding this
	ShutdownTimeout     time.Duration                  // graceful shutdown drain timeout (default 30s)
	QueryLimits         *config.QueryLimits            // global cost-based query limits (nil = unlimited)
	RoleLimits          map[string]*config.QueryLimits // per-role overrides (nil = use global)
	SortMergeJoinBytes  int64                          // local sort-merge-join gate (0 = disabled)
	LateMaterialization bool                           // view-column join output, deferred gather (default off)
}

type CreateTableColumn struct {
	Name     string `json:"name"`
	Type     string `json:"type"`
	Nullable *bool  `json:"nullable,omitempty"` // default true
}

type CreateTableRequest struct {
	Name          string              `json:"name"`
	Columns       []CreateTableColumn `json:"columns"`
	PartitionKeys []string            `json:"partition_keys,omitempty"`
}

type GRPCConfig struct {
	Addr           string
	Catalog        *catalog.Catalog
	Coord          *coordinator.Coordinator // nil = standalone
	DB             *wadjetdb.DB             // nil = distributed
	TLSConfig      *tls.Config              // nil = plain gRPC
	MaxConnections int                      // 0 = unlimited
	AuthProvider   *auth.Provider           // nil = no auth enforcement
}

type GRPCServer struct {
	wadjetv1.UnimplementedWadjetServiceServer
	// contains filtered or unexported fields
}

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

type QueryRequest struct {
	SQL string `json:"sql"`
}

type QueryResponse struct {
	QueryID string           `json:"query_id"`
	Columns []string         `json:"columns"`
	Rows    []map[string]any `json:"rows"`
	// Values is the same rows POSITIONALLY, one slice per row aligned with
	// Columns. It is sent whenever two output columns publish ONE NAME, which
	// a JSON object cannot represent: `SELECT g + 1, g + 2, g + 3` is three
	// columns called `?column?` in PostgreSQL and here (#732), and `rows`
	// carries one key for the three of them. `columns` is always the full
	// positional list; a client that needs every value reads `values` when it
	// is present (round-1 review B1).
	Values [][]any    `json:"values,omitempty"`
	Stats  QueryStats `json:"stats"`
	Error  string     `json:"error,omitempty"`
}

type QueryStats struct {
	Elapsed     string `json:"elapsed"`
	RowsScanned int64  `json:"rows_scanned"`
	Plan        string `json:"plan,omitempty"`
}

type QueryStatusResponse struct {
	QueryID   string            `json:"query_id"`
	SQL       string            `json:"sql"`
	State     string            `json:"state"`
	Stages    []StageStatusView `json:"stages,omitempty"`
	Elapsed   string            `json:"elapsed"`
	TotalRows int64             `json:"total_rows"`
	Error     string            `json:"error,omitempty"`
}

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

type StageStatusView struct {
	StageID     string `json:"stage_id"`
	Type        string `json:"type"`
	TotalTasks  int    `json:"total_tasks"`
	DoneTasks   int    `json:"done_tasks"`
	FailedTasks int    `json:"failed_tasks"`
}