drivers

Oct 16, 2024

Changes in this version

+ type FindModelSplitsOptions struct

+ AfterIndex int

+ AfterKey string

+ Limit int

+ ModelID string

+ WhereErrored bool

+ WherePending bool

Sep 13, 2024

Changes in this version

+ const RepoListLimit

+ var ErrRepoListLimitExceeded = fmt.Errorf("glob exceeded limit of %d matched files", RepoListLimit)

type CatalogStore

+ UpdateModelSplitPending func(ctx context.Context, modelID, splitKey string) error

type Dialect

+ func (d Dialect) DateDiff(grain runtimev1.TimeGrain, t1, t2 time.Time) (string, error)

+ func (d Dialect) RequiresCastForLike() bool

Aug 8, 2024

Changes in this version

type CatalogStore

+ CheckModelSplitsHaveErrors func(ctx context.Context, modelID string) (bool, error)

+ DeleteModelSplits func(ctx context.Context, modelID string) error

+ FindModelSplits func(ctx context.Context, modelID string, afterIndex int, afterKey string, ...) ([]ModelSplit, error)

+ FindModelSplitsByKeys func(ctx context.Context, modelID string, keys []string) ([]ModelSplit, error)

+ FindModelSplitsByPending func(ctx context.Context, modelID string, limit int) ([]ModelSplit, error)

+ InsertModelSplit func(ctx context.Context, modelID string, split ModelSplit) error

+ UpdateModelSplit func(ctx context.Context, modelID string, split ModelSplit) error

+ UpdateModelSplitsPendingIfError func(ctx context.Context, modelID string) error

type Handle

+ AsWarehouse func() (Warehouse, bool)

+ type ModelExecuteOptions struct

+ Incremental bool

+ IncrementalRun bool

+ InputProperties map[string]any

+ OutputProperties map[string]any

+ PreviousResult *ModelResult

+ Priority int

+ SplitRun bool

type ModelExecutor

+ Concurrency func(desired int) (int, bool)

type ModelExecutorOptions

+ PreliminaryInputProperties map[string]any

+ PreliminaryOutputProperties map[string]any

type ModelManager

+ MergeSplitResults func(a, b *ModelResult) (*ModelResult, error)

+ type ModelSplit struct

+ DataJSON []byte

+ Elapsed time.Duration

+ Error string

+ ExecutedOn *time.Time

+ Index int

+ Key string

+ Watermark *time.Time

type ObjectStore

+ ListObjects func(ctx context.Context, props map[string]any) ([]ObjectStoreEntry, error)

+ type ObjectStoreEntry struct

+ IsDir bool

+ Path string

+ UpdatedOn time.Time

+ type ObjectStoreModelOutputProperties struct

+ Format FileFormat

+ Path string

+ type ObjectStoreModelResultProperties struct

+ Format FileFormat

+ Path string

type PropertySpec

+ NoPrompt bool

type Spec

+ ImplementsWarehouse bool

+ type Warehouse interface

+ QueryAsFiles func(ctx context.Context, props map[string]any, opt *QueryOption) (FileIterator, error)

Jul 8, 2024

Changes in this version

type Dialect

+ func (d Dialect) CanPivot() bool

+ func (d Dialect) DateTruncExpr(dim *runtimev1.MetricsViewSpec_DimensionV2, grain runtimev1.TimeGrain, ...) (string, error)

+ func (d Dialect) EscapeStringValue(s string) string

+ func (d Dialect) JoinOnExpression(lhs, rhs string) string

+ func (d Dialect) OrderByExpression(name string, desc bool) string

+ func (d Dialect) SafeDivideExpression(numExpr, denExpr string) string

+ func (d Dialect) SupportsILike() bool

+ type FileFormat string

+ const FileFormatCSV

+ const FileFormatJSON

+ const FileFormatParquet

+ const FileFormatUnspecified

+ const FileFormatXLSX

+ func (f FileFormat) Filename(stem string) string

+ func (f FileFormat) Valid() bool

type Handle

+ Ping func(ctx context.Context) error

type Instance

+ PublicPaths []string

type InstanceConfig

+ DownloadLimitBytes int64

+ MetricsApproximateComparisons bool

+ MetricsExactifyDruidTopN bool

type ModelExecutorOptions

+ Priority int

type Result

+ func (r *Result) Err() error

+ func (r *Result) Next() bool

+ func (r *Result) SetCap(n int64)

Jun 4, 2024

Changes in this version

type Dialect

+ func (d Dialect) DimensionSelectPair(db, dbSchema, table string, dim *runtimev1.MetricsViewSpec_DimensionV2) (expr, alias, unnestClause string)

+ func (d Dialect) LateralUnnest(expr, tableAlias, colName string) (tbl string, auto bool, err error)

May 21, 2024

Changes in this version

+ var ErrNoRows = errors.New("no rows found for the query")

type Handle

+ AsModelExecutor func(instanceID string, opts *ModelExecutorOptions) (ModelExecutor, bool)

+ AsModelManager func(instanceID string) (ModelManager, bool)

+ type IncrementalStrategy string

+ const IncrementalStrategyAppend

+ const IncrementalStrategyMerge

+ const IncrementalStrategyUnspecified

+ type ModelEnv struct

+ AcquireConnector func(ctx context.Context, name string) (Handle, func(), error)

+ AllowHostAccess bool

+ DefaultMaterialize bool

+ RepoRoot string

+ StageChanges bool

+ type ModelExecutor interface

+ Execute func(ctx context.Context) (*ModelResult, error)

+ type ModelExecutorOptions struct

+ Env *ModelEnv

+ Incremental bool

+ IncrementalRun bool

+ InputConnector string

+ InputHandle Handle

+ InputProperties map[string]any

+ ModelName string

+ OutputConnector string

+ OutputHandle Handle

+ OutputProperties map[string]any

+ PreviousResult *ModelResult

+ type ModelManager interface

+ Delete func(ctx context.Context, res *ModelResult) error

+ Exists func(ctx context.Context, res *ModelResult) (bool, error)

+ Rename func(ctx context.Context, res *ModelResult, newName string, env *ModelEnv) (*ModelResult, error)

+ type ModelResult struct

+ Connector string

+ Properties map[string]any

+ Table string

May 6, 2024

Changes in this version

+ func IsIgnored(path string, ignorePathsConfig []string) bool

type Dialect

+ const DialectPinot

+ func (d Dialect) DimensionSelect(db, dbSchema, table string, dim *runtimev1.MetricsViewSpec_DimensionV2) (dimSelect, unnestClause string)

+ func (d Dialect) MetricsViewDimensionExpression(dimension *runtimev1.MetricsViewSpec_DimensionV2) string

type Instance

+ FeatureFlags map[string]bool

type RepoObjectStat

+ IsDir bool

Apr 16, 2024

Changes in this version

+ var ErrNotNotifier = errors.New("driver: not a notifier")

+ type AlertStatus struct

+ EditLink string

+ ExecutionError string

+ ExecutionTime time.Time

+ FailRow map[string]any

+ IsRecover bool

+ OpenLink string

+ Status runtimev1.AssertionStatus

+ Title string

+ ToEmail string

+ ToName string

type Dialect

+ func (d Dialect) ConvertToDateTruncSpecifier(specifier runtimev1.TimeGrain) string

+ func (d Dialect) EscapeTable(db, schema, table string) string

+ type DirEntry struct

+ IsDir bool

+ Path string

type Handle

+ AsNotifier func(properties map[string]any) (Notifier, error)

type Instance

+ func (i *Instance) Config() (InstanceConfig, error)

+ type InstanceConfig struct

+ AlertsDefaultStreamingRefreshCron string

+ DownloadRowLimit int64

+ InteractiveSQLRowLimit int64

+ ModelDefaultMaterialize bool

+ ModelMaterializeDelaySeconds uint32

+ PivotCellLimit int64

+ StageChanges bool

+ type Notifier interface

+ SendAlertStatus func(s *AlertStatus) error

+ SendScheduledReport func(s *ScheduledReport) error

+ type PropertySpec struct

+ Default string

+ Description string

+ DisplayName string

+ DocsURL string

+ Hint string

+ Key string

+ Placeholder string

+ Required bool

+ Secret bool

+ Type PropertyType

+ type PropertyType int

+ const FilePropertyType

type RepoStore

+ MakeDir func(ctx context.Context, path string) error

+ type ScheduledReport struct

+ DownloadFormat string

+ DownloadLink string

+ EditLink string

+ OpenLink string

+ ReportTime time.Time

+ Title string

type Spec

+ DocsURL string

+ ImplementsAI bool

+ ImplementsAdmin bool

+ ImplementsCatalog bool

+ ImplementsFileStore bool

+ ImplementsNotifier bool

+ ImplementsOLAP bool

+ ImplementsObjectStore bool

+ ImplementsRegistry bool

+ ImplementsRepo bool

+ ImplementsSQLStore bool

type Table

+ IsDefaultDatabase bool

+ IsDefaultDatabaseSchema bool

+ UnsupportedCols map[string]string

Mar 15, 2024

Changes in this version

type Dialect

+ func (d Dialect) EscapeIdentifier(ident string) string

type Instance

+ ProjectOLAPConnector string

+ func (i *Instance) ResolveOLAPConnector() string

Feb 22, 2024

Changes in this version

+ type AIService interface

+ Complete func(ctx context.Context, msgs []*CompletionMessage) (*CompletionMessage, error)

type AdminService

+ GetAlertMetadata func(ctx context.Context, alertName string, annotations map[string]string, ...) (*AlertMetadata, error)

+ type AlertMetadata struct

+ EditURL string

+ OpenURL string

+ QueryForAttributes map[string]any

+ type CompletionMessage struct

+ Data string

+ Role string

type Dialect

+ const DialectClickHouse

type Handle

+ AsAI func(instanceID string) (AIService, bool)

type Instance

+ AIConnector string

+ Environment string

Nov 14, 2023

Changes in this version

+ type AdminService interface

+ GetReportMetadata func(ctx context.Context, reportName string, annotations map[string]string) (*ReportMetadata, error)

type Handle

+ AsAdmin func(instanceID string) (AdminService, bool)

type Instance

+ AdminConnector string

+ CatalogConnector string

+ type ReportMetadata struct

+ EditURL string

+ ExportURL string

+ OpenURL string

Oct 19, 2023

Changes in this version

+ var ErrStorageLimitExceeded = fmt.Errorf("connectors: exceeds storage limit")

type Instance

+ IgnoreInitialInvalidProjectError bool

Oct 9, 2023

Changes in this version

type OLAPStore

+ AddTableColumn func(ctx context.Context, tableName, columnName string, typ string) error

+ AlterTableColumn func(ctx context.Context, tableName, columnName string, newType string) error

+ CreateTableAsSelect func(ctx context.Context, name string, view bool, sql string) error

+ DropTable func(ctx context.Context, name string, view bool) error

+ InsertTableAsSelect func(ctx context.Context, name string, byName bool, sql string) error

+ RenameTable func(ctx context.Context, name, newName string, view bool) error

Sep 27, 2023

Changes in this version

+ var ErrNotImplemented = errors.New("driver: not implemented")

type Driver

+ TertiarySourceConnectors func(ctx context.Context, src map[string]any, logger *zap.Logger) ([]string, error)

type FileIterator

+ Format func() string

+ Next func() ([]string, error)

type Instance

+ ModelDefaultMaterialize bool

+ ModelMaterializeDelaySeconds uint32

+ StageChanges bool

+ WatchRepo bool

Sep 19, 2023

Changes in this version

+ type TransferOptions struct

+ AcquireConnector func(string) (Handle, func(), error)

+ AllowHostAccess bool

+ LimitInBytes int64

+ Progress Progress

+ RepoRoot string

Sep 14, 2023

Changes in this version

type FileIterator

+ NextBatchSize func(sizeInBytes int64) ([]string, error)

type Statement

+ LongRunning bool

type TransferOption

+ func WithIteratorBatchSizeInBytes(b int64) TransferOption

type TransferOpts

+ IteratorBatchSizeInBytes int64

Sep 7, 2023

Changes in this version

type Instance

+ OLAPConnector string

+ RepoConnector string

+ type QueryOption struct

+ TotalLimitInBytes int64

type SQLStore

+ QueryAsFiles func(ctx context.Context, props map[string]any, sql string, opt *QueryOption, ...) (FileIterator, error)

Sep 1, 2023

Changes in this version

+ var ErrInconsistentControllerVersion = errors.New("controller: inconsistent version")

+ var ErrResourceAlreadyExists = errors.New("controller: resource already exists")

+ var ErrResourceNotFound = errors.New("controller: resource not found")

type CatalogEntry

+ func (e *CatalogEntry) IsMetricsView() bool

type CatalogStore

+ CheckControllerVersion func(ctx context.Context, v int64) error

+ CreateResource func(ctx context.Context, v int64, r Resource) error

+ DeleteResource func(ctx context.Context, v int64, k, n string) error

+ DeleteResources func(ctx context.Context) error

+ FindResources func(ctx context.Context) ([]Resource, error)

+ NextControllerVersion func(ctx context.Context) (int64, error)

+ UpdateResource func(ctx context.Context, v int64, r Resource) error

+ type Resource struct

+ Data []byte

+ Kind string

+ Name string

Aug 17, 2023

Changes in this version

+ type Handle interface

+ AsCatalogStore func(instanceID string) (CatalogStore, bool)

+ AsFileStore func() (FileStore, bool)

+ AsOLAP func(instanceID string) (OLAPStore, bool)

+ AsObjectStore func() (ObjectStore, bool)

+ AsRegistry func() (RegistryStore, bool)

+ AsRepoStore func(instanceID string) (RepoStore, bool)

+ AsSQLStore func() (SQLStore, bool)

+ AsTransporter func(from Handle, to Handle) (Transporter, bool)

+ Close func() error

+ Config func() map[string]any

+ Driver func() string

+ Migrate func(ctx context.Context) error

+ MigrationStatus func(ctx context.Context) (current int, desired int, err error)

type Instance

+ Connectors []*runtimev1.Connector

+ ProjectConnectors []*runtimev1.Connector

type RepoStore

+ CommitHash func(ctx context.Context) (string, error)

type Table

+ View bool

Aug 2, 2023

Changes in this version

+ var ErrIteratorDone = errors.New("empty iterator")

type Connection

+ AsSQLStore func() (SQLStore, bool)

type DatabaseSource

+ Props map[string]any

+ SQL string

type FileIterator

+ KeepFilesUntilClose func(keepFilesUntilClose bool)

type Instance

+ Annotations map[string]string

type OLAPStore

+ WithRaw func(ctx context.Context, priority int, fn WithRawFunc) error

+ type RowIterator interface

+ Close func() error

+ Next func(ctx context.Context) ([]any, error)

+ Schema func(ctx context.Context) (*runtimev1.StructType, error)

+ Size func(unit ProgressUnit) (uint64, bool)

+ type SQLStore interface

+ Query func(ctx context.Context, props map[string]any, sql string) (RowIterator, error)

+ type WithRawFunc func(driverConn any) error

Jul 19, 2023

Changes in this version

+ var Connectors = make(map[string]Driver)

+ var ErrIngestionLimitExceeded = fmt.Errorf("connectors: source ingestion exceeds limit")

+ func NewPermissionDeniedError(msg string) error

+ func RecordDownloadMetrics(ctx context.Context, m *DownloadMetrics)

+ func RegisterAsConnector(name string, driver Driver)

+ type BucketSink struct

+ Path string

+ func (b *BucketSink) BucketSink() (*BucketSink, bool)

+ func (b *BucketSink) DatabaseSink() (*DatabaseSink, bool)

+ type BucketSource struct

+ ExtractPolicy *runtimev1.Source_ExtractPolicy

+ Properties map[string]any

+ func (b *BucketSource) BucketSource() (*BucketSource, bool)

+ func (b *BucketSource) DatabaseSource() (*DatabaseSource, bool)

+ func (b *BucketSource) FileSource() (*FileSource, bool)

type Connection

+ AsCatalogStore func() (CatalogStore, bool)

+ AsFileStore func() (FileStore, bool)

+ AsOLAP func() (OLAPStore, bool)

+ AsObjectStore func() (ObjectStore, bool)

+ AsRegistry func() (RegistryStore, bool)

+ AsRepoStore func() (RepoStore, bool)

+ AsTransporter func(from Connection, to Connection) (Transporter, bool)

+ Config func() map[string]any

+ Driver func() string

+ type DatabaseSink struct

+ Append bool

+ Table string

+ func (d *DatabaseSink) BucketSink() (*BucketSink, bool)

+ func (d *DatabaseSink) DatabaseSink() (*DatabaseSink, bool)

+ type DatabaseSource struct

+ Database string

+ Limit int

+ Query string

+ Table string

+ func (d *DatabaseSource) BucketSource() (*BucketSource, bool)

+ func (d *DatabaseSource) DatabaseSource() (*DatabaseSource, bool)

+ func (d *DatabaseSource) FileSource() (*FileSource, bool)

+ type DownloadMetrics struct

+ Connector string

+ Duration time.Duration

+ Ext string

+ Partial bool

+ Size int64

type Driver

+ HasAnonymousSourceAccess func(ctx context.Context, src Source, logger *zap.Logger) (bool, error)

+ Spec func() Spec

+ type FileIterator interface

+ Close func() error

+ HasNext func() bool

+ NextBatch func(limit int) ([]string, error)

+ Size func(unit ProgressUnit) (int64, bool)

+ type FileSource struct

+ Name string

+ Properties map[string]any

+ func (f *FileSource) BucketSource() (*BucketSource, bool)

+ func (f *FileSource) DatabaseSource() (*DatabaseSource, bool)

+ func (f *FileSource) FileSource() (*FileSource, bool)

+ type FileStore interface

+ FilePaths func(ctx context.Context, src *FileSource) ([]string, error)

+ type NoOpProgress struct

+ func (n NoOpProgress) Observe(val int64, unit ProgressUnit)

+ func (n NoOpProgress) Target(val int64, unit ProgressUnit)

+ type ObjectStore interface

+ DownloadFiles func(ctx context.Context, src *BucketSource) (FileIterator, error)

+ type PermissionDeniedError struct

+ func (e *PermissionDeniedError) Error() string

+ type Progress interface

+ Observe func(val int64, unit ProgressUnit)

+ Target func(val int64, unit ProgressUnit)

+ type ProgressUnit int

+ const ProgressUnitByte

+ const ProgressUnitFile

+ const ProgressUnitRecord

+ type PropertySchema struct

+ Default string

+ Description string

+ DisplayName string

+ Hint string

+ Href string

+ Key string

+ Placeholder string

+ Required bool

+ Secret bool

+ TransformFunc func(any interface{}) interface{}

+ Type PropertySchemaType

+ ValidateFunc func(any interface{}) error

+ func (ps PropertySchema) ValidateType(val any) bool

+ type PropertySchemaType int

+ const BooleanPropertyType

+ const InformationalPropertyType

+ const NumberPropertyType

+ const StringPropertyType

+ const UnspecifiedPropertyType

type RepoStore

+ Watch func(ctx context.Context, replay bool, callback WatchCallback) error

+ type Sink interface

+ BucketSink func() (*BucketSink, bool)

+ DatabaseSink func() (*DatabaseSink, bool)

+ type Source interface

+ BucketSource func() (*BucketSource, bool)

+ DatabaseSource func() (*DatabaseSource, bool)

+ FileSource func() (*FileSource, bool)

+ type Spec struct

+ ConfigProperties []PropertySchema

+ Description string

+ DisplayName string

+ Help string

+ ServiceAccountDocs string

+ SourceProperties []PropertySchema

+ type TransferOption func(*TransferOpts)

+ func WithIteratorBatch(b int) TransferOption

+ func WithLimitInBytes(limit int64) TransferOption

+ type TransferOpts struct

+ IteratorBatch int

+ LimitInBytes int64

+ func NewTransferOpts(opts ...TransferOption) *TransferOpts

+ type Transporter interface

+ Transfer func(ctx context.Context, source Source, sink Sink, t *TransferOpts, p Progress) error

+ type WatchCallback func(event WatchEvent) error

+ type WatchEvent struct

+ Dir bool

+ Path string

+ Type runtimev1.FileEvent

Jul 6, 2023

Changes in this version

type OLAPStore

+ EstimateSize func() (int64, bool)

Jun 6, 2023

Changes in this version

+ var ErrDropNotSupported = errors.New("driver: drop not supported")

+ func Drop(driver, dsn string, logger *zap.Logger) error

type Driver

+ Drop func(dsn string, logger *zap.Logger) error

type Statement

+ ExecutionTimeout time.Duration

Apr 24, 2023

Changes in this version

type CatalogEntry

+ BytesIngested int64

+ type IngestionSummary struct

+ BytesIngested int64

type Instance

+ IngestionLimitBytes int64

type RepoStore

+ Root func() string

Mar 16, 2023

Changes in this version

type CatalogStore

+ DeleteEntries func(ctx context.Context, instanceID string) error

type Instance

+ ProjectVariables map[string]string

+ Variables map[string]string

+ func (i *Instance) ResolveVariables() map[string]string

type OLAPStore

+ DropDB func() error

type RegistryStore

+ EditInstance func(ctx context.Context, instance *Instance) error

Mar 3, 2023

Changes in this version

type RepoStore

+ Sync func(ctx context.Context, instID string) error

Feb 23, 2023

Changes in this version

type Instance

+ Env map[string]string

+ ProjectEnv map[string]string

+ func (i *Instance) EnvironmentVariables() map[string]string

Jan 18, 2023

Changes in this version

type CatalogEntry

+ Children []string

+ Embedded bool

+ Parents []string

Jan 6, 2023

Changes in this version

type OLAPStore

+ Exec func(ctx context.Context, stmt *Statement) error

+ WithConnection func(ctx context.Context, priority int, fn WithConnectionFunc) error

type Result

+ func (r *Result) Close() error

+ func (r *Result) SetCleanupFunc(fn func() error)

+ type WithConnectionFunc func(wrappedCtx context.Context, ensuredCtx context.Context) error

Dec 14, 2022

Changes in this version

+ var ErrFileAlreadyExists = errors.New("file already exists")

+ type CatalogEntry struct

+ CreatedOn time.Time

+ Name string

+ Object proto.Message

+ Path string

+ RefreshedOn time.Time

+ Type ObjectType

+ UpdatedOn time.Time

+ func (e *CatalogEntry) GetMetricsView() *runtimev1.MetricsView

+ func (e *CatalogEntry) GetModel() *runtimev1.Model

+ func (e *CatalogEntry) GetSource() *runtimev1.Source

+ func (e *CatalogEntry) GetTable() *runtimev1.Table

type CatalogStore

+ CreateEntry func(ctx context.Context, instanceID string, entry *CatalogEntry) error

+ DeleteEntry func(ctx context.Context, instanceID string, name string) error

+ FindEntries func(ctx context.Context, instanceID string, t ObjectType) []*CatalogEntry

+ FindEntry func(ctx context.Context, instanceID string, name string) (*CatalogEntry, bool)

+ UpdateEntry func(ctx context.Context, instanceID string, entry *CatalogEntry) error

+ type Dialect int

+ const DialectDruid

+ const DialectDuckDB

+ const DialectUnspecified

+ func (d Dialect) String() string

type Instance

+ OLAPDSN string

+ OLAPDriver string

+ RepoDSN string

+ RepoDriver string

type OLAPStore

+ Dialect func() Dialect

+ type ObjectType int

+ const ObjectTypeMetricsView

+ const ObjectTypeModel

+ const ObjectTypeSource

+ const ObjectTypeTable

+ const ObjectTypeUnspecified

Nov 22, 2022

Changes in this version

type CatalogObject

+ Definition []byte

+ Managed bool

+ Path string

+ Schema *api.StructType

+ type CatalogObjectType string

+ const CatalogObjectTypeModel

+ const CatalogObjectTypeTable

+ const CatalogObjectTypeUnspecified

+ type RepoObjectStat struct

+ LastUpdated time.Time

type RepoStore

+ DSN func() string

+ Driver func() string

+ Rename func(ctx context.Context, repoID string, from string, path string) error

+ Stat func(ctx context.Context, repoID string, path string) (*RepoObjectStat, error)

+ type Result struct

+ Schema *api.StructType

type Table

+ DatabaseSchema string

Oct 28, 2022

Changes in this version

type CatalogObject

+ RefreshedOn time.Time

type RepoStore

+ PutBlob func(ctx context.Context, repoID string, path string, blob string) error

+ PutReader func(ctx context.Context, repoID string, path string, reader io.Reader) (string, error)

Oct 14, 2022

Changes in this version

+ const CatalogObjectTypeMetricsView

+ const CatalogObjectTypeSource

+ const CatalogObjectTypeUnmanagedTable

+ var Drivers = make(map[string]Driver)

+ var ErrClosed = errors.New("driver: connection is closed")

+ var ErrNotFound = errors.New("driver: not found")

+ var ErrUnsupportedConnector = errors.New("drivers: connector not supported")

+ func Register(name string, driver Driver)

+ type CatalogObject struct

+ CreatedOn time.Time

+ Name string

+ SQL string

+ Type string

+ UpdatedOn time.Time

+ type CatalogStore interface

+ CreateObject func(ctx context.Context, instanceID string, object *CatalogObject) error

+ DeleteObject func(ctx context.Context, instanceID string, name string) error

+ FindObject func(ctx context.Context, instanceID string, name string) (*CatalogObject, bool)

+ FindObjects func(ctx context.Context, instanceID string) []*CatalogObject

+ UpdateObject func(ctx context.Context, instanceID string, object *CatalogObject) error

+ type Column struct

+ Name string

+ Nullable bool

+ Type string

+ type Connection interface

+ CatalogStore func() (CatalogStore, bool)

+ Close func() error

+ Migrate func(ctx context.Context) error

+ MigrationStatus func(ctx context.Context) (current int, desired int, err error)

+ OLAPStore func() (OLAPStore, bool)

+ RegistryStore func() (RegistryStore, bool)

+ RepoStore func() (RepoStore, bool)

+ func Open(driver string, dsn string) (Connection, error)

+ type Driver interface

+ Open func(dsn string) (Connection, error)

+ type InformationSchema interface

+ All func(ctx context.Context) ([]*Table, error)

+ Lookup func(ctx context.Context, name string) (*Table, error)

+ type Instance struct

+ CreatedOn time.Time

+ DSN string

+ Driver string

+ EmbedCatalog bool

+ Exposed bool

+ ID string

+ ObjectPrefix string

+ UpdatedOn time.Time

+ type OLAPStore interface

+ Execute func(ctx context.Context, stmt *Statement) (*sqlx.Rows, error)

+ InformationSchema func() InformationSchema

+ Ingest func(ctx context.Context, source *connectors.Source) error

+ type RegistryStore interface

+ CreateInstance func(ctx context.Context, instance *Instance) error

+ CreateRepo func(ctx context.Context, repo *Repo) error

+ DeleteInstance func(ctx context.Context, id string) error

+ DeleteRepo func(ctx context.Context, id string) error

+ FindInstance func(ctx context.Context, id string) (*Instance, bool)

+ FindInstances func(ctx context.Context) []*Instance

+ FindRepo func(ctx context.Context, id string) (*Repo, bool)

+ FindRepos func(ctx context.Context) []*Repo

+ type Repo struct

+ CreatedOn time.Time

+ DSN string

+ Driver string

+ ID string

+ UpdatedOn time.Time

+ type RepoStore interface

+ Delete func(ctx context.Context, repoID string, path string) error

+ Get func(ctx context.Context, repoID string, path string) (string, error)

+ ListRecursive func(ctx context.Context, repoID string) ([]string, error)

+ Put func(ctx context.Context, repoID string, path string, blob string) error

+ type Statement struct

+ Args []any

+ DryRun bool

+ Priority int

+ Query string

+ type Table struct

+ Columns []Column

+ Database string

+ Name string

+ Schema string

+ Type string