redshift

func (*Connection) All ¶ added in v0.78.0

func (c *Connection) All(ctx context.Context, like string, pageSize uint32, pageToken string) ([]*drivers.OlapTable, string, error)

All implements drivers.OLAPInformationSchema.

func (*Connection) AsAI ¶

func (c *Connection) AsAI(instanceID string) (drivers.AIService, bool)

AsAI implements drivers.Handle.

func (*Connection) AsAdmin ¶

func (c *Connection) AsAdmin(instanceID string) (drivers.AdminService, bool)

AsAdmin implements drivers.Handle.

func (*Connection) AsCatalogStore ¶

func (c *Connection) AsCatalogStore(instanceID string) (drivers.CatalogStore, bool)

AsCatalogStore implements drivers.Connection.

func (*Connection) AsFileStore ¶

func (c *Connection) AsFileStore() (drivers.FileStore, bool)

func (*Connection) AsInformationSchema ¶ added in v0.78.0

func (c *Connection) AsInformationSchema() (drivers.InformationSchema, bool)

AsInformationSchema implements drivers.Connection.

func (*Connection) AsModelExecutor ¶ added in v0.45.0

func (c *Connection) AsModelExecutor(instanceID string, opts *drivers.ModelExecutorOptions) (drivers.ModelExecutor, error)

AsModelExecutor implements drivers.Handle.

func (*Connection) AsModelManager ¶ added in v0.45.0

func (c *Connection) AsModelManager(instanceID string) (drivers.ModelManager, error)

AsModelManager implements drivers.Handle.

func (*Connection) AsNotifier ¶ added in v0.43.0

func (c *Connection) AsNotifier(properties map[string]any) (drivers.Notifier, error)

AsNotifier implements drivers.Handle.

func (*Connection) AsOLAP ¶

func (c *Connection) AsOLAP(instanceID string) (drivers.OLAPStore, bool)

AsOLAP implements drivers.Connection.

func (*Connection) AsObjectStore ¶

func (c *Connection) AsObjectStore() (drivers.ObjectStore, bool)

AsObjectStore implements drivers.Connection.

func (*Connection) AsRegistry ¶

func (c *Connection) AsRegistry() (drivers.RegistryStore, bool)

AsRegistry implements drivers.Connection.

func (*Connection) AsRepoStore ¶

func (c *Connection) AsRepoStore(instanceID string) (drivers.RepoStore, bool)

AsRepoStore implements drivers.Connection.

func (*Connection) AsWarehouse ¶ added in v0.48.0

func (c *Connection) AsWarehouse() (drivers.Warehouse, bool)

AsWarehouse implements drivers.Handle.

func (*Connection) Close ¶

func (c *Connection) Close() error

Close implements drivers.Connection.

func (*Connection) Config ¶

func (c *Connection) Config() map[string]any

Config implements drivers.Connection.

func (*Connection) Dialect ¶ added in v0.78.0

func (c *Connection) Dialect() drivers.Dialect

Dialect implements drivers.OLAPStore.

func (*Connection) Driver ¶

func (c *Connection) Driver() string

Driver implements drivers.Connection.

func (*Connection) Exec ¶ added in v0.78.0

func (c *Connection) Exec(ctx context.Context, stmt *drivers.Statement) error

Exec implements drivers.OLAPStore.

func (*Connection) GetTable ¶ added in v0.78.0

func (c *Connection) GetTable(ctx context.Context, database, databaseSchema, table string) (*drivers.TableMetadata, error)

func (*Connection) InformationSchema ¶ added in v0.78.0

func (c *Connection) InformationSchema() drivers.OLAPInformationSchema

InformationSchema implements drivers.OLAPStore.

func (*Connection) ListDatabaseSchemas ¶ added in v0.78.0

func (c *Connection) ListDatabaseSchemas(ctx context.Context, pageSize uint32, pageToken string) ([]*drivers.DatabaseSchemaInfo, string, error)

func (*Connection) ListTables ¶ added in v0.78.0

func (c *Connection) ListTables(ctx context.Context, database, databaseSchema string, pageSize uint32, pageToken string) ([]*drivers.TableInfo, string, error)

func (*Connection) LoadPhysicalSize ¶ added in v0.78.0

func (c *Connection) LoadPhysicalSize(ctx context.Context, tables []*drivers.OlapTable) error

LoadPhysicalSize implements drivers.OLAPInformationSchema.

func (*Connection) Lookup ¶ added in v0.78.0

func (c *Connection) Lookup(ctx context.Context, db, schema, name string) (*drivers.OlapTable, error)

Lookup implements drivers.OLAPInformationSchema.

func (*Connection) MayBeScaledToZero ¶ added in v0.78.0

func (c *Connection) MayBeScaledToZero(ctx context.Context) bool

MayBeScaledToZero implements drivers.OLAPStore.

func (*Connection) Migrate ¶

func (c *Connection) Migrate(ctx context.Context) (err error)

Migrate implements drivers.Connection.

func (*Connection) MigrationStatus ¶

func (c *Connection) MigrationStatus(ctx context.Context) (current, desired int, err error)

MigrationStatus implements drivers.Connection.

func (*Connection) Ping ¶ added in v0.47.0

func (c *Connection) Ping(ctx context.Context) error

Ping implements drivers.Handle.

func (*Connection) Query ¶

func (c *Connection) Query(ctx context.Context, stmt *drivers.Statement) (*drivers.Result, error)

Query implements drivers.OLAPStore.

func (*Connection) QueryAsFiles ¶

func (c *Connection) QueryAsFiles(ctx context.Context, props map[string]any) (outIt drivers.FileIterator, outErr error)

func (*Connection) QuerySchema ¶ added in v0.78.0

func (c *Connection) QuerySchema(ctx context.Context, query string, args []any) (*runtimev1.StructType, error)

QuerySchema implements drivers.OLAPStore.

func (*Connection) WithConnection ¶ added in v0.78.0

func (c *Connection) WithConnection(ctx context.Context, priority int, fn drivers.WithConnectionFunc) error

WithConnection implements drivers.OLAPStore.