oapi

type Catalog struct {
	Description string    `json:"description"`
	Labels      *[]string `json:"labels"`
	Name        string    `json:"name"`
	Tables      Tables    `json:"tables"`
	Uid         string    `json:"uid"`
}

type CatalogTable struct {
	// Name the table name referenced within SQL queries
	Name string    `json:"name"`
	Ref  SourceRef `json:"ref"`

	// Schema the table schema referenced within SQL queries
	Schema string `json:"schema"`
}

type Catalogs = []Catalog

type ChiServerOptions struct {
	BaseURL          string
	BaseRouter       chi.Router
	Middlewares      []MiddlewareFunc
	ErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)
}

type Client struct {
	// The endpoint of the server conforming to this interface, with scheme,
	// https://api.deepmap.com for example. This can contain a path relative
	// to the server, such as https://api.deepmap.com/dev-test, and all the
	// paths in the swagger spec will be appended to the server.
	Server string

	// Doer for performing requests, typically a *http.Client with any
	// customized settings, such as certificate chains.
	Client HttpRequestDoer

	// A list of callbacks for modifying requests which are generated before sending over
	// the network.
	RequestEditors []RequestEditorFn
}

type ClientInterface interface {
	// GetConnectors request
	GetConnectors(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// SetCatalogWithBody request with any body
	SetCatalogWithBody(ctx context.Context, namespace string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	SetCatalog(ctx context.Context, namespace string, body SetCatalogJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteCatalog request
	DeleteCatalog(ctx context.Context, namespace string, catalog string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetCatalog request
	GetCatalog(ctx context.Context, namespace string, catalog string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// UpdateCatalogWithBody request with any body
	UpdateCatalogWithBody(ctx context.Context, namespace string, catalog string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	UpdateCatalog(ctx context.Context, namespace string, catalog string, body UpdateCatalogJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetCatalogs request
	GetCatalogs(ctx context.Context, namespace string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// NewConnectorWithBody request with any body
	NewConnectorWithBody(ctx context.Context, namespace string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	NewConnector(ctx context.Context, namespace string, body NewConnectorJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteKey request
	DeleteKey(ctx context.Context, namespace string, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetKeys request
	GetKeys(ctx context.Context, namespace string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// NewKeyWithBody request with any body
	NewKeyWithBody(ctx context.Context, namespace string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	NewKey(ctx context.Context, namespace string, body NewKeyJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// Query request
	Query(ctx context.Context, namespace string, params *QueryParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// NewSourceWithBody request with any body
	NewSourceWithBody(ctx context.Context, namespace string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	NewSource(ctx context.Context, namespace string, body NewSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// TestSourceConnectionWithBody request with any body
	TestSourceConnectionWithBody(ctx context.Context, namespace string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	TestSourceConnection(ctx context.Context, namespace string, body TestSourceConnectionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteSource request
	DeleteSource(ctx context.Context, namespace string, source string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetSource request
	GetSource(ctx context.Context, namespace string, source string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// FetchSource request
	FetchSource(ctx context.Context, namespace string, source string, params *FetchSourceParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetSourceOptions request
	GetSourceOptions(ctx context.Context, namespace string, source string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetSources request
	GetSources(ctx context.Context, namespace string, reqEditors ...RequestEditorFn) (*http.Response, error)
}

type ClientOption func(*Client) error

type ClientWithResponses struct {
	ClientInterface
}

type ClientWithResponsesInterface interface {
	// GetConnectorsWithResponse request
	GetConnectorsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetConnectorsResponse, error)

	// SetCatalogWithBodyWithResponse request with any body
	SetCatalogWithBodyWithResponse(ctx context.Context, namespace string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SetCatalogResponse, error)

	SetCatalogWithResponse(ctx context.Context, namespace string, body SetCatalogJSONRequestBody, reqEditors ...RequestEditorFn) (*SetCatalogResponse, error)

	// DeleteCatalogWithResponse request
	DeleteCatalogWithResponse(ctx context.Context, namespace string, catalog string, reqEditors ...RequestEditorFn) (*DeleteCatalogResponse, error)

	// GetCatalogWithResponse request
	GetCatalogWithResponse(ctx context.Context, namespace string, catalog string, reqEditors ...RequestEditorFn) (*GetCatalogResponse, error)

	// UpdateCatalogWithBodyWithResponse request with any body
	UpdateCatalogWithBodyWithResponse(ctx context.Context, namespace string, catalog string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateCatalogResponse, error)

	UpdateCatalogWithResponse(ctx context.Context, namespace string, catalog string, body UpdateCatalogJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateCatalogResponse, error)

	// GetCatalogsWithResponse request
	GetCatalogsWithResponse(ctx context.Context, namespace string, reqEditors ...RequestEditorFn) (*GetCatalogsResponse, error)

	// NewConnectorWithBodyWithResponse request with any body
	NewConnectorWithBodyWithResponse(ctx context.Context, namespace string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*NewConnectorResponse, error)

	NewConnectorWithResponse(ctx context.Context, namespace string, body NewConnectorJSONRequestBody, reqEditors ...RequestEditorFn) (*NewConnectorResponse, error)

	// DeleteKeyWithResponse request
	DeleteKeyWithResponse(ctx context.Context, namespace string, id string, reqEditors ...RequestEditorFn) (*DeleteKeyResponse, error)

	// GetKeysWithResponse request
	GetKeysWithResponse(ctx context.Context, namespace string, reqEditors ...RequestEditorFn) (*GetKeysResponse, error)

	// NewKeyWithBodyWithResponse request with any body
	NewKeyWithBodyWithResponse(ctx context.Context, namespace string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*NewKeyResponse, error)

	NewKeyWithResponse(ctx context.Context, namespace string, body NewKeyJSONRequestBody, reqEditors ...RequestEditorFn) (*NewKeyResponse, error)

	// QueryWithResponse request
	QueryWithResponse(ctx context.Context, namespace string, params *QueryParams, reqEditors ...RequestEditorFn) (*QueryResponse, error)

	// NewSourceWithBodyWithResponse request with any body
	NewSourceWithBodyWithResponse(ctx context.Context, namespace string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*NewSourceResponse, error)

	NewSourceWithResponse(ctx context.Context, namespace string, body NewSourceJSONRequestBody, reqEditors ...RequestEditorFn) (*NewSourceResponse, error)

	// TestSourceConnectionWithBodyWithResponse request with any body
	TestSourceConnectionWithBodyWithResponse(ctx context.Context, namespace string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*TestSourceConnectionResponse, error)

	TestSourceConnectionWithResponse(ctx context.Context, namespace string, body TestSourceConnectionJSONRequestBody, reqEditors ...RequestEditorFn) (*TestSourceConnectionResponse, error)

	// DeleteSourceWithResponse request
	DeleteSourceWithResponse(ctx context.Context, namespace string, source string, reqEditors ...RequestEditorFn) (*DeleteSourceResponse, error)

	// GetSourceWithResponse request
	GetSourceWithResponse(ctx context.Context, namespace string, source string, reqEditors ...RequestEditorFn) (*GetSourceResponse, error)

	// FetchSourceWithResponse request
	FetchSourceWithResponse(ctx context.Context, namespace string, source string, params *FetchSourceParams, reqEditors ...RequestEditorFn) (*FetchSourceResponse, error)

	// GetSourceOptionsWithResponse request
	GetSourceOptionsWithResponse(ctx context.Context, namespace string, source string, reqEditors ...RequestEditorFn) (*GetSourceOptionsResponse, error)

	// GetSourcesWithResponse request
	GetSourcesWithResponse(ctx context.Context, namespace string, reqEditors ...RequestEditorFn) (*GetSourcesResponse, error)
}

type Column struct {
	Name     string `json:"name"`
	Nullable bool   `json:"nullable"`
	Type     string `json:"type"`
}

type Connector struct {
	Description string              `json:"description"`
	Id          string              `json:"id"`
	Name        string              `json:"name"`
	Options     [][]ConnectorOption `json:"options"`
}

type ConnectorOption struct {
	Default     string              `json:"default"`
	Description string              `json:"description"`
	Key         string              `json:"key"`
	Name        string              `json:"name"`
	Placeholder string              `json:"placeholder"`
	Required    bool                `json:"required"`
	Type        ConnectorOptionType `json:"type"`
}

type ConnectorOptionType string

type Connectors = []Connector

type CustomConnector struct {
	Description string `json:"description"`
	Name        string `json:"name"`
}

type DeleteCatalogResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON401      *Problem
}

type DeleteKeyResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON401      *Problem
}

type DeleteSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON401      *Problem
}

type Empty = string

type Explain struct {
	// Execution response time in ms
	Execution int `json:"execution"`

	// Planning response time in ms
	Planning int `json:"planning"`
}

type FetchSourceParams struct {
	// ExposeGlobal Update the globally exposed tables from the given source
	ExposeGlobal bool `form:"expose_global" json:"expose_global"`
}

type FetchSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Source
	JSON401      *Problem
}

type GetCatalogResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Catalog
	JSON401      *Problem
}

type GetCatalogsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Catalogs
	JSON401      *Problem
}

type GetConnectorsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Connectors
	JSON401      *Problem
}

type GetKeysResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Keys
	JSON401      *Problem
}

type GetSourceOptionsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *SourceOptions
	JSON401      *Problem
}

type GetSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Source
	JSON401      *Problem
	JSON404      *Problem
}

type GetSourcesResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Sources
	JSON401      *Problem
}

type HttpRequestDoer interface {
	Do(req *http.Request) (*http.Response, error)
}

type InvalidParamFormatError struct {
	ParamName string
	Err       error
}

type Key struct {
	CreatedAt time.Time          `json:"created_at"`
	CreatedBy openapi_types.UUID `json:"created_by"`

	// Description Human-readable description
	Description string `json:"description"`

	// ExpiresAt Optional expiration timestamp
	ExpiresAt *time.Time `json:"expires_at"`

	// Id Unique identifier of the key
	Id       string   `json:"id"`
	Policies []Policy `json:"policies"`

	// Secret The API secret (only returned at creation time)
	Secret *string `json:"secret,omitempty"`
}

type Keys = []Key

type MiddlewareFunc func(http.Handler) http.Handler

type NewConnectorJSONRequestBody = CustomConnector

type NewConnectorResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *Source
	JSON401      *Problem
}

type NewKeyJSONRequestBody = Key

type NewKeyResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *Key
	JSON401      *Problem
}

type NewSource struct {
	// Connector represents the connector name used to connect with the given source
	Connector    string        `json:"connector"`
	Description  string        `json:"description"`
	ExposeGlobal bool          `json:"expose_global"`
	Labels       []string      `json:"labels"`
	Name         string        `json:"name"`
	Options      SourceOptions `json:"options"`
}

type NewSourceJSONRequestBody = NewSource

type NewSourceResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *Source
	JSON401      *Problem
}

type Policy struct {
	Permissions []string `json:"permissions"`
	Resources   []string `json:"resources"`
}

type Problem struct {
	// Detail A human readable explanation specific to this occurrence of the problem that is helpful to locate the problem and give advice on how to proceed. Written in English and readable for engineers, usually not suited for non technical stakeholders and not localized.
	Detail string `json:"detail"`

	// Title A short summary of the problem type. Written in English and readable for engineers, usually not suited for non technical stakeholders and not localized.
	Title string `json:"title"`
}

type QueryParams struct {
	// Statements SQL query statements to be executed
	Statements string `form:"statements" json:"statements"`

	// Catalog Currently selected catalog
	Catalog string `form:"catalog" json:"catalog"`

	// Limit The total amount of rows to be returned
	Limit *QueryParamsLimit `form:"limit,omitempty" json:"limit,omitempty"`

	// Stream If true, the server will stream results using Server-Sent Events.
	Stream *bool `form:"stream,omitempty" json:"stream,omitempty"`
}

type QueryParamsLimit float32

type QueryResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Rows
	JSON400      *Problem
	JSON401      *Problem
}

type RequestEditorFn func(ctx context.Context, req *http.Request) error

type RequiredHeaderError struct {
	ParamName string
	Err       error
}

type RequiredParamError struct {
	ParamName string
}

type Rows struct {
	Columns []Column `json:"columns"`

	// Explain explain the executed query
	Explain Explain    `json:"explain"`
	Rows    [][]string `json:"rows"`
	Scope   []Scope    `json:"scope"`
}

type Scope struct {
	Source ScopeRef   `json:"source"`
	Table  ScopeTable `json:"table"`
}

type ScopeRef struct {
	Connector string `json:"connector"`
	Name      string `json:"name"`
	Schema    string `json:"schema"`
	Table     string `json:"table"`
}

type ScopeTable struct {
	Name   string `json:"name"`
	Schema string `json:"schema"`
}

type ServerInterface interface {
	// Fetch all available connectors
	// (GET /v1/connectors)
	GetConnectors(w http.ResponseWriter, r *http.Request)
	// Set a new catalog
	// (POST /v1/namespace/{namespace}/catalog)
	SetCatalog(w http.ResponseWriter, r *http.Request, namespace string)
	// Delete a single catalog
	// (DELETE /v1/namespace/{namespace}/catalog/{catalog})
	DeleteCatalog(w http.ResponseWriter, r *http.Request, namespace string, catalog string)
	// Fetch all data sets within the given catalog
	// (GET /v1/namespace/{namespace}/catalog/{catalog})
	GetCatalog(w http.ResponseWriter, r *http.Request, namespace string, catalog string)
	// Add a table to a catalog
	// (PUT /v1/namespace/{namespace}/catalog/{catalog})
	UpdateCatalog(w http.ResponseWriter, r *http.Request, namespace string, catalog string)
	// Fetch all data catalogs
	// (GET /v1/namespace/{namespace}/catalogs)
	GetCatalogs(w http.ResponseWriter, r *http.Request, namespace string)
	// Register a new connector
	// (POST /v1/namespace/{namespace}/connectors)
	NewConnector(w http.ResponseWriter, r *http.Request, namespace string)
	// Revoke the given key
	// (DELETE /v1/namespace/{namespace}/key/{id}/revoke)
	DeleteKey(w http.ResponseWriter, r *http.Request, namespace string, id string)
	// Fetch all API keys
	// (GET /v1/namespace/{namespace}/keys)
	GetKeys(w http.ResponseWriter, r *http.Request, namespace string)
	// Register a new API key
	// (POST /v1/namespace/{namespace}/keys)
	NewKey(w http.ResponseWriter, r *http.Request, namespace string)
	// Interact with the data catalogs through SQL
	// (GET /v1/namespace/{namespace}/query)
	Query(w http.ResponseWriter, r *http.Request, namespace string, params QueryParams)
	// Create a new source
	// (POST /v1/namespace/{namespace}/source)
	NewSource(w http.ResponseWriter, r *http.Request, namespace string)
	// Test the source connection
	// (POST /v1/namespace/{namespace}/source/test_connection)
	TestSourceConnection(w http.ResponseWriter, r *http.Request, namespace string)
	// Delete a single catalog source
	// (DELETE /v1/namespace/{namespace}/source/{source})
	DeleteSource(w http.ResponseWriter, r *http.Request, namespace string, source string)
	// Fetch the source details within the given catalog
	// (GET /v1/namespace/{namespace}/source/{source})
	GetSource(w http.ResponseWriter, r *http.Request, namespace string, source string)
	// Fetch the latest source tables and schemas
	// (GET /v1/namespace/{namespace}/source/{source}/fetch)
	FetchSource(w http.ResponseWriter, r *http.Request, namespace string, source string, params FetchSourceParams)
	// Fetch the source options within the given catalog
	// (GET /v1/namespace/{namespace}/source/{source}/options)
	GetSourceOptions(w http.ResponseWriter, r *http.Request, namespace string, source string)
	// Fetch all sources
	// (GET /v1/namespace/{namespace}/sources)
	GetSources(w http.ResponseWriter, r *http.Request, namespace string)
}

type ServerInterfaceWrapper struct {
	Handler            ServerInterface
	HandlerMiddlewares []MiddlewareFunc
	ErrorHandlerFunc   func(w http.ResponseWriter, r *http.Request, err error)
}

type SetCatalog struct {
	Description string   `json:"description"`
	Labels      []string `json:"labels"`

	// Name the catalog name referenced within SQL queries
	Name   string         `json:"name"`
	Tables []CatalogTable `json:"tables"`
	Uid    string         `json:"uid"`
}

type SetCatalogJSONRequestBody = SetCatalog

type SetCatalogResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *Catalog
	JSON401      *Problem
}

type Source struct {
	// Connector represents the connector name used to connect with the given source
	Connector string `json:"connector"`
	Healthy   bool   `json:"healthy"`
	Name      string `json:"name"`
	Tables    Tables `json:"tables"`
	Uid       string `json:"uid"`
}

type SourceOptions map[string]string

type SourceRef struct {
	Name  string   `json:"name"`
	Table TableRef `json:"table"`
}

type Sources = []Source

type Table struct {
	Columns    []Column `json:"columns"`
	Connector  string   `json:"connector"`
	Name       string   `json:"name"`
	Schema     string   `json:"schema"`
	Schemaless bool     `json:"schemaless"`
}

type TableRef struct {
	// Name the table name referenced within SQL queries
	Name string `json:"name"`

	// Schema the table schema referenced within SQL queries
	Schema string `json:"schema"`
}

type Tables = []Table

type TestSourceConnectionJSONRequestBody = NewSource

type TestSourceConnectionResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Empty
	JSON400      *Problem
	JSON401      *Problem
}

type TooManyValuesForParamError struct {
	ParamName string
	Count     int
}

type UnescapedCookieParamError struct {
	ParamName string
	Err       error
}

type Unimplemented struct{}

type UnmarshalingParamError struct {
	ParamName string
	Err       error
}

type UpdateCatalogJSONRequestBody = SetCatalog

type UpdateCatalogResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *Catalog
	JSON401      *Problem
}