v1

package
v0.0.0-...-9d44915 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 11, 2023 License: MPL-2.0 Imports: 27 Imported by: 0

Documentation

Overview

Code generated by ogen, DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WithServerURL 

func WithServerURL(ctx context.Context, u *url.URL) context.Context

WithServerURL sets context key to override server URL.

Types

type Catalog 

type Catalog struct {
	ID          uint64   `json:"id"`
	Name        string   `json:"name"`
	Description string   `json:"description"`
	Labels      []string `json:"labels"`
	Tables      Tables   `json:"tables"`
}

Ref: #/components/schemas/Catalog

func (*Catalog) Decode 

func (s *Catalog) Decode(d *jx.Decoder) error

Decode decodes Catalog from json.

func (*Catalog) Encode 

func (s *Catalog) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*Catalog) GetDescription 

func (s *Catalog) GetDescription() string

GetDescription returns the value of Description.

func (*Catalog) GetID 

func (s *Catalog) GetID() uint64

GetID returns the value of ID.

func (*Catalog) GetLabels 

func (s *Catalog) GetLabels() []string

GetLabels returns the value of Labels.

func (*Catalog) GetName 

func (s *Catalog) GetName() string

GetName returns the value of Name.

func (*Catalog) GetTables 

func (s *Catalog) GetTables() Tables

GetTables returns the value of Tables.

func (*Catalog) MarshalJSON 

func (s *Catalog) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Catalog) SetDescription 

func (s *Catalog) SetDescription(val string)

SetDescription sets the value of Description.

func (*Catalog) SetID 

func (s *Catalog) SetID(val uint64)

SetID sets the value of ID.

func (*Catalog) SetLabels 

func (s *Catalog) SetLabels(val []string)

SetLabels sets the value of Labels.

func (*Catalog) SetName 

func (s *Catalog) SetName(val string)

SetName sets the value of Name.

func (*Catalog) SetTables 

func (s *Catalog) SetTables(val Tables)

SetTables sets the value of Tables.

func (*Catalog) UnmarshalJSON 

func (s *Catalog) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (*Catalog) Validate 

func (s *Catalog) Validate() error

type Catalogs 

type Catalogs []Catalog

func (*Catalogs) Decode 

func (s *Catalogs) Decode(d *jx.Decoder) error

Decode decodes Catalogs from json.

func (Catalogs) Encode 

func (s Catalogs) Encode(e *jx.Encoder)

Encode encodes Catalogs as json.

func (Catalogs) MarshalJSON 

func (s Catalogs) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Catalogs) UnmarshalJSON 

func (s *Catalogs) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (Catalogs) Validate 

func (s Catalogs) Validate() error

type Client 

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

Client implements OAS client.

func NewClient 

func NewClient(serverURL string, opts ...ClientOption) (*Client, error)

NewClient initializes new Client defined by OAS.

func (*Client) DeleteCatalog 

func (c *Client) DeleteCatalog(ctx context.Context, params DeleteCatalogParams) (DeleteCatalogRes, error)

DeleteCatalog invokes deleteCatalog operation.

Delete a single catalog.

DELETE /v1/namespace/{namespace}/catalog/{catalog}

func (*Client) DeleteNamespace 

func (c *Client) DeleteNamespace(ctx context.Context, params DeleteNamespaceParams) (DeleteNamespaceRes, error)

DeleteNamespace invokes deleteNamespace operation.

Delete a single namespace.

DELETE /v1/namespace/{namespace}

func (*Client) DeleteNamespaceServiceAccount 

func (c *Client) DeleteNamespaceServiceAccount(ctx context.Context, params DeleteNamespaceServiceAccountParams) (DeleteNamespaceServiceAccountRes, error)

DeleteNamespaceServiceAccount invokes deleteNamespaceServiceAccount operation.

Delete a single service account registered within the given namespace.

DELETE /v1/namespace/{namespace}/service_account/{service_id}

func (*Client) DeleteSource 

func (c *Client) DeleteSource(ctx context.Context, params DeleteSourceParams) (DeleteSourceRes, error)

DeleteSource invokes deleteSource operation.

Delete a single catalog source.

DELETE /v1/namespace/{namespace}/source/{source}

func (*Client) DeleteUser 

func (c *Client) DeleteUser(ctx context.Context, params DeleteUserParams) (DeleteUserRes, error)

DeleteUser invokes deleteUser operation.

Delete a single user.

DELETE /v1/user/{id}

func (*Client) FetchSource 

func (c *Client) FetchSource(ctx context.Context, params FetchSourceParams) (FetchSourceRes, error)

FetchSource invokes fetchSource operation.

Fetch the latest source tables and schemas and update the internal definitions.

GET /v1/namespace/{namespace}/source/{source}/fetch

func (*Client) GetAllNamespaces 

func (c *Client) GetAllNamespaces(ctx context.Context) (GetAllNamespacesRes, error)

GetAllNamespaces invokes getAllNamespaces operation.

Retreive all namespaces that the given user is part of.

GET /v1/namespaces

func (*Client) GetCatalog 

func (c *Client) GetCatalog(ctx context.Context, params GetCatalogParams) (GetCatalogRes, error)

GetCatalog invokes getCatalog operation.

Fetch all data sets within a given catalog.

GET /v1/namespace/{namespace}/catalog/{catalog}

func (*Client) GetCatalogs 

func (c *Client) GetCatalogs(ctx context.Context, params GetCatalogsParams) (Catalogs, error)

GetCatalogs invokes getCatalogs operation.

Fetches all configured catalogs.

GET /v1/namespace/{namespace}/catalogs

func (*Client) GetCluster 

func (c *Client) GetCluster(ctx context.Context) (GetClusterRes, error)

GetCluster invokes getCluster operation.

Get information about the current cluster.

GET /v1/cluster

func (*Client) GetNamespaceServiceAccount 

func (c *Client) GetNamespaceServiceAccount(ctx context.Context, params GetNamespaceServiceAccountParams) (GetNamespaceServiceAccountRes, error)

GetNamespaceServiceAccount invokes getNamespaceServiceAccount operation.

Get a single service account registered within the given namespace.

GET /v1/namespace/{namespace}/service_account/{service_id}

func (*Client) GetNamespaceServiceAccounts 

func (c *Client) GetNamespaceServiceAccounts(ctx context.Context, params GetNamespaceServiceAccountsParams) (GetNamespaceServiceAccountsRes, error)

GetNamespaceServiceAccounts invokes getNamespaceServiceAccounts operation.

Retreive all service accounts registered within the given namespace.

GET /v1/namespace/{namespace}/service_accounts

func (*Client) GetSource 

func (c *Client) GetSource(ctx context.Context, params GetSourceParams) (GetSourceRes, error)

GetSource invokes getSource operation.

Retreive the source details within the a given catalog matching the given source id.

GET /v1/namespace/{namespace}/source/{source}

func (*Client) GetSourceOptions 

func (c *Client) GetSourceOptions(ctx context.Context, params GetSourceOptionsParams) (GetSourceOptionsRes, error)

GetSourceOptions invokes getSourceOptions operation.

Retreive the source options within the a given catalog matching the given source id.

GET /v1/namespace/{namespace}/source/{source}/options

func (*Client) GetSources 

func (c *Client) GetSources(ctx context.Context, params GetSourcesParams) (GetSourcesRes, error)

GetSources invokes getSources operation.

Fetch all sources within a given catalog.

GET /v1/namespace/{namespace}/sources

func (*Client) GetUser 

func (c *Client) GetUser(ctx context.Context, params GetUserParams) (GetUserRes, error)

GetUser invokes getUser operation.

Get a user matching the given id.

GET /v1/user/{id}

func (*Client) NewCatalog 

func (c *Client) NewCatalog(ctx context.Context, request *UpsertCatalog, params NewCatalogParams) (NewCatalogRes, error)

NewCatalog invokes newCatalog operation.

Create a new catalog using the given parameters.

POST /v1/namespace/{namespace}/catalog

func (*Client) NewNamespace 

func (c *Client) NewNamespace(ctx context.Context, request *NewNamespace) (NewNamespaceRes, error)

NewNamespace invokes newNamespace operation.

Create a new namespace within the cluster.

POST /v1/namespace

func (*Client) NewNamespaceServiceAccount 

func (c *Client) NewNamespaceServiceAccount(ctx context.Context, request *NewServiceAccount, params NewNamespaceServiceAccountParams) (NewNamespaceServiceAccountRes, error)

NewNamespaceServiceAccount invokes newNamespaceServiceAccount operation.

Add a new service account to the given namespace.

POST /v1/namespace/{namespace}/service_account

func (*Client) NewSource 

func (c *Client) NewSource(ctx context.Context, request *NewSource, params NewSourceParams) (NewSourceRes, error)

NewSource invokes newSource operation.

Create a new catalog source using the given parameters.

POST /v1/namespace/{namespace}/source

func (*Client) NewUser 

func (c *Client) NewUser(ctx context.Context, request *NewUser) (*User, error)

NewUser invokes newUser operation.

Create a user account within the cluster.

POST /v1/user

func (*Client) Query 

func (c *Client) Query(ctx context.Context, params QueryParams) (QueryRes, error)

Query invokes query operation.

Interact with the configured underlying data catalogs using SQL.

GET /v1/namespace/{namespace}/query

func (*Client) UpdateCatalog 

func (c *Client) UpdateCatalog(ctx context.Context, request *UpsertCatalog, params UpdateCatalogParams) (UpdateCatalogRes, error)

UpdateCatalog invokes updateCatalog operation.

Attempts to add the given dataset to the given catalog.

PUT /v1/namespace/{namespace}/catalog/{catalog}

type ClientOption 

type ClientOption interface {
	// contains filtered or unexported methods
}

ClientOption is client config option.

func WithClient 

func WithClient(client ht.Client) ClientOption

WithClient specifies http client to use.

type Cluster 

type Cluster struct {
	Leader  uint64 `json:"leader"`
	Healthy bool   `json:"healthy"`
	Nodes   []Node `json:"nodes"`
}

Ref: #/components/schemas/Cluster

func (*Cluster) Decode 

func (s *Cluster) Decode(d *jx.Decoder) error

Decode decodes Cluster from json.

func (*Cluster) Encode 

func (s *Cluster) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*Cluster) GetHealthy 

func (s *Cluster) GetHealthy() bool

GetHealthy returns the value of Healthy.

func (*Cluster) GetLeader 

func (s *Cluster) GetLeader() uint64

GetLeader returns the value of Leader.

func (*Cluster) GetNodes 

func (s *Cluster) GetNodes() []Node

GetNodes returns the value of Nodes.

func (*Cluster) MarshalJSON 

func (s *Cluster) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Cluster) SetHealthy 

func (s *Cluster) SetHealthy(val bool)

SetHealthy sets the value of Healthy.

func (*Cluster) SetLeader 

func (s *Cluster) SetLeader(val uint64)

SetLeader sets the value of Leader.

func (*Cluster) SetNodes 

func (s *Cluster) SetNodes(val []Node)

SetNodes sets the value of Nodes.

func (*Cluster) UnmarshalJSON 

func (s *Cluster) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (*Cluster) Validate 

func (s *Cluster) Validate() error

type Column 

type Column struct {
	ID       uint64 `json:"id"`
	Name     string `json:"name"`
	Type     string `json:"type"`
	Cap      uint64 `json:"cap"`
	Nullable bool   `json:"nullable"`
}

Ref: #/components/schemas/Column

func (*Column) Decode 

func (s *Column) Decode(d *jx.Decoder) error

Decode decodes Column from json.

func (*Column) Encode 

func (s *Column) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*Column) GetCap 

func (s *Column) GetCap() uint64

GetCap returns the value of Cap.

func (*Column) GetID 

func (s *Column) GetID() uint64

GetID returns the value of ID.

func (*Column) GetName 

func (s *Column) GetName() string

GetName returns the value of Name.

func (*Column) GetNullable 

func (s *Column) GetNullable() bool

GetNullable returns the value of Nullable.

func (*Column) GetType 

func (s *Column) GetType() string

GetType returns the value of Type.

func (*Column) MarshalJSON 

func (s *Column) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Column) SetCap 

func (s *Column) SetCap(val uint64)

SetCap sets the value of Cap.

func (*Column) SetID 

func (s *Column) SetID(val uint64)

SetID sets the value of ID.

func (*Column) SetName 

func (s *Column) SetName(val string)

SetName sets the value of Name.

func (*Column) SetNullable 

func (s *Column) SetNullable(val bool)

SetNullable sets the value of Nullable.

func (*Column) SetType 

func (s *Column) SetType(val string)

SetType sets the value of Type.

func (*Column) UnmarshalJSON 

func (s *Column) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type DeleteCatalogOK 

type DeleteCatalogOK struct{}

DeleteCatalogOK is response for DeleteCatalog operation.

type DeleteCatalogParams 

type DeleteCatalogParams struct {
	// Unique namespace identifier.
	Namespace string
	// Unique catalog identifier.
	Catalog string
}

DeleteCatalogParams is parameters of deleteCatalog operation.

type DeleteCatalogRes 

type DeleteCatalogRes interface {
	// contains filtered or unexported methods
}

type DeleteNamespaceOK 

type DeleteNamespaceOK struct{}

DeleteNamespaceOK is response for DeleteNamespace operation.

type DeleteNamespaceParams 

type DeleteNamespaceParams struct {
	// Unique namespace identifier.
	Namespace string
}

DeleteNamespaceParams is parameters of deleteNamespace operation.

type DeleteNamespaceRes 

type DeleteNamespaceRes interface {
	// contains filtered or unexported methods
}

type DeleteNamespaceServiceAccountOK 

type DeleteNamespaceServiceAccountOK struct{}

DeleteNamespaceServiceAccountOK is response for DeleteNamespaceServiceAccount operation.

type DeleteNamespaceServiceAccountParams 

type DeleteNamespaceServiceAccountParams struct {
	// Unique namespace identifier.
	Namespace string
	// Unique service account identifier.
	ServiceID uint64
}

DeleteNamespaceServiceAccountParams is parameters of deleteNamespaceServiceAccount operation.

type DeleteNamespaceServiceAccountRes 

type DeleteNamespaceServiceAccountRes interface {
	// contains filtered or unexported methods
}

type DeleteSourceOK 

type DeleteSourceOK struct{}

DeleteSourceOK is response for DeleteSource operation.

type DeleteSourceParams 

type DeleteSourceParams struct {
	// Unique namespace identifier.
	Namespace string
	// Unique source identifier.
	Source string
}

DeleteSourceParams is parameters of deleteSource operation.

type DeleteSourceRes 

type DeleteSourceRes interface {
	// contains filtered or unexported methods
}

type DeleteUserOK 

type DeleteUserOK struct{}

DeleteUserOK is response for DeleteUser operation.

type DeleteUserParams 

type DeleteUserParams struct {
	// Unique user identifier.
	ID uint64
}

DeleteUserParams is parameters of deleteUser operation.

type DeleteUserRes 

type DeleteUserRes interface {
	// contains filtered or unexported methods
}

type ErrorHandler 

type ErrorHandler = ogenerrors.ErrorHandler

ErrorHandler is error handler.

type FetchSourceParams 

type FetchSourceParams struct {
	// Unique namespace identifier.
	Namespace string
	// Unique source identifier.
	Source string
}

FetchSourceParams is parameters of fetchSource operation.

type FetchSourceRes 

type FetchSourceRes interface {
	// contains filtered or unexported methods
}

type GetAllNamespacesRes 

type GetAllNamespacesRes interface {
	// contains filtered or unexported methods
}

type GetCatalogParams 

type GetCatalogParams struct {
	// Unique namespace identifier.
	Namespace string
	// Unique catalog identifier.
	Catalog string
}

GetCatalogParams is parameters of getCatalog operation.

type GetCatalogRes 

type GetCatalogRes interface {
	// contains filtered or unexported methods
}

type GetCatalogsParams 

type GetCatalogsParams struct {
	// Unique namespace identifier.
	Namespace string
}

GetCatalogsParams is parameters of getCatalogs operation.

type GetClusterRes 

type GetClusterRes interface {
	// contains filtered or unexported methods
}

type GetNamespaceServiceAccountParams 

type GetNamespaceServiceAccountParams struct {
	// Unique namespace identifier.
	Namespace string
	// Unique service account identifier.
	ServiceID uint64
}

GetNamespaceServiceAccountParams is parameters of getNamespaceServiceAccount operation.

type GetNamespaceServiceAccountRes 

type GetNamespaceServiceAccountRes interface {
	// contains filtered or unexported methods
}

type GetNamespaceServiceAccountsParams 

type GetNamespaceServiceAccountsParams struct {
	// Unique namespace identifier.
	Namespace string
}

GetNamespaceServiceAccountsParams is parameters of getNamespaceServiceAccounts operation.

type GetNamespaceServiceAccountsRes 

type GetNamespaceServiceAccountsRes interface {
	// contains filtered or unexported methods
}

type GetSourceNotFound 

type GetSourceNotFound Problem

func (*GetSourceNotFound) Decode 

func (s *GetSourceNotFound) Decode(d *jx.Decoder) error

Decode decodes GetSourceNotFound from json.

func (*GetSourceNotFound) Encode 

func (s *GetSourceNotFound) Encode(e *jx.Encoder)

Encode encodes GetSourceNotFound as json.

func (*GetSourceNotFound) MarshalJSON 

func (s *GetSourceNotFound) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*GetSourceNotFound) UnmarshalJSON 

func (s *GetSourceNotFound) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type GetSourceOptionsParams 

type GetSourceOptionsParams struct {
	// Unique namespace identifier.
	Namespace string
	// Unique source identifier.
	Source string
}

GetSourceOptionsParams is parameters of getSourceOptions operation.

type GetSourceOptionsRes 

type GetSourceOptionsRes interface {
	// contains filtered or unexported methods
}

type GetSourceParams 

type GetSourceParams struct {
	// Unique namespace identifier.
	Namespace string
	// Unique source identifier.
	Source string
}

GetSourceParams is parameters of getSource operation.

type GetSourceRes 

type GetSourceRes interface {
	// contains filtered or unexported methods
}

type GetSourceUnauthorized 

type GetSourceUnauthorized Problem

func (*GetSourceUnauthorized) Decode 

func (s *GetSourceUnauthorized) Decode(d *jx.Decoder) error

Decode decodes GetSourceUnauthorized from json.

func (*GetSourceUnauthorized) Encode 

func (s *GetSourceUnauthorized) Encode(e *jx.Encoder)

Encode encodes GetSourceUnauthorized as json.

func (*GetSourceUnauthorized) MarshalJSON 

func (s *GetSourceUnauthorized) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*GetSourceUnauthorized) UnmarshalJSON 

func (s *GetSourceUnauthorized) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type GetSourcesParams 

type GetSourcesParams struct {
	// Unique namespace identifier.
	Namespace string
}

GetSourcesParams is parameters of getSources operation.

type GetSourcesRes 

type GetSourcesRes interface {
	// contains filtered or unexported methods
}

type GetUserParams 

type GetUserParams struct {
	// Unique user identifier.
	ID uint64
}

GetUserParams is parameters of getUser operation.

type GetUserRes 

type GetUserRes interface {
	// contains filtered or unexported methods
}

type Handler 

type Handler interface {
	// DeleteCatalog implements deleteCatalog operation.
	//
	// Delete a single catalog.
	//
	// DELETE /v1/namespace/{namespace}/catalog/{catalog}
	DeleteCatalog(ctx context.Context, params DeleteCatalogParams) (DeleteCatalogRes, error)
	// DeleteNamespace implements deleteNamespace operation.
	//
	// Delete a single namespace.
	//
	// DELETE /v1/namespace/{namespace}
	DeleteNamespace(ctx context.Context, params DeleteNamespaceParams) (DeleteNamespaceRes, error)
	// DeleteNamespaceServiceAccount implements deleteNamespaceServiceAccount operation.
	//
	// Delete a single service account registered within the given namespace.
	//
	// DELETE /v1/namespace/{namespace}/service_account/{service_id}
	DeleteNamespaceServiceAccount(ctx context.Context, params DeleteNamespaceServiceAccountParams) (DeleteNamespaceServiceAccountRes, error)
	// DeleteSource implements deleteSource operation.
	//
	// Delete a single catalog source.
	//
	// DELETE /v1/namespace/{namespace}/source/{source}
	DeleteSource(ctx context.Context, params DeleteSourceParams) (DeleteSourceRes, error)
	// DeleteUser implements deleteUser operation.
	//
	// Delete a single user.
	//
	// DELETE /v1/user/{id}
	DeleteUser(ctx context.Context, params DeleteUserParams) (DeleteUserRes, error)
	// FetchSource implements fetchSource operation.
	//
	// Fetch the latest source tables and schemas and update the internal definitions.
	//
	// GET /v1/namespace/{namespace}/source/{source}/fetch
	FetchSource(ctx context.Context, params FetchSourceParams) (FetchSourceRes, error)
	// GetAllNamespaces implements getAllNamespaces operation.
	//
	// Retreive all namespaces that the given user is part of.
	//
	// GET /v1/namespaces
	GetAllNamespaces(ctx context.Context) (GetAllNamespacesRes, error)
	// GetCatalog implements getCatalog operation.
	//
	// Fetch all data sets within a given catalog.
	//
	// GET /v1/namespace/{namespace}/catalog/{catalog}
	GetCatalog(ctx context.Context, params GetCatalogParams) (GetCatalogRes, error)
	// GetCatalogs implements getCatalogs operation.
	//
	// Fetches all configured catalogs.
	//
	// GET /v1/namespace/{namespace}/catalogs
	GetCatalogs(ctx context.Context, params GetCatalogsParams) (Catalogs, error)
	// GetCluster implements getCluster operation.
	//
	// Get information about the current cluster.
	//
	// GET /v1/cluster
	GetCluster(ctx context.Context) (GetClusterRes, error)
	// GetNamespaceServiceAccount implements getNamespaceServiceAccount operation.
	//
	// Get a single service account registered within the given namespace.
	//
	// GET /v1/namespace/{namespace}/service_account/{service_id}
	GetNamespaceServiceAccount(ctx context.Context, params GetNamespaceServiceAccountParams) (GetNamespaceServiceAccountRes, error)
	// GetNamespaceServiceAccounts implements getNamespaceServiceAccounts operation.
	//
	// Retreive all service accounts registered within the given namespace.
	//
	// GET /v1/namespace/{namespace}/service_accounts
	GetNamespaceServiceAccounts(ctx context.Context, params GetNamespaceServiceAccountsParams) (GetNamespaceServiceAccountsRes, error)
	// GetSource implements getSource operation.
	//
	// Retreive the source details within the a given catalog matching the given source id.
	//
	// GET /v1/namespace/{namespace}/source/{source}
	GetSource(ctx context.Context, params GetSourceParams) (GetSourceRes, error)
	// GetSourceOptions implements getSourceOptions operation.
	//
	// Retreive the source options within the a given catalog matching the given source id.
	//
	// GET /v1/namespace/{namespace}/source/{source}/options
	GetSourceOptions(ctx context.Context, params GetSourceOptionsParams) (GetSourceOptionsRes, error)
	// GetSources implements getSources operation.
	//
	// Fetch all sources within a given catalog.
	//
	// GET /v1/namespace/{namespace}/sources
	GetSources(ctx context.Context, params GetSourcesParams) (GetSourcesRes, error)
	// GetUser implements getUser operation.
	//
	// Get a user matching the given id.
	//
	// GET /v1/user/{id}
	GetUser(ctx context.Context, params GetUserParams) (GetUserRes, error)
	// NewCatalog implements newCatalog operation.
	//
	// Create a new catalog using the given parameters.
	//
	// POST /v1/namespace/{namespace}/catalog
	NewCatalog(ctx context.Context, req *UpsertCatalog, params NewCatalogParams) (NewCatalogRes, error)
	// NewNamespace implements newNamespace operation.
	//
	// Create a new namespace within the cluster.
	//
	// POST /v1/namespace
	NewNamespace(ctx context.Context, req *NewNamespace) (NewNamespaceRes, error)
	// NewNamespaceServiceAccount implements newNamespaceServiceAccount operation.
	//
	// Add a new service account to the given namespace.
	//
	// POST /v1/namespace/{namespace}/service_account
	NewNamespaceServiceAccount(ctx context.Context, req *NewServiceAccount, params NewNamespaceServiceAccountParams) (NewNamespaceServiceAccountRes, error)
	// NewSource implements newSource operation.
	//
	// Create a new catalog source using the given parameters.
	//
	// POST /v1/namespace/{namespace}/source
	NewSource(ctx context.Context, req *NewSource, params NewSourceParams) (NewSourceRes, error)
	// NewUser implements newUser operation.
	//
	// Create a user account within the cluster.
	//
	// POST /v1/user
	NewUser(ctx context.Context, req *NewUser) (*User, error)
	// Query implements query operation.
	//
	// Interact with the configured underlying data catalogs using SQL.
	//
	// GET /v1/namespace/{namespace}/query
	Query(ctx context.Context, params QueryParams) (QueryRes, error)
	// UpdateCatalog implements updateCatalog operation.
	//
	// Attempts to add the given dataset to the given catalog.
	//
	// PUT /v1/namespace/{namespace}/catalog/{catalog}
	UpdateCatalog(ctx context.Context, req *UpsertCatalog, params UpdateCatalogParams) (UpdateCatalogRes, error)
}

Handler handles operations described by OpenAPI v3 specification.

type Middleware 

type Middleware = middleware.Middleware

Middleware is middleware type.

type Namespace 

type Namespace struct {
	Name string `json:"name"`
}

Ref: #/components/schemas/Namespace

func (*Namespace) Decode 

func (s *Namespace) Decode(d *jx.Decoder) error

Decode decodes Namespace from json.

func (*Namespace) Encode 

func (s *Namespace) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*Namespace) GetName 

func (s *Namespace) GetName() string

GetName returns the value of Name.

func (*Namespace) MarshalJSON 

func (s *Namespace) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Namespace) SetName 

func (s *Namespace) SetName(val string)

SetName sets the value of Name.

func (*Namespace) UnmarshalJSON 

func (s *Namespace) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type Namespaces 

type Namespaces []Namespace

func (*Namespaces) Decode 

func (s *Namespaces) Decode(d *jx.Decoder) error

Decode decodes Namespaces from json.

func (Namespaces) Encode 

func (s Namespaces) Encode(e *jx.Encoder)

Encode encodes Namespaces as json.

func (Namespaces) MarshalJSON 

func (s Namespaces) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Namespaces) UnmarshalJSON 

func (s *Namespaces) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (Namespaces) Validate 

func (s Namespaces) Validate() error

type NewCatalogParams 

type NewCatalogParams struct {
	// Unique namespace identifier.
	Namespace string
}

NewCatalogParams is parameters of newCatalog operation.

type NewCatalogRes 

type NewCatalogRes interface {
	// contains filtered or unexported methods
}

type NewNamespace 

type NewNamespace struct {
	Name string `json:"name"`
}

Ref: #/components/schemas/NewNamespace

func (*NewNamespace) Decode 

func (s *NewNamespace) Decode(d *jx.Decoder) error

Decode decodes NewNamespace from json.

func (*NewNamespace) Encode 

func (s *NewNamespace) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*NewNamespace) GetName 

func (s *NewNamespace) GetName() string

GetName returns the value of Name.

func (*NewNamespace) MarshalJSON 

func (s *NewNamespace) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*NewNamespace) SetName 

func (s *NewNamespace) SetName(val string)

SetName sets the value of Name.

func (*NewNamespace) UnmarshalJSON 

func (s *NewNamespace) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type NewNamespaceRes 

type NewNamespaceRes interface {
	// contains filtered or unexported methods
}

type NewNamespaceServiceAccountParams 

type NewNamespaceServiceAccountParams struct {
	// Unique namespace identifier.
	Namespace string
}

NewNamespaceServiceAccountParams is parameters of newNamespaceServiceAccount operation.

type NewNamespaceServiceAccountRes 

type NewNamespaceServiceAccountRes interface {
	// contains filtered or unexported methods
}

type NewServiceAccount 

type NewServiceAccount struct {
	Principal   OptString `json:"principal"`
	Name        string    `json:"name"`
	Description string    `json:"description"`
	Labels      []string  `json:"labels"`
}

Ref: #/components/schemas/NewServiceAccount

func (*NewServiceAccount) Decode 

func (s *NewServiceAccount) Decode(d *jx.Decoder) error

Decode decodes NewServiceAccount from json.

func (*NewServiceAccount) Encode 

func (s *NewServiceAccount) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*NewServiceAccount) GetDescription 

func (s *NewServiceAccount) GetDescription() string

GetDescription returns the value of Description.

func (*NewServiceAccount) GetLabels 

func (s *NewServiceAccount) GetLabels() []string

GetLabels returns the value of Labels.

func (*NewServiceAccount) GetName 

func (s *NewServiceAccount) GetName() string

GetName returns the value of Name.

func (*NewServiceAccount) GetPrincipal 

func (s *NewServiceAccount) GetPrincipal() OptString

GetPrincipal returns the value of Principal.

func (*NewServiceAccount) MarshalJSON 

func (s *NewServiceAccount) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*NewServiceAccount) SetDescription 

func (s *NewServiceAccount) SetDescription(val string)

SetDescription sets the value of Description.

func (*NewServiceAccount) SetLabels 

func (s *NewServiceAccount) SetLabels(val []string)

SetLabels sets the value of Labels.

func (*NewServiceAccount) SetName 

func (s *NewServiceAccount) SetName(val string)

SetName sets the value of Name.

func (*NewServiceAccount) SetPrincipal 

func (s *NewServiceAccount) SetPrincipal(val OptString)

SetPrincipal sets the value of Principal.

func (*NewServiceAccount) UnmarshalJSON 

func (s *NewServiceAccount) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (*NewServiceAccount) Validate 

func (s *NewServiceAccount) Validate() error

type NewSource 

type NewSource struct {
	Name string `json:"name"`
	// Represents the connector name used to connect with the given source.
	Connector string        `json:"connector"`
	Options   SourceOptions `json:"options"`
}

Ref: #/components/schemas/NewSource

func (*NewSource) Decode 

func (s *NewSource) Decode(d *jx.Decoder) error

Decode decodes NewSource from json.

func (*NewSource) Encode 

func (s *NewSource) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*NewSource) GetConnector 

func (s *NewSource) GetConnector() string

GetConnector returns the value of Connector.

func (*NewSource) GetName 

func (s *NewSource) GetName() string

GetName returns the value of Name.

func (*NewSource) GetOptions 

func (s *NewSource) GetOptions() SourceOptions

GetOptions returns the value of Options.

func (*NewSource) MarshalJSON 

func (s *NewSource) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*NewSource) SetConnector 

func (s *NewSource) SetConnector(val string)

SetConnector sets the value of Connector.

func (*NewSource) SetName 

func (s *NewSource) SetName(val string)

SetName sets the value of Name.

func (*NewSource) SetOptions 

func (s *NewSource) SetOptions(val SourceOptions)

SetOptions sets the value of Options.

func (*NewSource) UnmarshalJSON 

func (s *NewSource) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type NewSourceParams 

type NewSourceParams struct {
	// Unique namespace identifier.
	Namespace string
}

NewSourceParams is parameters of newSource operation.

type NewSourceRes 

type NewSourceRes interface {
	// contains filtered or unexported methods
}

type NewUser 

type NewUser struct {
	FullName string `json:"full_name"`
	Username string `json:"username"`
	Email    string `json:"email"`
	Password string `json:"password"`
}

Ref: #/components/schemas/NewUser

func (*NewUser) Decode 

func (s *NewUser) Decode(d *jx.Decoder) error

Decode decodes NewUser from json.

func (*NewUser) Encode 

func (s *NewUser) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*NewUser) GetEmail 

func (s *NewUser) GetEmail() string

GetEmail returns the value of Email.

func (*NewUser) GetFullName 

func (s *NewUser) GetFullName() string

GetFullName returns the value of FullName.

func (*NewUser) GetPassword 

func (s *NewUser) GetPassword() string

GetPassword returns the value of Password.

func (*NewUser) GetUsername 

func (s *NewUser) GetUsername() string

GetUsername returns the value of Username.

func (*NewUser) MarshalJSON 

func (s *NewUser) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*NewUser) SetEmail 

func (s *NewUser) SetEmail(val string)

SetEmail sets the value of Email.

func (*NewUser) SetFullName 

func (s *NewUser) SetFullName(val string)

SetFullName sets the value of FullName.

func (*NewUser) SetPassword 

func (s *NewUser) SetPassword(val string)

SetPassword sets the value of Password.

func (*NewUser) SetUsername 

func (s *NewUser) SetUsername(val string)

SetUsername sets the value of Username.

func (*NewUser) UnmarshalJSON 

func (s *NewUser) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (*NewUser) Validate 

func (s *NewUser) Validate() error

type Node 

type Node struct {
	ID      uint64 `json:"id"`
	Address string `json:"address"`
	Healthy bool   `json:"healthy"`
	Ready   bool   `json:"ready"`
}

Ref: #/components/schemas/Node

func (*Node) Decode 

func (s *Node) Decode(d *jx.Decoder) error

Decode decodes Node from json.

func (*Node) Encode 

func (s *Node) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*Node) GetAddress 

func (s *Node) GetAddress() string

GetAddress returns the value of Address.

func (*Node) GetHealthy 

func (s *Node) GetHealthy() bool

GetHealthy returns the value of Healthy.

func (*Node) GetID 

func (s *Node) GetID() uint64

GetID returns the value of ID.

func (*Node) GetReady 

func (s *Node) GetReady() bool

GetReady returns the value of Ready.

func (*Node) MarshalJSON 

func (s *Node) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Node) SetAddress 

func (s *Node) SetAddress(val string)

SetAddress sets the value of Address.

func (*Node) SetHealthy 

func (s *Node) SetHealthy(val bool)

SetHealthy sets the value of Healthy.

func (*Node) SetID 

func (s *Node) SetID(val uint64)

SetID sets the value of ID.

func (*Node) SetReady 

func (s *Node) SetReady(val bool)

SetReady sets the value of Ready.

func (*Node) UnmarshalJSON 

func (s *Node) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type OptString 

type OptString struct {
	Value string
	Set   bool
}

OptString is optional string.

func NewOptString 

func NewOptString(v string) OptString

NewOptString returns new OptString with value set to v.

func (*OptString) Decode 

func (o *OptString) Decode(d *jx.Decoder) error

Decode decodes string from json.

func (OptString) Encode 

func (o OptString) Encode(e *jx.Encoder)

Encode encodes string as json.

func (OptString) Get 

func (o OptString) Get() (v string, ok bool)

Get returns value and boolean that denotes whether value was set.

func (OptString) IsSet 

func (o OptString) IsSet() bool

IsSet returns true if OptString was set.

func (OptString) MarshalJSON 

func (s OptString) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (OptString) Or 

func (o OptString) Or(d string) string

Or returns value if set, or given parameter if does not.

func (*OptString) Reset 

func (o *OptString) Reset()

Reset unsets value.

func (*OptString) SetTo 

func (o *OptString) SetTo(v string)

SetTo sets value to v.

func (*OptString) UnmarshalJSON 

func (s *OptString) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type Option 

type Option interface {
	ServerOption
	ClientOption
}

Option is config option.

func WithMeterProvider 

func WithMeterProvider(provider metric.MeterProvider) Option

WithMeterProvider specifies a meter provider to use for creating a meter.

If none is specified, the otel.GetMeterProvider() is used.

func WithTracerProvider 

func WithTracerProvider(provider trace.TracerProvider) Option

WithTracerProvider specifies a tracer provider to use for creating a tracer.

If none is specified, the global provider is used.

type Problem 

type Problem struct {
	// 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"`
	// 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"`
}

Ref: #/components/schemas/Problem

func (*Problem) Decode 

func (s *Problem) Decode(d *jx.Decoder) error

Decode decodes Problem from json.

func (*Problem) Encode 

func (s *Problem) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*Problem) GetDetail 

func (s *Problem) GetDetail() string

GetDetail returns the value of Detail.

func (*Problem) GetTitle 

func (s *Problem) GetTitle() string

GetTitle returns the value of Title.

func (*Problem) MarshalJSON 

func (s *Problem) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Problem) SetDetail 

func (s *Problem) SetDetail(val string)

SetDetail sets the value of Detail.

func (*Problem) SetTitle 

func (s *Problem) SetTitle(val string)

SetTitle sets the value of Title.

func (*Problem) UnmarshalJSON 

func (s *Problem) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type QueryBadRequest 

type QueryBadRequest Problem

func (*QueryBadRequest) Decode 

func (s *QueryBadRequest) Decode(d *jx.Decoder) error

Decode decodes QueryBadRequest from json.

func (*QueryBadRequest) Encode 

func (s *QueryBadRequest) Encode(e *jx.Encoder)

Encode encodes QueryBadRequest as json.

func (*QueryBadRequest) MarshalJSON 

func (s *QueryBadRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*QueryBadRequest) UnmarshalJSON 

func (s *QueryBadRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type QueryParams 

type QueryParams struct {
	// Unique namespace identifier.
	Namespace string
	// SQL query statements to be executed.
	Statements string
}

QueryParams is parameters of query operation.

type QueryRes 

type QueryRes interface {
	// contains filtered or unexported methods
}

type QueryUnauthorized 

type QueryUnauthorized Problem

func (*QueryUnauthorized) Decode 

func (s *QueryUnauthorized) Decode(d *jx.Decoder) error

Decode decodes QueryUnauthorized from json.

func (*QueryUnauthorized) Encode 

func (s *QueryUnauthorized) Encode(e *jx.Encoder)

Encode encodes QueryUnauthorized as json.

func (*QueryUnauthorized) MarshalJSON 

func (s *QueryUnauthorized) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*QueryUnauthorized) UnmarshalJSON 

func (s *QueryUnauthorized) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type Route 

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

Route is route object.

func (Route) Args 

func (r Route) Args() []string

Args returns parsed arguments.

func (Route) Name 

func (r Route) Name() string

Name returns ogen operation name.

It is guaranteed to be unique and not empty.

func (Route) OperationID 

func (r Route) OperationID() string

OperationID returns OpenAPI operationId.

func (Route) PathPattern 

func (r Route) PathPattern() string

PathPattern returns OpenAPI path.

type Rows 

type Rows struct {
	Columns []Column   `json:"columns"`
	Rows    [][]jx.Raw `json:"rows"`
}

Ref: #/components/schemas/Rows

func (*Rows) Decode 

func (s *Rows) Decode(d *jx.Decoder) error

Decode decodes Rows from json.

func (*Rows) Encode 

func (s *Rows) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*Rows) GetColumns 

func (s *Rows) GetColumns() []Column

GetColumns returns the value of Columns.

func (*Rows) GetRows 

func (s *Rows) GetRows() [][]jx.Raw

GetRows returns the value of Rows.

func (*Rows) MarshalJSON 

func (s *Rows) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Rows) SetColumns 

func (s *Rows) SetColumns(val []Column)

SetColumns sets the value of Columns.

func (*Rows) SetRows 

func (s *Rows) SetRows(val [][]jx.Raw)

SetRows sets the value of Rows.

func (*Rows) UnmarshalJSON 

func (s *Rows) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (*Rows) Validate 

func (s *Rows) Validate() error

type Server 

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

Server implements http server based on OpenAPI v3 specification and calls Handler to handle requests.

func NewServer 

func NewServer(h Handler, opts ...ServerOption) (*Server, error)

NewServer creates new Server.

func (*Server) FindPath 

func (s *Server) FindPath(method string, u *url.URL) (r Route, _ bool)

FindPath finds Route for given method and URL.

func (*Server) FindRoute 

func (s *Server) FindRoute(method, path string) (Route, bool)

FindRoute finds Route for given method and path.

Note: this method does not unescape path or handle reserved characters in path properly. Use FindPath instead.

func (*Server) ServeHTTP 

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP serves http request as defined by OpenAPI v3 specification, calling handler that matches the path or returning not found error.

type ServerOption 

type ServerOption interface {
	// contains filtered or unexported methods
}

ServerOption is server config option.

func WithErrorHandler 

func WithErrorHandler(h ErrorHandler) ServerOption

WithErrorHandler specifies error handler to use.

func WithMaxMultipartMemory 

func WithMaxMultipartMemory(max int64) ServerOption

WithMaxMultipartMemory specifies limit of memory for storing file parts. File parts which can't be stored in memory will be stored on disk in temporary files.

func WithMethodNotAllowed 

func WithMethodNotAllowed(methodNotAllowed func(w http.ResponseWriter, r *http.Request, allowed string)) ServerOption

WithMethodNotAllowed specifies Method Not Allowed handler to use.

func WithMiddleware 

func WithMiddleware(m ...Middleware) ServerOption

WithMiddleware specifies middlewares to use.

func WithNotFound 

func WithNotFound(notFound http.HandlerFunc) ServerOption

WithNotFound specifies Not Found handler to use.

func WithPathPrefix 

func WithPathPrefix(prefix string) ServerOption

WithPathPrefix specifies server path prefix.

type ServiceAccount 

type ServiceAccount struct {
	Principal   string   `json:"principal"`
	Name        string   `json:"name"`
	Description string   `json:"description"`
	Labels      []string `json:"labels"`
}

Ref: #/components/schemas/ServiceAccount

func (*ServiceAccount) Decode 

func (s *ServiceAccount) Decode(d *jx.Decoder) error

Decode decodes ServiceAccount from json.

func (*ServiceAccount) Encode 

func (s *ServiceAccount) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*ServiceAccount) GetDescription 

func (s *ServiceAccount) GetDescription() string

GetDescription returns the value of Description.

func (*ServiceAccount) GetLabels 

func (s *ServiceAccount) GetLabels() []string

GetLabels returns the value of Labels.

func (*ServiceAccount) GetName 

func (s *ServiceAccount) GetName() string

GetName returns the value of Name.

func (*ServiceAccount) GetPrincipal 

func (s *ServiceAccount) GetPrincipal() string

GetPrincipal returns the value of Principal.

func (*ServiceAccount) MarshalJSON 

func (s *ServiceAccount) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*ServiceAccount) SetDescription 

func (s *ServiceAccount) SetDescription(val string)

SetDescription sets the value of Description.

func (*ServiceAccount) SetLabels 

func (s *ServiceAccount) SetLabels(val []string)

SetLabels sets the value of Labels.

func (*ServiceAccount) SetName 

func (s *ServiceAccount) SetName(val string)

SetName sets the value of Name.

func (*ServiceAccount) SetPrincipal 

func (s *ServiceAccount) SetPrincipal(val string)

SetPrincipal sets the value of Principal.

func (*ServiceAccount) UnmarshalJSON 

func (s *ServiceAccount) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (*ServiceAccount) Validate 

func (s *ServiceAccount) Validate() error

type ServiceAccounts 

type ServiceAccounts []ServiceAccount

func (*ServiceAccounts) Decode 

func (s *ServiceAccounts) Decode(d *jx.Decoder) error

Decode decodes ServiceAccounts from json.

func (ServiceAccounts) Encode 

func (s ServiceAccounts) Encode(e *jx.Encoder)

Encode encodes ServiceAccounts as json.

func (ServiceAccounts) MarshalJSON 

func (s ServiceAccounts) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*ServiceAccounts) UnmarshalJSON 

func (s *ServiceAccounts) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (ServiceAccounts) Validate 

func (s ServiceAccounts) Validate() error

type Source 

type Source struct {
	ID   uint64 `json:"id"`
	Name string `json:"name"`
	// Represents the connector name used to connect with the given source.
	Connector string `json:"connector"`
	Healthy   bool   `json:"healthy"`
	Tables    Tables `json:"tables"`
}

Ref: #/components/schemas/Source

func (*Source) Decode 

func (s *Source) Decode(d *jx.Decoder) error

Decode decodes Source from json.

func (*Source) Encode 

func (s *Source) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*Source) GetConnector 

func (s *Source) GetConnector() string

GetConnector returns the value of Connector.

func (*Source) GetHealthy 

func (s *Source) GetHealthy() bool

GetHealthy returns the value of Healthy.

func (*Source) GetID 

func (s *Source) GetID() uint64

GetID returns the value of ID.

func (*Source) GetName 

func (s *Source) GetName() string

GetName returns the value of Name.

func (*Source) GetTables 

func (s *Source) GetTables() Tables

GetTables returns the value of Tables.

func (*Source) MarshalJSON 

func (s *Source) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Source) SetConnector 

func (s *Source) SetConnector(val string)

SetConnector sets the value of Connector.

func (*Source) SetHealthy 

func (s *Source) SetHealthy(val bool)

SetHealthy sets the value of Healthy.

func (*Source) SetID 

func (s *Source) SetID(val uint64)

SetID sets the value of ID.

func (*Source) SetName 

func (s *Source) SetName(val string)

SetName sets the value of Name.

func (*Source) SetTables 

func (s *Source) SetTables(val Tables)

SetTables sets the value of Tables.

func (*Source) UnmarshalJSON 

func (s *Source) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (*Source) Validate 

func (s *Source) Validate() error

type SourceOptions 

type SourceOptions map[string]string

Ref: #/components/schemas/SourceOptions

func (*SourceOptions) Decode 

func (s *SourceOptions) Decode(d *jx.Decoder) error

Decode decodes SourceOptions from json.

func (SourceOptions) Encode 

func (s SourceOptions) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (SourceOptions) MarshalJSON 

func (s SourceOptions) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*SourceOptions) UnmarshalJSON 

func (s *SourceOptions) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type Sources 

type Sources []Source

func (*Sources) Decode 

func (s *Sources) Decode(d *jx.Decoder) error

Decode decodes Sources from json.

func (Sources) Encode 

func (s Sources) Encode(e *jx.Encoder)

Encode encodes Sources as json.

func (Sources) MarshalJSON 

func (s Sources) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Sources) UnmarshalJSON 

func (s *Sources) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (Sources) Validate 

func (s Sources) Validate() error

type Table 

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

Ref: #/components/schemas/Table

func (*Table) Decode 

func (s *Table) Decode(d *jx.Decoder) error

Decode decodes Table from json.

func (*Table) Encode 

func (s *Table) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*Table) GetColumns 

func (s *Table) GetColumns() []Column

GetColumns returns the value of Columns.

func (*Table) GetID 

func (s *Table) GetID() uint64

GetID returns the value of ID.

func (*Table) GetName 

func (s *Table) GetName() string

GetName returns the value of Name.

func (*Table) GetSchema 

func (s *Table) GetSchema() string

GetSchema returns the value of Schema.

func (*Table) GetSchemaless 

func (s *Table) GetSchemaless() bool

GetSchemaless returns the value of Schemaless.

func (*Table) MarshalJSON 

func (s *Table) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Table) SetColumns 

func (s *Table) SetColumns(val []Column)

SetColumns sets the value of Columns.

func (*Table) SetID 

func (s *Table) SetID(val uint64)

SetID sets the value of ID.

func (*Table) SetName 

func (s *Table) SetName(val string)

SetName sets the value of Name.

func (*Table) SetSchema 

func (s *Table) SetSchema(val string)

SetSchema sets the value of Schema.

func (*Table) SetSchemaless 

func (s *Table) SetSchemaless(val bool)

SetSchemaless sets the value of Schemaless.

func (*Table) UnmarshalJSON 

func (s *Table) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (*Table) Validate 

func (s *Table) Validate() error

type Tables 

type Tables []Table

func (*Tables) Decode 

func (s *Tables) Decode(d *jx.Decoder) error

Decode decodes Tables from json.

func (Tables) Encode 

func (s Tables) Encode(e *jx.Encoder)

Encode encodes Tables as json.

func (Tables) MarshalJSON 

func (s Tables) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*Tables) UnmarshalJSON 

func (s *Tables) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (Tables) Validate 

func (s Tables) Validate() error

type UnimplementedHandler 

type UnimplementedHandler struct{}

UnimplementedHandler is no-op Handler which returns http.ErrNotImplemented.

func (UnimplementedHandler) DeleteCatalog 

func (UnimplementedHandler) DeleteCatalog(ctx context.Context, params DeleteCatalogParams) (r DeleteCatalogRes, _ error)

DeleteCatalog implements deleteCatalog operation.

Delete a single catalog.

DELETE /v1/namespace/{namespace}/catalog/{catalog}

func (UnimplementedHandler) DeleteNamespace 

func (UnimplementedHandler) DeleteNamespace(ctx context.Context, params DeleteNamespaceParams) (r DeleteNamespaceRes, _ error)

DeleteNamespace implements deleteNamespace operation.

Delete a single namespace.

DELETE /v1/namespace/{namespace}

func (UnimplementedHandler) DeleteNamespaceServiceAccount 

func (UnimplementedHandler) DeleteNamespaceServiceAccount(ctx context.Context, params DeleteNamespaceServiceAccountParams) (r DeleteNamespaceServiceAccountRes, _ error)

DeleteNamespaceServiceAccount implements deleteNamespaceServiceAccount operation.

Delete a single service account registered within the given namespace.

DELETE /v1/namespace/{namespace}/service_account/{service_id}

func (UnimplementedHandler) DeleteSource 

func (UnimplementedHandler) DeleteSource(ctx context.Context, params DeleteSourceParams) (r DeleteSourceRes, _ error)

DeleteSource implements deleteSource operation.

Delete a single catalog source.

DELETE /v1/namespace/{namespace}/source/{source}

func (UnimplementedHandler) DeleteUser 

func (UnimplementedHandler) DeleteUser(ctx context.Context, params DeleteUserParams) (r DeleteUserRes, _ error)

DeleteUser implements deleteUser operation.

Delete a single user.

DELETE /v1/user/{id}

func (UnimplementedHandler) FetchSource 

func (UnimplementedHandler) FetchSource(ctx context.Context, params FetchSourceParams) (r FetchSourceRes, _ error)

FetchSource implements fetchSource operation.

Fetch the latest source tables and schemas and update the internal definitions.

GET /v1/namespace/{namespace}/source/{source}/fetch

func (UnimplementedHandler) GetAllNamespaces 

func (UnimplementedHandler) GetAllNamespaces(ctx context.Context) (r GetAllNamespacesRes, _ error)

GetAllNamespaces implements getAllNamespaces operation.

Retreive all namespaces that the given user is part of.

GET /v1/namespaces

func (UnimplementedHandler) GetCatalog 

func (UnimplementedHandler) GetCatalog(ctx context.Context, params GetCatalogParams) (r GetCatalogRes, _ error)

GetCatalog implements getCatalog operation.

Fetch all data sets within a given catalog.

GET /v1/namespace/{namespace}/catalog/{catalog}

func (UnimplementedHandler) GetCatalogs 

func (UnimplementedHandler) GetCatalogs(ctx context.Context, params GetCatalogsParams) (r Catalogs, _ error)

GetCatalogs implements getCatalogs operation.

Fetches all configured catalogs.

GET /v1/namespace/{namespace}/catalogs

func (UnimplementedHandler) GetCluster 

func (UnimplementedHandler) GetCluster(ctx context.Context) (r GetClusterRes, _ error)

GetCluster implements getCluster operation.

Get information about the current cluster.

GET /v1/cluster

func (UnimplementedHandler) GetNamespaceServiceAccount 

func (UnimplementedHandler) GetNamespaceServiceAccount(ctx context.Context, params GetNamespaceServiceAccountParams) (r GetNamespaceServiceAccountRes, _ error)

GetNamespaceServiceAccount implements getNamespaceServiceAccount operation.

Get a single service account registered within the given namespace.

GET /v1/namespace/{namespace}/service_account/{service_id}

func (UnimplementedHandler) GetNamespaceServiceAccounts 

func (UnimplementedHandler) GetNamespaceServiceAccounts(ctx context.Context, params GetNamespaceServiceAccountsParams) (r GetNamespaceServiceAccountsRes, _ error)

GetNamespaceServiceAccounts implements getNamespaceServiceAccounts operation.

Retreive all service accounts registered within the given namespace.

GET /v1/namespace/{namespace}/service_accounts

func (UnimplementedHandler) GetSource 

func (UnimplementedHandler) GetSource(ctx context.Context, params GetSourceParams) (r GetSourceRes, _ error)

GetSource implements getSource operation.

Retreive the source details within the a given catalog matching the given source id.

GET /v1/namespace/{namespace}/source/{source}

func (UnimplementedHandler) GetSourceOptions 

func (UnimplementedHandler) GetSourceOptions(ctx context.Context, params GetSourceOptionsParams) (r GetSourceOptionsRes, _ error)

GetSourceOptions implements getSourceOptions operation.

Retreive the source options within the a given catalog matching the given source id.

GET /v1/namespace/{namespace}/source/{source}/options

func (UnimplementedHandler) GetSources 

func (UnimplementedHandler) GetSources(ctx context.Context, params GetSourcesParams) (r GetSourcesRes, _ error)

GetSources implements getSources operation.

Fetch all sources within a given catalog.

GET /v1/namespace/{namespace}/sources

func (UnimplementedHandler) GetUser 

func (UnimplementedHandler) GetUser(ctx context.Context, params GetUserParams) (r GetUserRes, _ error)

GetUser implements getUser operation.

Get a user matching the given id.

GET /v1/user/{id}

func (UnimplementedHandler) NewCatalog 

func (UnimplementedHandler) NewCatalog(ctx context.Context, req *UpsertCatalog, params NewCatalogParams) (r NewCatalogRes, _ error)

NewCatalog implements newCatalog operation.

Create a new catalog using the given parameters.

POST /v1/namespace/{namespace}/catalog

func (UnimplementedHandler) NewNamespace 

func (UnimplementedHandler) NewNamespace(ctx context.Context, req *NewNamespace) (r NewNamespaceRes, _ error)

NewNamespace implements newNamespace operation.

Create a new namespace within the cluster.

POST /v1/namespace

func (UnimplementedHandler) NewNamespaceServiceAccount 

func (UnimplementedHandler) NewNamespaceServiceAccount(ctx context.Context, req *NewServiceAccount, params NewNamespaceServiceAccountParams) (r NewNamespaceServiceAccountRes, _ error)

NewNamespaceServiceAccount implements newNamespaceServiceAccount operation.

Add a new service account to the given namespace.

POST /v1/namespace/{namespace}/service_account

func (UnimplementedHandler) NewSource 

func (UnimplementedHandler) NewSource(ctx context.Context, req *NewSource, params NewSourceParams) (r NewSourceRes, _ error)

NewSource implements newSource operation.

Create a new catalog source using the given parameters.

POST /v1/namespace/{namespace}/source

func (UnimplementedHandler) NewUser 

func (UnimplementedHandler) NewUser(ctx context.Context, req *NewUser) (r *User, _ error)

NewUser implements newUser operation.

Create a user account within the cluster.

POST /v1/user

func (UnimplementedHandler) Query 

func (UnimplementedHandler) Query(ctx context.Context, params QueryParams) (r QueryRes, _ error)

Query implements query operation.

Interact with the configured underlying data catalogs using SQL.

GET /v1/namespace/{namespace}/query

func (UnimplementedHandler) UpdateCatalog 

func (UnimplementedHandler) UpdateCatalog(ctx context.Context, req *UpsertCatalog, params UpdateCatalogParams) (r UpdateCatalogRes, _ error)

UpdateCatalog implements updateCatalog operation.

Attempts to add the given dataset to the given catalog.

PUT /v1/namespace/{namespace}/catalog/{catalog}

type UpdateCatalogParams 

type UpdateCatalogParams struct {
	// Unique namespace identifier.
	Namespace string
	// Unique catalog identifier.
	Catalog string
}

UpdateCatalogParams is parameters of updateCatalog operation.

type UpdateCatalogRes 

type UpdateCatalogRes interface {
	// contains filtered or unexported methods
}

type UpsertCatalog 

type UpsertCatalog struct {
	// The catalog name referenced within SQL queries.
	Name        string        `json:"name"`
	Description string        `json:"description"`
	Labels      []string      `json:"labels"`
	Tables      []UpsertTable `json:"tables"`
}

Ref: #/components/schemas/UpsertCatalog

func (*UpsertCatalog) Decode 

func (s *UpsertCatalog) Decode(d *jx.Decoder) error

Decode decodes UpsertCatalog from json.

func (*UpsertCatalog) Encode 

func (s *UpsertCatalog) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*UpsertCatalog) GetDescription 

func (s *UpsertCatalog) GetDescription() string

GetDescription returns the value of Description.

func (*UpsertCatalog) GetLabels 

func (s *UpsertCatalog) GetLabels() []string

GetLabels returns the value of Labels.

func (*UpsertCatalog) GetName 

func (s *UpsertCatalog) GetName() string

GetName returns the value of Name.

func (*UpsertCatalog) GetTables 

func (s *UpsertCatalog) GetTables() []UpsertTable

GetTables returns the value of Tables.

func (*UpsertCatalog) MarshalJSON 

func (s *UpsertCatalog) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*UpsertCatalog) SetDescription 

func (s *UpsertCatalog) SetDescription(val string)

SetDescription sets the value of Description.

func (*UpsertCatalog) SetLabels 

func (s *UpsertCatalog) SetLabels(val []string)

SetLabels sets the value of Labels.

func (*UpsertCatalog) SetName 

func (s *UpsertCatalog) SetName(val string)

SetName sets the value of Name.

func (*UpsertCatalog) SetTables 

func (s *UpsertCatalog) SetTables(val []UpsertTable)

SetTables sets the value of Tables.

func (*UpsertCatalog) UnmarshalJSON 

func (s *UpsertCatalog) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (*UpsertCatalog) Validate 

func (s *UpsertCatalog) Validate() error

type UpsertTable 

type UpsertTable struct {
	ID uint64 `json:"id"`
	// The table name referenced within SQL queries.
	Name string `json:"name"`
	// The table schema referenced within SQL queries.
	Schema string `json:"schema"`
}

Ref: #/components/schemas/UpsertTable

func (*UpsertTable) Decode 

func (s *UpsertTable) Decode(d *jx.Decoder) error

Decode decodes UpsertTable from json.

func (*UpsertTable) Encode 

func (s *UpsertTable) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*UpsertTable) GetID 

func (s *UpsertTable) GetID() uint64

GetID returns the value of ID.

func (*UpsertTable) GetName 

func (s *UpsertTable) GetName() string

GetName returns the value of Name.

func (*UpsertTable) GetSchema 

func (s *UpsertTable) GetSchema() string

GetSchema returns the value of Schema.

func (*UpsertTable) MarshalJSON 

func (s *UpsertTable) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*UpsertTable) SetID 

func (s *UpsertTable) SetID(val uint64)

SetID sets the value of ID.

func (*UpsertTable) SetName 

func (s *UpsertTable) SetName(val string)

SetName sets the value of Name.

func (*UpsertTable) SetSchema 

func (s *UpsertTable) SetSchema(val string)

SetSchema sets the value of Schema.

func (*UpsertTable) UnmarshalJSON 

func (s *UpsertTable) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type User 

type User struct {
	ID       uint64 `json:"id"`
	Username string `json:"username"`
	FullName string `json:"full_name"`
	Email    string `json:"email"`
}

Ref: #/components/schemas/User

func (*User) Decode 

func (s *User) Decode(d *jx.Decoder) error

Decode decodes User from json.

func (*User) Encode 

func (s *User) Encode(e *jx.Encoder)

Encode implements json.Marshaler.

func (*User) GetEmail 

func (s *User) GetEmail() string

GetEmail returns the value of Email.

func (*User) GetFullName 

func (s *User) GetFullName() string

GetFullName returns the value of FullName.

func (*User) GetID 

func (s *User) GetID() uint64

GetID returns the value of ID.

func (*User) GetUsername 

func (s *User) GetUsername() string

GetUsername returns the value of Username.

func (*User) MarshalJSON 

func (s *User) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*User) SetEmail 

func (s *User) SetEmail(val string)

SetEmail sets the value of Email.

func (*User) SetFullName 

func (s *User) SetFullName(val string)

SetFullName sets the value of FullName.

func (*User) SetID 

func (s *User) SetID(val uint64)

SetID sets the value of ID.

func (*User) SetUsername 

func (s *User) SetUsername(val string)

SetUsername sets the value of Username.

func (*User) UnmarshalJSON 

func (s *User) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (*User) Validate 

func (s *User) Validate() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.