ws

type ControlMessage struct {
	Type       string   `json:"type"`
	StreamID   string   `json:"stream_id"`
	Fields     []string `json:"fields,omitempty"`
	BatchIndex int      `json:"batch_index,omitempty"`
	NumRows    int      `json:"num_rows,omitempty"`
	Error      string   `json:"error,omitempty"`
}

type Engine = engine.Engine

type QueryRequest struct {
	Query string `json:"query"`
}

type Server struct {
	Engine         Engine
	Logger         *slog.Logger
	Telemetry      telemetry.Publisher
	OriginPatterns []string
}