Documentation
¶
Index ¶
- type ConfigProperties
- type Connection
- func (c *Connection) AsAI(instanceID string) (drivers.AIService, bool)
- func (c *Connection) AsAdmin(instanceID string) (drivers.AdminService, bool)
- func (c *Connection) AsCatalogStore(instanceID string) (drivers.CatalogStore, bool)
- func (c *Connection) AsFileStore() (drivers.FileStore, bool)
- func (c *Connection) AsInformationSchema() (drivers.InformationSchema, bool)
- func (c *Connection) AsModelExecutor(instanceID string, opts *drivers.ModelExecutorOptions) (drivers.ModelExecutor, error)
- func (c *Connection) AsModelManager(instanceID string) (drivers.ModelManager, error)
- func (c *Connection) AsNotifier(properties map[string]any) (drivers.Notifier, error)
- func (c *Connection) AsOLAP(instanceID string) (drivers.OLAPStore, bool)
- func (c *Connection) AsObjectStore() (drivers.ObjectStore, bool)
- func (c *Connection) AsRegistry() (drivers.RegistryStore, bool)
- func (c *Connection) AsRepoStore(instanceID string) (drivers.RepoStore, bool)
- func (c *Connection) AsWarehouse() (drivers.Warehouse, bool)
- func (c *Connection) Close() error
- func (c *Connection) Config() map[string]any
- func (c *Connection) DownloadFiles(ctx context.Context, path string) (drivers.FileIterator, error)
- func (c *Connection) Driver() string
- func (c *Connection) ListBuckets(ctx context.Context, pageSize uint32, pageToken string) ([]string, string, error)
- func (c *Connection) ListObjects(ctx context.Context, bucket, path, delimiter string, pageSize uint32, ...) ([]drivers.ObjectStoreEntry, string, error)
- func (c *Connection) ListObjectsForGlob(ctx context.Context, bucket, glob string, pageSize uint32, ...) ([]drivers.ObjectStoreEntry, string, error)
- func (c *Connection) Migrate(ctx context.Context) (err error)
- func (c *Connection) MigrationStatus(ctx context.Context) (current, desired int, err error)
- func (c *Connection) ParsedConfig() *ConfigProperties
- func (c *Connection) Ping(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConfigProperties ¶ added in v0.56.0
type ConfigProperties struct {
Account string `mapstructure:"azure_storage_account"`
Key string `mapstructure:"azure_storage_key"`
SASToken string `mapstructure:"azure_storage_sas_token"`
ConnectionString string `mapstructure:"azure_storage_connection_string"`
// A list of container or virtual directory prefixes that this connector is allowed to access.
// Useful when different containers or paths use different credentials, allowing the system
// to route access through the appropriate connector based on the blob path.
// Example formats: `azure://my-container/` `azure://my-container/path/` `azure://my-container/path/prefix`
PathPrefixes []string `mapstructure:"path_prefixes"`
AllowHostAccess bool `mapstructure:"allow_host_access"`
}
func (*ConfigProperties) GetAccount ¶ added in v0.78.0
func (c *ConfigProperties) GetAccount() string
func (*ConfigProperties) GetConnectionString ¶ added in v0.78.0
func (c *ConfigProperties) GetConnectionString() string
func (*ConfigProperties) GetKey ¶ added in v0.78.0
func (c *ConfigProperties) GetKey() string
func (*ConfigProperties) GetSASToken ¶ added in v0.78.0
func (c *ConfigProperties) GetSASToken() string
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func (*Connection) AsAI ¶ added in v0.41.0
func (c *Connection) AsAI(instanceID string) (drivers.AIService, bool)
AsAI implements drivers.Handle.
func (*Connection) AsAdmin ¶ added in v0.37.0
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)
InformationSchema implements drivers.Handle.
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
AsNotifier implements drivers.Connection.
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) Config ¶
func (c *Connection) Config() map[string]any
Config implements drivers.Connection.
func (*Connection) DownloadFiles ¶
func (c *Connection) DownloadFiles(ctx context.Context, path string) (drivers.FileIterator, error)
DownloadFiles returns a file iterator over objects stored in azure blob storage.
func (*Connection) Driver ¶
func (c *Connection) Driver() string
Driver implements drivers.Connection.
func (*Connection) ListBuckets ¶ added in v0.78.0
func (*Connection) ListObjects ¶ added in v0.48.0
func (c *Connection) ListObjects(ctx context.Context, bucket, path, delimiter string, pageSize uint32, pageToken string) ([]drivers.ObjectStoreEntry, string, error)
ListObjects implements drivers.ObjectStore.
func (*Connection) ListObjectsForGlob ¶ added in v0.78.0
func (c *Connection) ListObjectsForGlob(ctx context.Context, bucket, glob string, pageSize uint32, pageToken, start, end string) ([]drivers.ObjectStoreEntry, string, error)
ListObjectsForGlob implements drivers.ObjectStore.
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) ParsedConfig ¶ added in v0.78.0
func (c *Connection) ParsedConfig() *ConfigProperties
ParsedConfig returns the parsed configuration of the connection.
Source Files
Click to show internal directories.
Click to hide internal directories.