catalog

package

Go to main page

Versions in this module

v0

v0.51.0

Nov 7, 2024

Changes in this version

+ type AzureActiveDirectoryToken struct

+ AadToken string

+ ForceSendFields []string

+ func (s *AzureActiveDirectoryToken) UnmarshalJSON(b []byte) error

+ func (s AzureActiveDirectoryToken) MarshalJSON() ([]byte, error)

type ColumnTypeName

+ const ColumnTypeNameVariant

+ type CreateCredentialRequest struct

+ AwsIamRole *AwsIamRole

+ AzureManagedIdentity *AzureManagedIdentity

+ Comment string

+ ForceSendFields []string

+ Name string

+ Purpose CredentialPurpose

+ SkipValidation bool

+ func (s *CreateCredentialRequest) UnmarshalJSON(b []byte) error

+ func (s CreateCredentialRequest) MarshalJSON() ([]byte, error)

+ type CredentialInfo struct

+ AwsIamRole *AwsIamRole

+ AzureManagedIdentity *AzureManagedIdentity

+ Comment string

+ CreatedAt int64

+ CreatedBy string

+ ForceSendFields []string

+ FullName string

+ Id string

+ IsolationMode IsolationMode

+ MetastoreId string

+ Name string

+ Owner string

+ Purpose CredentialPurpose

+ UpdatedAt int64

+ UpdatedBy string

+ func (s *CredentialInfo) UnmarshalJSON(b []byte) error

+ func (s CredentialInfo) MarshalJSON() ([]byte, error)

+ type CredentialPurpose string

+ const CredentialPurposeService

+ func (f *CredentialPurpose) Set(v string) error

+ func (f *CredentialPurpose) String() string

+ func (f *CredentialPurpose) Type() string

+ type CredentialValidationResult struct

+ ForceSendFields []string

+ Message string

+ Result ValidateCredentialResult

+ func (s *CredentialValidationResult) UnmarshalJSON(b []byte) error

+ func (s CredentialValidationResult) MarshalJSON() ([]byte, error)

+ type CredentialsAPI struct

+ func NewCredentials(client *client.DatabricksClient) *CredentialsAPI

+ func (a *CredentialsAPI) CreateCredential(ctx context.Context, request CreateCredentialRequest) (*CredentialInfo, error)

+ func (a *CredentialsAPI) DeleteCredential(ctx context.Context, request DeleteCredentialRequest) error

+ func (a *CredentialsAPI) DeleteCredentialByNameArg(ctx context.Context, nameArg string) error

+ func (a *CredentialsAPI) GenerateTemporaryServiceCredential(ctx context.Context, request GenerateTemporaryServiceCredentialRequest) (*TemporaryCredentials, error)

+ func (a *CredentialsAPI) GetCredential(ctx context.Context, request GetCredentialRequest) (*CredentialInfo, error)

+ func (a *CredentialsAPI) GetCredentialByNameArg(ctx context.Context, nameArg string) (*CredentialInfo, error)

+ func (a *CredentialsAPI) ListCredentials(ctx context.Context, request ListCredentialsRequest) listing.Iterator[CredentialInfo]

+ func (a *CredentialsAPI) ListCredentialsAll(ctx context.Context, request ListCredentialsRequest) ([]CredentialInfo, error)

+ func (a *CredentialsAPI) UpdateCredential(ctx context.Context, request UpdateCredentialRequest) (*CredentialInfo, error)

+ func (a *CredentialsAPI) ValidateCredential(ctx context.Context, request ValidateCredentialRequest) (*ValidateCredentialResponse, error)

+ type CredentialsInterface interface

+ CreateCredential func(ctx context.Context, request CreateCredentialRequest) (*CredentialInfo, error)

+ DeleteCredential func(ctx context.Context, request DeleteCredentialRequest) error

+ DeleteCredentialByNameArg func(ctx context.Context, nameArg string) error

+ GenerateTemporaryServiceCredential func(ctx context.Context, request GenerateTemporaryServiceCredentialRequest) (*TemporaryCredentials, error)

+ GetCredential func(ctx context.Context, request GetCredentialRequest) (*CredentialInfo, error)

+ GetCredentialByNameArg func(ctx context.Context, nameArg string) (*CredentialInfo, error)

+ ListCredentials func(ctx context.Context, request ListCredentialsRequest) listing.Iterator[CredentialInfo]

+ ListCredentialsAll func(ctx context.Context, request ListCredentialsRequest) ([]CredentialInfo, error)

+ UpdateCredential func(ctx context.Context, request UpdateCredentialRequest) (*CredentialInfo, error)

+ ValidateCredential func(ctx context.Context, request ValidateCredentialRequest) (*ValidateCredentialResponse, error)

+ type CredentialsService interface

+ CreateCredential func(ctx context.Context, request CreateCredentialRequest) (*CredentialInfo, error)

+ DeleteCredential func(ctx context.Context, request DeleteCredentialRequest) error

+ GenerateTemporaryServiceCredential func(ctx context.Context, request GenerateTemporaryServiceCredentialRequest) (*TemporaryCredentials, error)

+ GetCredential func(ctx context.Context, request GetCredentialRequest) (*CredentialInfo, error)

+ ListCredentials func(ctx context.Context, request ListCredentialsRequest) (*ListCredentialsResponse, error)

+ UpdateCredential func(ctx context.Context, request UpdateCredentialRequest) (*CredentialInfo, error)

+ ValidateCredential func(ctx context.Context, request ValidateCredentialRequest) (*ValidateCredentialResponse, error)

+ type DeleteCredentialRequest struct

+ Force bool

+ ForceSendFields []string

+ NameArg string

+ func (s *DeleteCredentialRequest) UnmarshalJSON(b []byte) error

+ func (s DeleteCredentialRequest) MarshalJSON() ([]byte, error)

+ type DeleteCredentialResponse struct

+ type GenerateTemporaryServiceCredentialAzureOptions struct

+ Resources []string

+ type GenerateTemporaryServiceCredentialRequest struct

+ AzureOptions *GenerateTemporaryServiceCredentialAzureOptions

+ CredentialName string

+ ForceSendFields []string

+ func (s *GenerateTemporaryServiceCredentialRequest) UnmarshalJSON(b []byte) error

+ func (s GenerateTemporaryServiceCredentialRequest) MarshalJSON() ([]byte, error)

type GenerateTemporaryTableCredentialResponse

+ AzureAad *AzureActiveDirectoryToken

type GetBindingsSecurableType

+ const GetBindingsSecurableTypeServiceCredential

+ type GetCredentialRequest struct

+ NameArg string

+ type ListCredentialsRequest struct

+ ForceSendFields []string

+ MaxResults int

+ PageToken string

+ Purpose CredentialPurpose

+ func (s *ListCredentialsRequest) UnmarshalJSON(b []byte) error

+ func (s ListCredentialsRequest) MarshalJSON() ([]byte, error)

+ type ListCredentialsResponse struct

+ Credentials []CredentialInfo

+ ForceSendFields []string

+ NextPageToken string

+ func (s *ListCredentialsResponse) UnmarshalJSON(b []byte) error

+ func (s ListCredentialsResponse) MarshalJSON() ([]byte, error)

type ListTablesRequest

+ OmitUsername bool

type SecurableType

+ const SecurableTypeCredential

type StorageCredentialInfo

+ FullName string

+ type TemporaryCredentials struct

+ AwsTempCredentials *AwsCredentials

+ AzureAad *AzureActiveDirectoryToken

+ ExpirationTime int64

+ ForceSendFields []string

+ func (s *TemporaryCredentials) UnmarshalJSON(b []byte) error

+ func (s TemporaryCredentials) MarshalJSON() ([]byte, error)

type UpdateBindingsSecurableType

+ const UpdateBindingsSecurableTypeServiceCredential

+ type UpdateCredentialRequest struct

+ AwsIamRole *AwsIamRole

+ AzureManagedIdentity *AzureManagedIdentity

+ Comment string

+ Force bool

+ ForceSendFields []string

+ IsolationMode IsolationMode

+ NameArg string

+ NewName string

+ Owner string

+ SkipValidation bool

+ func (s *UpdateCredentialRequest) UnmarshalJSON(b []byte) error

+ func (s UpdateCredentialRequest) MarshalJSON() ([]byte, error)

+ type ValidateCredentialRequest struct

+ AwsIamRole *AwsIamRole

+ AzureManagedIdentity *AzureManagedIdentity

+ CredentialName string

+ ForceSendFields []string

+ Purpose CredentialPurpose

+ func (s *ValidateCredentialRequest) UnmarshalJSON(b []byte) error

+ func (s ValidateCredentialRequest) MarshalJSON() ([]byte, error)

+ type ValidateCredentialResponse struct

+ Results []CredentialValidationResult

+ type ValidateCredentialResult string

+ const ValidateCredentialResultFail

+ const ValidateCredentialResultPass

+ const ValidateCredentialResultSkip

+ func (f *ValidateCredentialResult) Set(v string) error

+ func (f *ValidateCredentialResult) String() string

+ func (f *ValidateCredentialResult) Type() string

v0.50.0

Oct 31, 2024

Changes in this version

type CreateOnlineTableRequest

+ Table *OnlineTable

type OnlineTablesAPI

+ func (a *OnlineTablesAPI) CreateAndWait(ctx context.Context, createOnlineTableRequest CreateOnlineTableRequest, ...) (*OnlineTable, error)

+ func (a *OnlineTablesAPI) WaitGetOnlineTableActive(ctx context.Context, name string, timeout time.Duration, ...) (*OnlineTable, error)

type OnlineTablesInterface

+ CreateAndWait func(ctx context.Context, createOnlineTableRequest CreateOnlineTableRequest, ...) (*OnlineTable, error)

+ WaitGetOnlineTableActive func(ctx context.Context, name string, timeout time.Duration, ...) (*OnlineTable, error)

+ type WaitGetOnlineTableActive struct

+ Name string

+ Poll func(time.Duration, func(*OnlineTable)) (*OnlineTable, error)

+ Response *R

+ func (w *WaitGetOnlineTableActive[R]) Get() (*OnlineTable, error)

+ func (w *WaitGetOnlineTableActive[R]) GetWithTimeout(timeout time.Duration) (*OnlineTable, error)

+ func (w *WaitGetOnlineTableActive[R]) OnProgress(callback func(*OnlineTable)) *WaitGetOnlineTableActive[R]

v0.49.0

Oct 14, 2024

Changes in this version

type ConnectionInfoSecurableKind

+ const ConnectionInfoSecurableKindConnectionHttpBearer

type ConnectionType

+ const ConnectionTypeHttp

type CredentialType

+ const CredentialTypeBearerToken

type OnlineTable

+ UnityCatalogProvisioningState ProvisioningInfoState

type ProvisioningInfoState

+ const ProvisioningInfoStateUpdating

v0.48.0

Oct 3, 2024

v0.47.0

Oct 1, 2024

Changes in this version

+ type AwsCredentials struct

+ AccessKeyId string

+ AccessPoint string

+ ForceSendFields []string

+ SecretAccessKey string

+ SessionToken string

+ func (s *AwsCredentials) UnmarshalJSON(b []byte) error

+ func (s AwsCredentials) MarshalJSON() ([]byte, error)

+ type AzureUserDelegationSas struct

+ ForceSendFields []string

+ SasToken string

+ func (s *AzureUserDelegationSas) UnmarshalJSON(b []byte) error

+ func (s AzureUserDelegationSas) MarshalJSON() ([]byte, error)

+ type GcpOauthToken struct

+ ForceSendFields []string

+ OauthToken string

+ func (s *GcpOauthToken) UnmarshalJSON(b []byte) error

+ func (s GcpOauthToken) MarshalJSON() ([]byte, error)

+ type GenerateTemporaryTableCredentialRequest struct

+ ForceSendFields []string

+ Operation TableOperation

+ TableId string

+ func (s *GenerateTemporaryTableCredentialRequest) UnmarshalJSON(b []byte) error

+ func (s GenerateTemporaryTableCredentialRequest) MarshalJSON() ([]byte, error)

+ type GenerateTemporaryTableCredentialResponse struct

+ AwsTempCredentials *AwsCredentials

+ AzureUserDelegationSas *AzureUserDelegationSas

+ ExpirationTime int64

+ ForceSendFields []string

+ GcpOauthToken *GcpOauthToken

+ R2TempCredentials *R2Credentials

+ Url string

+ func (s *GenerateTemporaryTableCredentialResponse) UnmarshalJSON(b []byte) error

+ func (s GenerateTemporaryTableCredentialResponse) MarshalJSON() ([]byte, error)

type GetMetastoreSummaryResponse

+ ExternalAccessEnabled bool

type GetTableRequest

+ IncludeManifestCapabilities bool

type ListSummariesRequest

+ IncludeManifestCapabilities bool

type ListTablesRequest

+ IncludeManifestCapabilities bool

type MetastoreInfo

+ ExternalAccessEnabled bool

+ type R2Credentials struct

+ AccessKeyId string

+ ForceSendFields []string

+ SecretAccessKey string

+ SessionToken string

+ func (s *R2Credentials) UnmarshalJSON(b []byte) error

+ func (s R2Credentials) MarshalJSON() ([]byte, error)

+ type TableOperation string

+ const TableOperationRead

+ const TableOperationReadWrite

+ func (f *TableOperation) Set(v string) error

+ func (f *TableOperation) String() string

+ func (f *TableOperation) Type() string

+ type TemporaryTableCredentialsAPI struct

+ func NewTemporaryTableCredentials(client *client.DatabricksClient) *TemporaryTableCredentialsAPI

+ func (a *TemporaryTableCredentialsAPI) GenerateTemporaryTableCredentials(ctx context.Context, request GenerateTemporaryTableCredentialRequest) (*GenerateTemporaryTableCredentialResponse, error)

+ type TemporaryTableCredentialsInterface interface

+ GenerateTemporaryTableCredentials func(ctx context.Context, request GenerateTemporaryTableCredentialRequest) (*GenerateTemporaryTableCredentialResponse, error)

+ type TemporaryTableCredentialsService interface

+ GenerateTemporaryTableCredentials func(ctx context.Context, request GenerateTemporaryTableCredentialRequest) (*GenerateTemporaryTableCredentialResponse, error)

v0.46.0

Sep 4, 2024

Changes in this version

type QualityMonitorsAPI

+ func (a *QualityMonitorsAPI) RegenerateDashboard(ctx context.Context, request RegenerateDashboardRequest) (*RegenerateDashboardResponse, error)

type QualityMonitorsInterface

+ RegenerateDashboard func(ctx context.Context, request RegenerateDashboardRequest) (*RegenerateDashboardResponse, error)

type QualityMonitorsService

+ RegenerateDashboard func(ctx context.Context, request RegenerateDashboardRequest) (*RegenerateDashboardResponse, error)

+ type RegenerateDashboardRequest struct

+ ForceSendFields []string

+ TableName string

+ WarehouseId string

+ func (s *RegenerateDashboardRequest) UnmarshalJSON(b []byte) error

+ func (s RegenerateDashboardRequest) MarshalJSON() ([]byte, error)

+ type RegenerateDashboardResponse struct

+ DashboardId string

+ ForceSendFields []string

+ ParentFolder string

+ func (s *RegenerateDashboardResponse) UnmarshalJSON(b []byte) error

+ func (s RegenerateDashboardResponse) MarshalJSON() ([]byte, error)

v0.45.0

Aug 21, 2024

Changes in this version

type ConnectionInfoSecurableKind

+ const ConnectionInfoSecurableKindConnectionBuiltinHiveMetastore

+ const ConnectionInfoSecurableKindConnectionExternalHiveMetastore

+ const ConnectionInfoSecurableKindConnectionGlue

type ConnectionType

+ const ConnectionTypeGlue

+ const ConnectionTypeHiveMetastore

type CreateExternalLocation

+ Fallback bool

type ExternalLocationInfo

+ Fallback bool

+ type GetQuotaRequest struct

+ ParentFullName string

+ ParentSecurableType string

+ QuotaName string

+ type GetQuotaResponse struct

+ QuotaInfo *QuotaInfo

+ type ListQuotasRequest struct

+ ForceSendFields []string

+ MaxResults int

+ PageToken string

+ func (s *ListQuotasRequest) UnmarshalJSON(b []byte) error

+ func (s ListQuotasRequest) MarshalJSON() ([]byte, error)

+ type ListQuotasResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ Quotas []QuotaInfo

+ func (s *ListQuotasResponse) UnmarshalJSON(b []byte) error

+ func (s ListQuotasResponse) MarshalJSON() ([]byte, error)

+ type QuotaInfo struct

+ ForceSendFields []string

+ LastRefreshedAt int64

+ ParentFullName string

+ ParentSecurableType SecurableType

+ QuotaCount int

+ QuotaLimit int

+ QuotaName string

+ func (s *QuotaInfo) UnmarshalJSON(b []byte) error

+ func (s QuotaInfo) MarshalJSON() ([]byte, error)

+ type ResourceQuotasAPI struct

+ func NewResourceQuotas(client *client.DatabricksClient) *ResourceQuotasAPI

+ func (a *ResourceQuotasAPI) GetQuota(ctx context.Context, request GetQuotaRequest) (*GetQuotaResponse, error)

+ func (a *ResourceQuotasAPI) GetQuotaByParentSecurableTypeAndParentFullNameAndQuotaName(ctx context.Context, parentSecurableType string, parentFullName string, ...) (*GetQuotaResponse, error)

+ func (a *ResourceQuotasAPI) ListQuotas(ctx context.Context, request ListQuotasRequest) listing.Iterator[QuotaInfo]

+ func (a *ResourceQuotasAPI) ListQuotasAll(ctx context.Context, request ListQuotasRequest) ([]QuotaInfo, error)

+ type ResourceQuotasInterface interface

+ GetQuota func(ctx context.Context, request GetQuotaRequest) (*GetQuotaResponse, error)

+ GetQuotaByParentSecurableTypeAndParentFullNameAndQuotaName func(ctx context.Context, parentSecurableType string, parentFullName string, ...) (*GetQuotaResponse, error)

+ ListQuotas func(ctx context.Context, request ListQuotasRequest) listing.Iterator[QuotaInfo]

+ ListQuotasAll func(ctx context.Context, request ListQuotasRequest) ([]QuotaInfo, error)

+ type ResourceQuotasService interface

+ GetQuota func(ctx context.Context, request GetQuotaRequest) (*GetQuotaResponse, error)

+ ListQuotas func(ctx context.Context, request ListQuotasRequest) (*ListQuotasResponse, error)

type UpdateExternalLocation

+ Fallback bool

v0.44.0

Aug 13, 2024

Changes in this version

type DeleteSchemaRequest

+ Force bool

+ ForceSendFields []string

+ func (s *DeleteSchemaRequest) UnmarshalJSON(b []byte) error

+ func (s DeleteSchemaRequest) MarshalJSON() ([]byte, error)

type GetBindingsRequest

+ ForceSendFields []string

+ MaxResults int

+ PageToken string

+ func (s *GetBindingsRequest) UnmarshalJSON(b []byte) error

+ func (s GetBindingsRequest) MarshalJSON() ([]byte, error)

+ type GetBindingsSecurableType string

+ const GetBindingsSecurableTypeCatalog

+ const GetBindingsSecurableTypeExternalLocation

+ const GetBindingsSecurableTypeStorageCredential

+ func (f *GetBindingsSecurableType) Set(v string) error

+ func (f *GetBindingsSecurableType) String() string

+ func (f *GetBindingsSecurableType) Type() string

type GetByAliasRequest

+ ForceSendFields []string

+ IncludeAliases bool

+ func (s *GetByAliasRequest) UnmarshalJSON(b []byte) error

+ func (s GetByAliasRequest) MarshalJSON() ([]byte, error)

type GetModelVersionRequest

+ IncludeAliases bool

type GetRegisteredModelRequest

+ IncludeAliases bool

type ListSystemSchemasRequest

+ ForceSendFields []string

+ MaxResults int

+ PageToken string

+ func (s *ListSystemSchemasRequest) UnmarshalJSON(b []byte) error

+ func (s ListSystemSchemasRequest) MarshalJSON() ([]byte, error)

type ListSystemSchemasResponse

+ ForceSendFields []string

+ NextPageToken string

+ func (s *ListSystemSchemasResponse) UnmarshalJSON(b []byte) error

+ func (s ListSystemSchemasResponse) MarshalJSON() ([]byte, error)

type ModelVersionInfo

+ Aliases []RegisteredModelAlias

type Privilege

+ const PrivilegeManage

+ type UpdateBindingsSecurableType string

+ const UpdateBindingsSecurableTypeCatalog

+ const UpdateBindingsSecurableTypeExternalLocation

+ const UpdateBindingsSecurableTypeStorageCredential

+ func (f *UpdateBindingsSecurableType) Set(v string) error

+ func (f *UpdateBindingsSecurableType) String() string

+ func (f *UpdateBindingsSecurableType) Type() string

type WorkspaceBindingsAPI

+ func (a *WorkspaceBindingsAPI) GetBindingsAll(ctx context.Context, request GetBindingsRequest) ([]WorkspaceBinding, error)

type WorkspaceBindingsInterface

+ GetBindingsAll func(ctx context.Context, request GetBindingsRequest) ([]WorkspaceBinding, error)

type WorkspaceBindingsResponse

+ ForceSendFields []string

+ NextPageToken string

+ func (s *WorkspaceBindingsResponse) UnmarshalJSON(b []byte) error

+ func (s WorkspaceBindingsResponse) MarshalJSON() ([]byte, error)

v0.43.2

Jul 9, 2024

v0.43.1

Jul 8, 2024

v0.43.0

Jun 24, 2024

Changes in this version

+ type CatalogIsolationMode string

+ const CatalogIsolationModeIsolated

+ const CatalogIsolationModeOpen

+ func (f *CatalogIsolationMode) Set(v string) error

+ func (f *CatalogIsolationMode) String() string

+ func (f *CatalogIsolationMode) Type() string

type ExternalLocationInfo

+ IsolationMode IsolationMode

type IsolationMode

+ const IsolationModeIsolationModeIsolated

+ const IsolationModeIsolationModeOpen

type ListCatalogsRequest

+ MaxResults int

+ PageToken string

type ListCatalogsResponse

+ ForceSendFields []string

+ NextPageToken string

+ func (s *ListCatalogsResponse) UnmarshalJSON(b []byte) error

+ func (s ListCatalogsResponse) MarshalJSON() ([]byte, error)

type OnlineTable

+ TableServingUrl string

type StorageCredentialInfo

+ IsolationMode IsolationMode

type UpdateExternalLocation

+ IsolationMode IsolationMode

type UpdateStorageCredential

+ IsolationMode IsolationMode

v0.42.0

Jun 3, 2024

Changes in this version

type AccountStorageCredentialsAPI

+ func (a *AccountStorageCredentialsAPI) ListAll(ctx context.Context, request ListAccountStorageCredentialsRequest) ([]StorageCredentialInfo, error)

type AccountStorageCredentialsInterface

+ ListAll func(ctx context.Context, request ListAccountStorageCredentialsRequest) ([]StorageCredentialInfo, error)

type DataSourceFormat

+ const DataSourceFormatBigqueryFormat

+ const DataSourceFormatDatabricksFormat

+ const DataSourceFormatHiveCustom

+ const DataSourceFormatHiveSerde

+ const DataSourceFormatMysqlFormat

+ const DataSourceFormatNetsuiteFormat

+ const DataSourceFormatPostgresqlFormat

+ const DataSourceFormatRedshiftFormat

+ const DataSourceFormatSalesforceFormat

+ const DataSourceFormatSnowflakeFormat

+ const DataSourceFormatSqldwFormat

+ const DataSourceFormatSqlserverFormat

+ const DataSourceFormatVectorIndexFormat

+ const DataSourceFormatWorkdayRaasFormat

+ type ListAccountStorageCredentialsResponse struct

+ StorageCredentials []StorageCredentialInfo

type TableType

+ const TableTypeExternalShallowClone

+ const TableTypeForeign

+ const TableTypeManagedShallowClone

v0.41.0

May 21, 2024

Changes in this version

+ type DeleteQualityMonitorRequest struct

+ TableName string

+ type GetQualityMonitorRequest struct

+ TableName string

+ type ListConnectionsRequest struct

+ ForceSendFields []string

+ MaxResults int

+ PageToken string

+ func (s *ListConnectionsRequest) UnmarshalJSON(b []byte) error

+ func (s ListConnectionsRequest) MarshalJSON() ([]byte, error)

type ListConnectionsResponse

+ ForceSendFields []string

+ NextPageToken string

+ func (s *ListConnectionsResponse) UnmarshalJSON(b []byte) error

+ func (s ListConnectionsResponse) MarshalJSON() ([]byte, error)

+ type MonitorRefreshListResponse struct

+ Refreshes []MonitorRefreshInfo

type Privilege

+ const PrivilegeSingleUserAccess

+ type QualityMonitorsAPI struct

+ func NewQualityMonitors(client *client.DatabricksClient) *QualityMonitorsAPI

+ func (a *QualityMonitorsAPI) CancelRefresh(ctx context.Context, request CancelRefreshRequest) error

+ func (a *QualityMonitorsAPI) Create(ctx context.Context, request CreateMonitor) (*MonitorInfo, error)

+ func (a *QualityMonitorsAPI) Delete(ctx context.Context, request DeleteQualityMonitorRequest) error

+ func (a *QualityMonitorsAPI) DeleteByTableName(ctx context.Context, tableName string) error

+ func (a *QualityMonitorsAPI) Get(ctx context.Context, request GetQualityMonitorRequest) (*MonitorInfo, error)

+ func (a *QualityMonitorsAPI) GetByTableName(ctx context.Context, tableName string) (*MonitorInfo, error)

+ func (a *QualityMonitorsAPI) GetRefresh(ctx context.Context, request GetRefreshRequest) (*MonitorRefreshInfo, error)

+ func (a *QualityMonitorsAPI) GetRefreshByTableNameAndRefreshId(ctx context.Context, tableName string, refreshId string) (*MonitorRefreshInfo, error)

+ func (a *QualityMonitorsAPI) Impl() QualityMonitorsService

+ func (a *QualityMonitorsAPI) ListRefreshes(ctx context.Context, request ListRefreshesRequest) (*MonitorRefreshListResponse, error)

+ func (a *QualityMonitorsAPI) ListRefreshesByTableName(ctx context.Context, tableName string) (*MonitorRefreshListResponse, error)

+ func (a *QualityMonitorsAPI) RunRefresh(ctx context.Context, request RunRefreshRequest) (*MonitorRefreshInfo, error)

+ func (a *QualityMonitorsAPI) Update(ctx context.Context, request UpdateMonitor) (*MonitorInfo, error)

+ func (a *QualityMonitorsAPI) WithImpl(impl QualityMonitorsService) QualityMonitorsInterface

+ type QualityMonitorsInterface interface

+ CancelRefresh func(ctx context.Context, request CancelRefreshRequest) error

+ Create func(ctx context.Context, request CreateMonitor) (*MonitorInfo, error)

+ Delete func(ctx context.Context, request DeleteQualityMonitorRequest) error

+ DeleteByTableName func(ctx context.Context, tableName string) error

+ Get func(ctx context.Context, request GetQualityMonitorRequest) (*MonitorInfo, error)

+ GetByTableName func(ctx context.Context, tableName string) (*MonitorInfo, error)

+ GetRefresh func(ctx context.Context, request GetRefreshRequest) (*MonitorRefreshInfo, error)

+ GetRefreshByTableNameAndRefreshId func(ctx context.Context, tableName string, refreshId string) (*MonitorRefreshInfo, error)

+ Impl func() QualityMonitorsService

+ ListRefreshes func(ctx context.Context, request ListRefreshesRequest) (*MonitorRefreshListResponse, error)

+ ListRefreshesByTableName func(ctx context.Context, tableName string) (*MonitorRefreshListResponse, error)

+ RunRefresh func(ctx context.Context, request RunRefreshRequest) (*MonitorRefreshInfo, error)

+ Update func(ctx context.Context, request UpdateMonitor) (*MonitorInfo, error)

+ WithImpl func(impl QualityMonitorsService) QualityMonitorsInterface

+ type QualityMonitorsService interface

+ CancelRefresh func(ctx context.Context, request CancelRefreshRequest) error

+ Create func(ctx context.Context, request CreateMonitor) (*MonitorInfo, error)

+ Delete func(ctx context.Context, request DeleteQualityMonitorRequest) error

+ Get func(ctx context.Context, request GetQualityMonitorRequest) (*MonitorInfo, error)

+ GetRefresh func(ctx context.Context, request GetRefreshRequest) (*MonitorRefreshInfo, error)

+ ListRefreshes func(ctx context.Context, request ListRefreshesRequest) (*MonitorRefreshListResponse, error)

+ RunRefresh func(ctx context.Context, request RunRefreshRequest) (*MonitorRefreshInfo, error)

+ Update func(ctx context.Context, request UpdateMonitor) (*MonitorInfo, error)

type UpdateMonitor

+ DashboardId string

v0.40.1

May 14, 2024

v0.40.0

May 2, 2024

v0.39.0

Apr 24, 2024

Changes in this version

type Privilege

+ const PrivilegeAccess

+ const PrivilegeCreateServiceCredential

type SchemaInfo

+ SchemaId string

type ValidationResultOperation

+ const ValidationResultOperationPathExists

v0.38.0

Apr 11, 2024

Changes in this version

+ type AzureManagedIdentityRequest struct

+ AccessConnectorId string

+ ForceSendFields []string

+ ManagedIdentityId string

+ func (s *AzureManagedIdentityRequest) UnmarshalJSON(b []byte) error

+ func (s AzureManagedIdentityRequest) MarshalJSON() ([]byte, error)

+ type AzureManagedIdentityResponse struct

+ AccessConnectorId string

+ CredentialId string

+ ForceSendFields []string

+ ManagedIdentityId string

+ func (s *AzureManagedIdentityResponse) UnmarshalJSON(b []byte) error

+ func (s AzureManagedIdentityResponse) MarshalJSON() ([]byte, error)

type CancelRefreshRequest

+ TableName string

type CreateMonitor

+ TableName string

type DeleteLakehouseMonitorRequest

+ TableName string

type GetLakehouseMonitorRequest

+ TableName string

type GetRefreshRequest

+ TableName string

type LakehouseMonitorsAPI

+ func (a *LakehouseMonitorsAPI) DeleteByTableName(ctx context.Context, tableName string) error

+ func (a *LakehouseMonitorsAPI) GetByTableName(ctx context.Context, tableName string) (*MonitorInfo, error)

+ func (a *LakehouseMonitorsAPI) GetRefreshByTableNameAndRefreshId(ctx context.Context, tableName string, refreshId string) (*MonitorRefreshInfo, error)

+ func (a *LakehouseMonitorsAPI) ListRefreshesByTableName(ctx context.Context, tableName string) ([]MonitorRefreshInfo, error)

type LakehouseMonitorsInterface

+ DeleteByTableName func(ctx context.Context, tableName string) error

+ GetByTableName func(ctx context.Context, tableName string) (*MonitorInfo, error)

+ GetRefreshByTableNameAndRefreshId func(ctx context.Context, tableName string, refreshId string) (*MonitorRefreshInfo, error)

+ ListRefreshesByTableName func(ctx context.Context, tableName string) ([]MonitorRefreshInfo, error)

type ListRefreshesRequest

+ TableName string

+ type MonitorDestination struct

+ EmailAddresses []string

+ type MonitorInferenceLog struct

+ ForceSendFields []string

+ Granularities []string

+ LabelCol string

+ ModelIdCol string

+ PredictionCol string

+ PredictionProbaCol string

+ ProblemType MonitorInferenceLogProblemType

+ TimestampCol string

+ func (s *MonitorInferenceLog) UnmarshalJSON(b []byte) error

+ func (s MonitorInferenceLog) MarshalJSON() ([]byte, error)

+ type MonitorInferenceLogProblemType string

+ const MonitorInferenceLogProblemTypeProblemTypeClassification

+ const MonitorInferenceLogProblemTypeProblemTypeRegression

+ func (f *MonitorInferenceLogProblemType) Set(v string) error

+ func (f *MonitorInferenceLogProblemType) String() string

+ func (f *MonitorInferenceLogProblemType) Type() string

+ type MonitorMetric struct

+ Definition string

+ InputColumns []string

+ Name string

+ OutputDataType string

+ Type MonitorMetricType

+ type MonitorMetricType string

+ const MonitorMetricTypeCustomMetricTypeAggregate

+ const MonitorMetricTypeCustomMetricTypeDerived

+ const MonitorMetricTypeCustomMetricTypeDrift

+ func (f *MonitorMetricType) Set(v string) error

+ func (f *MonitorMetricType) String() string

+ func (f *MonitorMetricType) Type() string

+ type MonitorNotifications struct

+ OnFailure *MonitorDestination

+ OnNewClassificationTagDetected *MonitorDestination

type MonitorRefreshInfo

+ Trigger MonitorRefreshInfoTrigger

+ type MonitorRefreshInfoTrigger string

+ const MonitorRefreshInfoTriggerManual

+ const MonitorRefreshInfoTriggerSchedule

+ func (f *MonitorRefreshInfoTrigger) Set(v string) error

+ func (f *MonitorRefreshInfoTrigger) String() string

+ func (f *MonitorRefreshInfoTrigger) Type() string

+ type MonitorSnapshot struct

+ type MonitorTimeSeries struct

+ Granularities []string

+ TimestampCol string

type RunRefreshRequest

+ TableName string

type TableRowFilter

+ FunctionName string

type UpdateMonitor

+ TableName string

type ValidationResult

+ AwsOperation ValidationResultAwsOperation

+ AzureOperation ValidationResultAzureOperation

+ GcpOperation ValidationResultGcpOperation

+ type ValidationResultAwsOperation string

+ const ValidationResultAwsOperationDelete

+ const ValidationResultAwsOperationList

+ const ValidationResultAwsOperationPathExists

+ const ValidationResultAwsOperationRead

+ const ValidationResultAwsOperationWrite

+ func (f *ValidationResultAwsOperation) Set(v string) error

+ func (f *ValidationResultAwsOperation) String() string

+ func (f *ValidationResultAwsOperation) Type() string

+ type ValidationResultAzureOperation string

+ const ValidationResultAzureOperationDelete

+ const ValidationResultAzureOperationHierarchicalNamespaceEnabled

+ const ValidationResultAzureOperationList

+ const ValidationResultAzureOperationPathExists

+ const ValidationResultAzureOperationRead

+ const ValidationResultAzureOperationWrite

+ func (f *ValidationResultAzureOperation) Set(v string) error

+ func (f *ValidationResultAzureOperation) String() string

+ func (f *ValidationResultAzureOperation) Type() string

+ type ValidationResultGcpOperation string

+ const ValidationResultGcpOperationDelete

+ const ValidationResultGcpOperationList

+ const ValidationResultGcpOperationPathExists

+ const ValidationResultGcpOperationRead

+ const ValidationResultGcpOperationWrite

+ func (f *ValidationResultGcpOperation) Set(v string) error

+ func (f *ValidationResultGcpOperation) String() string

+ func (f *ValidationResultGcpOperation) Type() string

v0.37.0

Mar 28, 2024

v0.36.0

Mar 20, 2024

v0.35.0

Mar 20, 2024

Changes in this version

+ type AwsIamRoleRequest struct

+ RoleArn string

+ type AwsIamRoleResponse struct

+ ExternalId string

+ ForceSendFields []string

+ RoleArn string

+ UnityCatalogIamArn string

+ func (s *AwsIamRoleResponse) UnmarshalJSON(b []byte) error

+ func (s AwsIamRoleResponse) MarshalJSON() ([]byte, error)

+ type CreateOnlineTableRequest struct

+ ForceSendFields []string

+ Name string

+ Spec *OnlineTableSpec

+ func (s *CreateOnlineTableRequest) UnmarshalJSON(b []byte) error

+ func (s CreateOnlineTableRequest) MarshalJSON() ([]byte, error)

type ExternalLocationInfo

+ BrowseOnly bool

type FunctionInfo

+ BrowseOnly bool

type GetCatalogRequest

+ ForceSendFields []string

+ IncludeBrowse bool

+ func (s *GetCatalogRequest) UnmarshalJSON(b []byte) error

+ func (s GetCatalogRequest) MarshalJSON() ([]byte, error)

type GetExternalLocationRequest

+ ForceSendFields []string

+ IncludeBrowse bool

+ func (s *GetExternalLocationRequest) UnmarshalJSON(b []byte) error

+ func (s GetExternalLocationRequest) MarshalJSON() ([]byte, error)

type GetFunctionRequest

+ ForceSendFields []string

+ IncludeBrowse bool

+ func (s *GetFunctionRequest) UnmarshalJSON(b []byte) error

+ func (s GetFunctionRequest) MarshalJSON() ([]byte, error)

type GetModelVersionRequest

+ ForceSendFields []string

+ IncludeBrowse bool

+ func (s *GetModelVersionRequest) UnmarshalJSON(b []byte) error

+ func (s GetModelVersionRequest) MarshalJSON() ([]byte, error)

type GetRegisteredModelRequest

+ ForceSendFields []string

+ IncludeBrowse bool

+ func (s *GetRegisteredModelRequest) UnmarshalJSON(b []byte) error

+ func (s GetRegisteredModelRequest) MarshalJSON() ([]byte, error)

type GetSchemaRequest

+ ForceSendFields []string

+ IncludeBrowse bool

+ func (s *GetSchemaRequest) UnmarshalJSON(b []byte) error

+ func (s GetSchemaRequest) MarshalJSON() ([]byte, error)

type GetTableRequest

+ IncludeBrowse bool

+ type ListCatalogsRequest struct

+ ForceSendFields []string

+ IncludeBrowse bool

+ func (s *ListCatalogsRequest) UnmarshalJSON(b []byte) error

+ func (s ListCatalogsRequest) MarshalJSON() ([]byte, error)

type ListExternalLocationsRequest

+ IncludeBrowse bool

type ListFunctionsRequest

+ IncludeBrowse bool

type ListModelVersionsRequest

+ IncludeBrowse bool

type ListRegisteredModelsRequest

+ IncludeBrowse bool

type ListSchemasRequest

+ IncludeBrowse bool

type ListTablesRequest

+ IncludeBrowse bool

type ListVolumesRequest

+ IncludeBrowse bool

type ModelVersionInfo

+ BrowseOnly bool

type ReadVolumeRequest

+ ForceSendFields []string

+ IncludeBrowse bool

+ func (s *ReadVolumeRequest) UnmarshalJSON(b []byte) error

+ func (s ReadVolumeRequest) MarshalJSON() ([]byte, error)

type RegisteredModelInfo

+ BrowseOnly bool

type SchemaInfo

+ BrowseOnly bool

type TableInfo

+ BrowseOnly bool

type VolumeInfo

+ BrowseOnly bool

v0.34.0

Mar 5, 2024

Changes in this version

+ type AssignResponse struct

+ type CancelRefreshResponse struct

+ type CreateResponse struct

+ type DatabricksGcpServiceAccountRequest struct

+ type DeleteAliasResponse struct

+ type DeleteResponse struct

+ type DisableResponse struct

+ type EnableResponse struct

+ type MonitorSnapshotProfileType struct

+ type OnlineTableSpecContinuousSchedulingPolicy struct

+ type OnlineTableSpecTriggeredSchedulingPolicy struct

+ type UnassignResponse struct

+ type UpdateAssignmentResponse struct

+ type UpdateResponse struct

v0.33.0

Feb 19, 2024

Changes in this version

+ type ContinuousUpdateStatus struct

+ ForceSendFields []string

+ InitialPipelineSyncProgress *PipelineProgress

+ LastProcessedCommitVersion int64

+ Timestamp string

+ func (s *ContinuousUpdateStatus) UnmarshalJSON(b []byte) error

+ func (s ContinuousUpdateStatus) MarshalJSON() ([]byte, error)

+ type DeleteOnlineTableRequest struct

+ Name string

+ type FailedStatus struct

+ ForceSendFields []string

+ LastProcessedCommitVersion int64

+ Timestamp string

+ func (s *FailedStatus) UnmarshalJSON(b []byte) error

+ func (s FailedStatus) MarshalJSON() ([]byte, error)

+ type GetOnlineTableRequest struct

+ Name string

+ type OnlineTable struct

+ ForceSendFields []string

+ Name string

+ Spec *OnlineTableSpec

+ Status *OnlineTableStatus

+ func (s *OnlineTable) UnmarshalJSON(b []byte) error

+ func (s OnlineTable) MarshalJSON() ([]byte, error)

+ type OnlineTableSpec struct

+ ForceSendFields []string

+ PerformFullCopy bool

+ PipelineId string

+ PrimaryKeyColumns []string

+ RunContinuously any

+ RunTriggered any

+ SourceTableFullName string

+ TimeseriesKey string

+ func (s *OnlineTableSpec) UnmarshalJSON(b []byte) error

+ func (s OnlineTableSpec) MarshalJSON() ([]byte, error)

+ type OnlineTableState string

+ const OnlineTableStateOffline

+ const OnlineTableStateOfflineFailed

+ const OnlineTableStateOnline

+ const OnlineTableStateOnlineContinuousUpdate

+ const OnlineTableStateOnlineNoPendingUpdate

+ const OnlineTableStateOnlinePipelineFailed

+ const OnlineTableStateOnlineTableStateUnspecified

+ const OnlineTableStateOnlineTriggeredUpdate

+ const OnlineTableStateOnlineUpdatingPipelineResources

+ const OnlineTableStateProvisioning

+ const OnlineTableStateProvisioningInitialSnapshot

+ const OnlineTableStateProvisioningPipelineResources

+ func (f *OnlineTableState) Set(v string) error

+ func (f *OnlineTableState) String() string

+ func (f *OnlineTableState) Type() string

+ type OnlineTableStatus struct

+ ContinuousUpdateStatus *ContinuousUpdateStatus

+ DetailedState OnlineTableState

+ FailedStatus *FailedStatus

+ ForceSendFields []string

+ Message string

+ ProvisioningStatus *ProvisioningStatus

+ TriggeredUpdateStatus *TriggeredUpdateStatus

+ func (s *OnlineTableStatus) UnmarshalJSON(b []byte) error

+ func (s OnlineTableStatus) MarshalJSON() ([]byte, error)

+ type OnlineTablesAPI struct

+ func NewOnlineTables(client *client.DatabricksClient) *OnlineTablesAPI

+ func (a *OnlineTablesAPI) Create(ctx context.Context, request ViewData) (*OnlineTable, error)

+ func (a *OnlineTablesAPI) Delete(ctx context.Context, request DeleteOnlineTableRequest) error

+ func (a *OnlineTablesAPI) DeleteByName(ctx context.Context, name string) error

+ func (a *OnlineTablesAPI) Get(ctx context.Context, request GetOnlineTableRequest) (*OnlineTable, error)

+ func (a *OnlineTablesAPI) GetByName(ctx context.Context, name string) (*OnlineTable, error)

+ func (a *OnlineTablesAPI) Impl() OnlineTablesService

+ func (a *OnlineTablesAPI) WithImpl(impl OnlineTablesService) OnlineTablesInterface

+ type OnlineTablesInterface interface

+ Create func(ctx context.Context, request ViewData) (*OnlineTable, error)

+ Delete func(ctx context.Context, request DeleteOnlineTableRequest) error

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

+ Get func(ctx context.Context, request GetOnlineTableRequest) (*OnlineTable, error)

+ GetByName func(ctx context.Context, name string) (*OnlineTable, error)

+ Impl func() OnlineTablesService

+ WithImpl func(impl OnlineTablesService) OnlineTablesInterface

+ type OnlineTablesService interface

+ Create func(ctx context.Context, request ViewData) (*OnlineTable, error)

+ Delete func(ctx context.Context, request DeleteOnlineTableRequest) error

+ Get func(ctx context.Context, request GetOnlineTableRequest) (*OnlineTable, error)

+ type PipelineProgress struct

+ EstimatedCompletionTimeSeconds float64

+ ForceSendFields []string

+ LatestVersionCurrentlyProcessing int64

+ SyncProgressCompletion float64

+ SyncedRowCount int64

+ TotalRowCount int64

+ func (s *PipelineProgress) UnmarshalJSON(b []byte) error

+ func (s PipelineProgress) MarshalJSON() ([]byte, error)

+ type ProvisioningStatus struct

+ InitialPipelineSyncProgress *PipelineProgress

+ type TriggeredUpdateStatus struct

+ ForceSendFields []string

+ LastProcessedCommitVersion int64

+ Timestamp string

+ TriggeredUpdateProgress *PipelineProgress

+ func (s *TriggeredUpdateStatus) UnmarshalJSON(b []byte) error

+ func (s TriggeredUpdateStatus) MarshalJSON() ([]byte, error)

+ type ViewData struct

+ ForceSendFields []string

+ Name string

+ Spec *OnlineTableSpec

+ func (s *ViewData) UnmarshalJSON(b []byte) error

+ func (s ViewData) MarshalJSON() ([]byte, error)

v0.32.0

Feb 14, 2024

Changes in this version

type ConnectionsAPI

+ func (a *ConnectionsAPI) DeleteByName(ctx context.Context, name string) error

type ConnectionsInterface

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

type DeleteConnectionRequest

+ Name string

type DeleteVolumeRequest

+ Name string

type GetConnectionRequest

+ Name string

type ListVolumesRequest

+ ForceSendFields []string

+ MaxResults int

+ PageToken string

+ func (s *ListVolumesRequest) UnmarshalJSON(b []byte) error

+ func (s ListVolumesRequest) MarshalJSON() ([]byte, error)

type ListVolumesResponseContent

+ ForceSendFields []string

+ NextPageToken string

+ func (s *ListVolumesResponseContent) UnmarshalJSON(b []byte) error

+ func (s ListVolumesResponseContent) MarshalJSON() ([]byte, error)

type ReadVolumeRequest

+ Name string

type VolumesAPI

+ func (a *VolumesAPI) DeleteByName(ctx context.Context, name string) error

+ func (a *VolumesAPI) ReadByName(ctx context.Context, name string) (*VolumeInfo, error)

type VolumesInterface

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

+ ReadByName func(ctx context.Context, name string) (*VolumeInfo, error)

v0.31.0

Feb 8, 2024

Changes in this version

+ type CancelRefreshRequest struct

+ FullName string

+ RefreshId string

type ConnectionType

+ const ConnectionTypeBigquery

+ type GetRefreshRequest struct

+ FullName string

+ RefreshId string

type LakehouseMonitorsAPI

+ func (a *LakehouseMonitorsAPI) CancelRefresh(ctx context.Context, request CancelRefreshRequest) error

+ func (a *LakehouseMonitorsAPI) GetRefresh(ctx context.Context, request GetRefreshRequest) (*MonitorRefreshInfo, error)

+ func (a *LakehouseMonitorsAPI) GetRefreshByFullNameAndRefreshId(ctx context.Context, fullName string, refreshId string) (*MonitorRefreshInfo, error)

+ func (a *LakehouseMonitorsAPI) ListRefreshes(ctx context.Context, request ListRefreshesRequest) ([]MonitorRefreshInfo, error)

+ func (a *LakehouseMonitorsAPI) ListRefreshesByFullName(ctx context.Context, fullName string) ([]MonitorRefreshInfo, error)

+ func (a *LakehouseMonitorsAPI) RunRefresh(ctx context.Context, request RunRefreshRequest) (*MonitorRefreshInfo, error)

type LakehouseMonitorsInterface

+ CancelRefresh func(ctx context.Context, request CancelRefreshRequest) error

+ GetRefresh func(ctx context.Context, request GetRefreshRequest) (*MonitorRefreshInfo, error)

+ GetRefreshByFullNameAndRefreshId func(ctx context.Context, fullName string, refreshId string) (*MonitorRefreshInfo, error)

+ ListRefreshes func(ctx context.Context, request ListRefreshesRequest) ([]MonitorRefreshInfo, error)

+ ListRefreshesByFullName func(ctx context.Context, fullName string) ([]MonitorRefreshInfo, error)

+ RunRefresh func(ctx context.Context, request RunRefreshRequest) (*MonitorRefreshInfo, error)

type LakehouseMonitorsService

+ CancelRefresh func(ctx context.Context, request CancelRefreshRequest) error

+ GetRefresh func(ctx context.Context, request GetRefreshRequest) (*MonitorRefreshInfo, error)

+ ListRefreshes func(ctx context.Context, request ListRefreshesRequest) ([]MonitorRefreshInfo, error)

+ RunRefresh func(ctx context.Context, request RunRefreshRequest) (*MonitorRefreshInfo, error)

+ type ListRefreshesRequest struct

+ FullName string

+ type MonitorRefreshInfo struct

+ EndTimeMs int64

+ ForceSendFields []string

+ Message string

+ RefreshId int64

+ StartTimeMs int64

+ State MonitorRefreshInfoState

+ func (s *MonitorRefreshInfo) UnmarshalJSON(b []byte) error

+ func (s MonitorRefreshInfo) MarshalJSON() ([]byte, error)

+ type MonitorRefreshInfoState string

+ const MonitorRefreshInfoStateCanceled

+ const MonitorRefreshInfoStateFailed

+ const MonitorRefreshInfoStatePending

+ const MonitorRefreshInfoStateRunning

+ const MonitorRefreshInfoStateSuccess

+ func (f *MonitorRefreshInfoState) Set(v string) error

+ func (f *MonitorRefreshInfoState) String() string

+ func (f *MonitorRefreshInfoState) Type() string

+ type RunRefreshRequest struct

+ FullName string

v0.30.1

Jan 25, 2024

v0.30.0

Jan 24, 2024

Changes in this version

+ type CreateMonitor struct

+ AssetsDir string

+ BaselineTableName string

+ CustomMetrics []MonitorCustomMetric

+ DataClassificationConfig *MonitorDataClassificationConfig

+ ForceSendFields []string

+ FullName string

+ InferenceLog *MonitorInferenceLogProfileType

+ Notifications []MonitorNotificationsConfig

+ OutputSchemaName string

+ Schedule *MonitorCronSchedule

+ SkipBuiltinDashboard bool

+ SlicingExprs []string

+ Snapshot any

+ TimeSeries *MonitorTimeSeriesProfileType

+ WarehouseId string

+ func (s *CreateMonitor) UnmarshalJSON(b []byte) error

+ func (s CreateMonitor) MarshalJSON() ([]byte, error)

+ type DeleteLakehouseMonitorRequest struct

+ FullName string

+ type ExistsRequest struct

+ FullName string

+ type GetLakehouseMonitorRequest struct

+ FullName string

+ type LakehouseMonitorsAPI struct

+ func NewLakehouseMonitors(client *client.DatabricksClient) *LakehouseMonitorsAPI

+ func (a *LakehouseMonitorsAPI) Create(ctx context.Context, request CreateMonitor) (*MonitorInfo, error)

+ func (a *LakehouseMonitorsAPI) Delete(ctx context.Context, request DeleteLakehouseMonitorRequest) error

+ func (a *LakehouseMonitorsAPI) DeleteByFullName(ctx context.Context, fullName string) error

+ func (a *LakehouseMonitorsAPI) Get(ctx context.Context, request GetLakehouseMonitorRequest) (*MonitorInfo, error)

+ func (a *LakehouseMonitorsAPI) GetByFullName(ctx context.Context, fullName string) (*MonitorInfo, error)

+ func (a *LakehouseMonitorsAPI) Impl() LakehouseMonitorsService

+ func (a *LakehouseMonitorsAPI) Update(ctx context.Context, request UpdateMonitor) (*MonitorInfo, error)

+ func (a *LakehouseMonitorsAPI) WithImpl(impl LakehouseMonitorsService) LakehouseMonitorsInterface

+ type LakehouseMonitorsInterface interface

+ Create func(ctx context.Context, request CreateMonitor) (*MonitorInfo, error)

+ Delete func(ctx context.Context, request DeleteLakehouseMonitorRequest) error

+ DeleteByFullName func(ctx context.Context, fullName string) error

+ Get func(ctx context.Context, request GetLakehouseMonitorRequest) (*MonitorInfo, error)

+ GetByFullName func(ctx context.Context, fullName string) (*MonitorInfo, error)

+ Impl func() LakehouseMonitorsService

+ Update func(ctx context.Context, request UpdateMonitor) (*MonitorInfo, error)

+ WithImpl func(impl LakehouseMonitorsService) LakehouseMonitorsInterface

+ type LakehouseMonitorsService interface

+ Create func(ctx context.Context, request CreateMonitor) (*MonitorInfo, error)

+ Delete func(ctx context.Context, request DeleteLakehouseMonitorRequest) error

+ Get func(ctx context.Context, request GetLakehouseMonitorRequest) (*MonitorInfo, error)

+ Update func(ctx context.Context, request UpdateMonitor) (*MonitorInfo, error)

+ type MonitorCronSchedule struct

+ ForceSendFields []string

+ PauseStatus MonitorCronSchedulePauseStatus

+ QuartzCronExpression string

+ TimezoneId string

+ func (s *MonitorCronSchedule) UnmarshalJSON(b []byte) error

+ func (s MonitorCronSchedule) MarshalJSON() ([]byte, error)

+ type MonitorCronSchedulePauseStatus string

+ const MonitorCronSchedulePauseStatusPaused

+ const MonitorCronSchedulePauseStatusUnpaused

+ func (f *MonitorCronSchedulePauseStatus) Set(v string) error

+ func (f *MonitorCronSchedulePauseStatus) String() string

+ func (f *MonitorCronSchedulePauseStatus) Type() string

+ type MonitorCustomMetric struct

+ Definition string

+ ForceSendFields []string

+ InputColumns []string

+ Name string

+ OutputDataType string

+ Type MonitorCustomMetricType

+ func (s *MonitorCustomMetric) UnmarshalJSON(b []byte) error

+ func (s MonitorCustomMetric) MarshalJSON() ([]byte, error)

+ type MonitorCustomMetricType string

+ const MonitorCustomMetricTypeCustomMetricTypeAggregate

+ const MonitorCustomMetricTypeCustomMetricTypeDerived

+ const MonitorCustomMetricTypeCustomMetricTypeDrift

+ const MonitorCustomMetricTypeMonitorStatusError

+ const MonitorCustomMetricTypeMonitorStatusFailed

+ func (f *MonitorCustomMetricType) Set(v string) error

+ func (f *MonitorCustomMetricType) String() string

+ func (f *MonitorCustomMetricType) Type() string

+ type MonitorDataClassificationConfig struct

+ Enabled bool

+ ForceSendFields []string

+ func (s *MonitorDataClassificationConfig) UnmarshalJSON(b []byte) error

+ func (s MonitorDataClassificationConfig) MarshalJSON() ([]byte, error)

+ type MonitorDestinations struct

+ EmailAddresses []string

+ type MonitorInferenceLogProfileType struct

+ ForceSendFields []string

+ Granularities []string

+ LabelCol string

+ ModelIdCol string

+ PredictionCol string

+ PredictionProbaCol string

+ ProblemType MonitorInferenceLogProfileTypeProblemType

+ TimestampCol string

+ func (s *MonitorInferenceLogProfileType) UnmarshalJSON(b []byte) error

+ func (s MonitorInferenceLogProfileType) MarshalJSON() ([]byte, error)

+ type MonitorInferenceLogProfileTypeProblemType string

+ const MonitorInferenceLogProfileTypeProblemTypeProblemTypeClassification

+ const MonitorInferenceLogProfileTypeProblemTypeProblemTypeRegression

+ func (f *MonitorInferenceLogProfileTypeProblemType) Set(v string) error

+ func (f *MonitorInferenceLogProfileTypeProblemType) String() string

+ func (f *MonitorInferenceLogProfileTypeProblemType) Type() string

+ type MonitorInfo struct

+ AssetsDir string

+ BaselineTableName string

+ CustomMetrics []MonitorCustomMetric

+ DashboardId string

+ DataClassificationConfig *MonitorDataClassificationConfig

+ DriftMetricsTableName string

+ ForceSendFields []string

+ InferenceLog *MonitorInferenceLogProfileType

+ LatestMonitorFailureMsg string

+ MonitorVersion string

+ Notifications []MonitorNotificationsConfig

+ OutputSchemaName string

+ ProfileMetricsTableName string

+ Schedule *MonitorCronSchedule

+ SlicingExprs []string

+ Snapshot any

+ Status MonitorInfoStatus

+ TableName string

+ TimeSeries *MonitorTimeSeriesProfileType

+ func (s *MonitorInfo) UnmarshalJSON(b []byte) error

+ func (s MonitorInfo) MarshalJSON() ([]byte, error)

+ type MonitorInfoStatus string

+ const MonitorInfoStatusMonitorStatusActive

+ const MonitorInfoStatusMonitorStatusDeletePending

+ const MonitorInfoStatusMonitorStatusError

+ const MonitorInfoStatusMonitorStatusFailed

+ const MonitorInfoStatusMonitorStatusPending

+ func (f *MonitorInfoStatus) Set(v string) error

+ func (f *MonitorInfoStatus) String() string

+ func (f *MonitorInfoStatus) Type() string

+ type MonitorNotificationsConfig struct

+ OnFailure *MonitorDestinations

+ type MonitorTimeSeriesProfileType struct

+ ForceSendFields []string

+ Granularities []string

+ TimestampCol string

+ func (s *MonitorTimeSeriesProfileType) UnmarshalJSON(b []byte) error

+ func (s MonitorTimeSeriesProfileType) MarshalJSON() ([]byte, error)

+ type TableExistsResponse struct

+ ForceSendFields []string

+ TableExists bool

+ func (s *TableExistsResponse) UnmarshalJSON(b []byte) error

+ func (s TableExistsResponse) MarshalJSON() ([]byte, error)

type TablesAPI

+ func (a *TablesAPI) Exists(ctx context.Context, request ExistsRequest) (*TableExistsResponse, error)

+ func (a *TablesAPI) ExistsByFullName(ctx context.Context, fullName string) (*TableExistsResponse, error)

type TablesInterface

+ Exists func(ctx context.Context, request ExistsRequest) (*TableExistsResponse, error)

+ ExistsByFullName func(ctx context.Context, fullName string) (*TableExistsResponse, error)

type TablesService

+ Exists func(ctx context.Context, request ExistsRequest) (*TableExistsResponse, error)

+ type UpdateMonitor struct

+ AssetsDir string

+ BaselineTableName string

+ CustomMetrics []MonitorCustomMetric

+ DataClassificationConfig *MonitorDataClassificationConfig

+ ForceSendFields []string

+ FullName string

+ InferenceLog *MonitorInferenceLogProfileType

+ Notifications []MonitorNotificationsConfig

+ OutputSchemaName string

+ Schedule *MonitorCronSchedule

+ SlicingExprs []string

+ Snapshot any

+ TimeSeries *MonitorTimeSeriesProfileType

+ func (s *UpdateMonitor) UnmarshalJSON(b []byte) error

+ func (s UpdateMonitor) MarshalJSON() ([]byte, error)

v0.29.1

Jan 16, 2024

v0.29.0

Jan 10, 2024

Changes in this version

+ type AccountMetastoreAssignmentsInterface interface

+ Create func(ctx context.Context, request AccountsCreateMetastoreAssignment) error

+ Delete func(ctx context.Context, request DeleteAccountMetastoreAssignmentRequest) error

+ DeleteByWorkspaceIdAndMetastoreId func(ctx context.Context, workspaceId int64, metastoreId string) error

+ Get func(ctx context.Context, request GetAccountMetastoreAssignmentRequest) (*AccountsMetastoreAssignment, error)

+ GetByWorkspaceId func(ctx context.Context, workspaceId int64) (*AccountsMetastoreAssignment, error)

+ Impl func() AccountMetastoreAssignmentsService

+ List func(ctx context.Context, request ListAccountMetastoreAssignmentsRequest) ...

+ ListAll func(ctx context.Context, request ListAccountMetastoreAssignmentsRequest) ([]int64, error)

+ ListByMetastoreId func(ctx context.Context, metastoreId string) (*ListAccountMetastoreAssignmentsResponse, error)

+ Update func(ctx context.Context, request AccountsUpdateMetastoreAssignment) error

+ WithImpl func(impl AccountMetastoreAssignmentsService) AccountMetastoreAssignmentsInterface

+ type AccountMetastoresInterface interface

+ Create func(ctx context.Context, request AccountsCreateMetastore) (*AccountsMetastoreInfo, error)

+ Delete func(ctx context.Context, request DeleteAccountMetastoreRequest) error

+ DeleteByMetastoreId func(ctx context.Context, metastoreId string) error

+ Get func(ctx context.Context, request GetAccountMetastoreRequest) (*AccountsMetastoreInfo, error)

+ GetByMetastoreId func(ctx context.Context, metastoreId string) (*AccountsMetastoreInfo, error)

+ Impl func() AccountMetastoresService

+ List func(ctx context.Context) *listing.PaginatingIterator[struct{}, *ListMetastoresResponse, MetastoreInfo]

+ ListAll func(ctx context.Context) ([]MetastoreInfo, error)

+ Update func(ctx context.Context, request AccountsUpdateMetastore) (*AccountsMetastoreInfo, error)

+ WithImpl func(impl AccountMetastoresService) AccountMetastoresInterface

+ type AccountStorageCredentialsInterface interface

+ Create func(ctx context.Context, request AccountsCreateStorageCredential) (*AccountsStorageCredentialInfo, error)

+ Delete func(ctx context.Context, request DeleteAccountStorageCredentialRequest) error

+ DeleteByMetastoreIdAndStorageCredentialName func(ctx context.Context, metastoreId string, storageCredentialName string) error

+ Get func(ctx context.Context, request GetAccountStorageCredentialRequest) (*AccountsStorageCredentialInfo, error)

+ GetByMetastoreIdAndStorageCredentialName func(ctx context.Context, metastoreId string, storageCredentialName string) (*AccountsStorageCredentialInfo, error)

+ GetByName func(ctx context.Context, name string) (*StorageCredentialInfo, error)

+ Impl func() AccountStorageCredentialsService

+ List func(ctx context.Context, request ListAccountStorageCredentialsRequest) ([]StorageCredentialInfo, error)

+ ListByMetastoreId func(ctx context.Context, metastoreId string) ([]StorageCredentialInfo, error)

+ StorageCredentialInfoNameToIdMap func(ctx context.Context, request ListAccountStorageCredentialsRequest) (map[string]string, error)

+ Update func(ctx context.Context, request AccountsUpdateStorageCredential) (*AccountsStorageCredentialInfo, error)

+ WithImpl func(impl AccountStorageCredentialsService) AccountStorageCredentialsInterface

+ type ArtifactAllowlistsInterface interface

+ Get func(ctx context.Context, request GetArtifactAllowlistRequest) (*ArtifactAllowlistInfo, error)

+ GetByArtifactType func(ctx context.Context, artifactType ArtifactType) (*ArtifactAllowlistInfo, error)

+ Impl func() ArtifactAllowlistsService

+ Update func(ctx context.Context, request SetArtifactAllowlist) (*ArtifactAllowlistInfo, error)

+ WithImpl func(impl ArtifactAllowlistsService) ArtifactAllowlistsInterface

+ type CatalogsInterface interface

+ Create func(ctx context.Context, request CreateCatalog) (*CatalogInfo, error)

+ Delete func(ctx context.Context, request DeleteCatalogRequest) error

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

+ Get func(ctx context.Context, request GetCatalogRequest) (*CatalogInfo, error)

+ GetByName func(ctx context.Context, name string) (*CatalogInfo, error)

+ Impl func() CatalogsService

+ List func(ctx context.Context) *listing.PaginatingIterator[struct{}, *ListCatalogsResponse, CatalogInfo]

+ ListAll func(ctx context.Context) ([]CatalogInfo, error)

+ Update func(ctx context.Context, request UpdateCatalog) (*CatalogInfo, error)

+ WithImpl func(impl CatalogsService) CatalogsInterface

+ type ConnectionsInterface interface

+ ConnectionInfoNameToFullNameMap func(ctx context.Context) (map[string]string, error)

+ Create func(ctx context.Context, request CreateConnection) (*ConnectionInfo, error)

+ Delete func(ctx context.Context, request DeleteConnectionRequest) error

+ DeleteByNameArg func(ctx context.Context, nameArg string) error

+ Get func(ctx context.Context, request GetConnectionRequest) (*ConnectionInfo, error)

+ GetByName func(ctx context.Context, name string) (*ConnectionInfo, error)

+ GetByNameArg func(ctx context.Context, nameArg string) (*ConnectionInfo, error)

+ Impl func() ConnectionsService

+ List func(ctx context.Context) ...

+ ListAll func(ctx context.Context) ([]ConnectionInfo, error)

+ Update func(ctx context.Context, request UpdateConnection) (*ConnectionInfo, error)

+ WithImpl func(impl ConnectionsService) ConnectionsInterface

+ type ExternalLocationsInterface interface

+ Create func(ctx context.Context, request CreateExternalLocation) (*ExternalLocationInfo, error)

+ Delete func(ctx context.Context, request DeleteExternalLocationRequest) error

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

+ Get func(ctx context.Context, request GetExternalLocationRequest) (*ExternalLocationInfo, error)

+ GetByName func(ctx context.Context, name string) (*ExternalLocationInfo, error)

+ Impl func() ExternalLocationsService

+ List func(ctx context.Context, request ListExternalLocationsRequest) ...

+ ListAll func(ctx context.Context, request ListExternalLocationsRequest) ([]ExternalLocationInfo, error)

+ Update func(ctx context.Context, request UpdateExternalLocation) (*ExternalLocationInfo, error)

+ WithImpl func(impl ExternalLocationsService) ExternalLocationsInterface

+ type FunctionsInterface interface

+ Create func(ctx context.Context, request CreateFunctionRequest) (*FunctionInfo, error)

+ Delete func(ctx context.Context, request DeleteFunctionRequest) error

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

+ FunctionInfoNameToFullNameMap func(ctx context.Context, request ListFunctionsRequest) (map[string]string, error)

+ Get func(ctx context.Context, request GetFunctionRequest) (*FunctionInfo, error)

+ GetByName func(ctx context.Context, name string) (*FunctionInfo, error)

+ Impl func() FunctionsService

+ List func(ctx context.Context, request ListFunctionsRequest) ...

+ ListAll func(ctx context.Context, request ListFunctionsRequest) ([]FunctionInfo, error)

+ Update func(ctx context.Context, request UpdateFunction) (*FunctionInfo, error)

+ WithImpl func(impl FunctionsService) FunctionsInterface

+ type GrantsInterface interface

+ Get func(ctx context.Context, request GetGrantRequest) (*PermissionsList, error)

+ GetBySecurableTypeAndFullName func(ctx context.Context, securableType SecurableType, fullName string) (*PermissionsList, error)

+ GetEffective func(ctx context.Context, request GetEffectiveRequest) (*EffectivePermissionsList, error)

+ GetEffectiveBySecurableTypeAndFullName func(ctx context.Context, securableType SecurableType, fullName string) (*EffectivePermissionsList, error)

+ Impl func() GrantsService

+ Update func(ctx context.Context, request UpdatePermissions) (*PermissionsList, error)

+ WithImpl func(impl GrantsService) GrantsInterface

+ type ListExternalLocationsRequest struct

+ ForceSendFields []string

+ MaxResults int

+ PageToken string

+ func (s *ListExternalLocationsRequest) UnmarshalJSON(b []byte) error

+ func (s ListExternalLocationsRequest) MarshalJSON() ([]byte, error)

type ListExternalLocationsResponse

+ ForceSendFields []string

+ NextPageToken string

+ func (s *ListExternalLocationsResponse) UnmarshalJSON(b []byte) error

+ func (s ListExternalLocationsResponse) MarshalJSON() ([]byte, error)

type ListFunctionsRequest

+ ForceSendFields []string

+ MaxResults int

+ PageToken string

+ func (s *ListFunctionsRequest) UnmarshalJSON(b []byte) error

+ func (s ListFunctionsRequest) MarshalJSON() ([]byte, error)

type ListFunctionsResponse

+ ForceSendFields []string

+ NextPageToken string

+ func (s *ListFunctionsResponse) UnmarshalJSON(b []byte) error

+ func (s ListFunctionsResponse) MarshalJSON() ([]byte, error)

type ListSchemasRequest

+ ForceSendFields []string

+ MaxResults int

+ PageToken string

+ func (s *ListSchemasRequest) UnmarshalJSON(b []byte) error

+ func (s ListSchemasRequest) MarshalJSON() ([]byte, error)

type ListSchemasResponse

+ ForceSendFields []string

+ NextPageToken string

+ func (s *ListSchemasResponse) UnmarshalJSON(b []byte) error

+ func (s ListSchemasResponse) MarshalJSON() ([]byte, error)

+ type ListStorageCredentialsRequest struct

+ ForceSendFields []string

+ MaxResults int

+ PageToken string

+ func (s *ListStorageCredentialsRequest) UnmarshalJSON(b []byte) error

+ func (s ListStorageCredentialsRequest) MarshalJSON() ([]byte, error)

type ListStorageCredentialsResponse

+ ForceSendFields []string

+ NextPageToken string

+ func (s *ListStorageCredentialsResponse) UnmarshalJSON(b []byte) error

+ func (s ListStorageCredentialsResponse) MarshalJSON() ([]byte, error)

type ListTablesRequest

+ OmitColumns bool

+ OmitProperties bool

+ type MetastoresInterface interface

+ Assign func(ctx context.Context, request CreateMetastoreAssignment) error

+ Create func(ctx context.Context, request CreateMetastore) (*MetastoreInfo, error)

+ Current func(ctx context.Context) (*MetastoreAssignment, error)

+ Delete func(ctx context.Context, request DeleteMetastoreRequest) error

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

+ Get func(ctx context.Context, request GetMetastoreRequest) (*MetastoreInfo, error)

+ GetById func(ctx context.Context, id string) (*MetastoreInfo, error)

+ GetByName func(ctx context.Context, name string) (*MetastoreInfo, error)

+ Impl func() MetastoresService

+ List func(ctx context.Context) *listing.PaginatingIterator[struct{}, *ListMetastoresResponse, MetastoreInfo]

+ ListAll func(ctx context.Context) ([]MetastoreInfo, error)

+ MetastoreInfoNameToMetastoreIdMap func(ctx context.Context) (map[string]string, error)

+ Summary func(ctx context.Context) (*GetMetastoreSummaryResponse, error)

+ Unassign func(ctx context.Context, request UnassignRequest) error

+ UnassignByWorkspaceId func(ctx context.Context, workspaceId int64) error

+ Update func(ctx context.Context, request UpdateMetastore) (*MetastoreInfo, error)

+ UpdateAssignment func(ctx context.Context, request UpdateMetastoreAssignment) error

+ WithImpl func(impl MetastoresService) MetastoresInterface

+ type ModelVersionsInterface interface

+ Delete func(ctx context.Context, request DeleteModelVersionRequest) error

+ DeleteByFullNameAndVersion func(ctx context.Context, fullName string, version int) error

+ Get func(ctx context.Context, request GetModelVersionRequest) (*RegisteredModelInfo, error)

+ GetByAlias func(ctx context.Context, request GetByAliasRequest) (*ModelVersionInfo, error)

+ GetByAliasByFullNameAndAlias func(ctx context.Context, fullName string, alias string) (*ModelVersionInfo, error)

+ GetByFullNameAndVersion func(ctx context.Context, fullName string, version int) (*RegisteredModelInfo, error)

+ Impl func() ModelVersionsService

+ List func(ctx context.Context, request ListModelVersionsRequest) ...

+ ListAll func(ctx context.Context, request ListModelVersionsRequest) ([]ModelVersionInfo, error)

+ ListByFullName func(ctx context.Context, fullName string) (*ListModelVersionsResponse, error)

+ Update func(ctx context.Context, request UpdateModelVersionRequest) (*ModelVersionInfo, error)

+ WithImpl func(impl ModelVersionsService) ModelVersionsInterface

+ type RegisteredModelsInterface interface

+ Create func(ctx context.Context, request CreateRegisteredModelRequest) (*RegisteredModelInfo, error)

+ Delete func(ctx context.Context, request DeleteRegisteredModelRequest) error

+ DeleteAlias func(ctx context.Context, request DeleteAliasRequest) error

+ DeleteAliasByFullNameAndAlias func(ctx context.Context, fullName string, alias string) error

+ DeleteByFullName func(ctx context.Context, fullName string) error

+ Get func(ctx context.Context, request GetRegisteredModelRequest) (*RegisteredModelInfo, error)

+ GetByFullName func(ctx context.Context, fullName string) (*RegisteredModelInfo, error)

+ GetByName func(ctx context.Context, name string) (*RegisteredModelInfo, error)

+ Impl func() RegisteredModelsService

+ List func(ctx context.Context, request ListRegisteredModelsRequest) ...

+ ListAll func(ctx context.Context, request ListRegisteredModelsRequest) ([]RegisteredModelInfo, error)

+ RegisteredModelInfoNameToFullNameMap func(ctx context.Context, request ListRegisteredModelsRequest) (map[string]string, error)

+ SetAlias func(ctx context.Context, request SetRegisteredModelAliasRequest) (*RegisteredModelAlias, error)

+ Update func(ctx context.Context, request UpdateRegisteredModelRequest) (*RegisteredModelInfo, error)

+ WithImpl func(impl RegisteredModelsService) RegisteredModelsInterface

+ type SchemasInterface interface

+ Create func(ctx context.Context, request CreateSchema) (*SchemaInfo, error)

+ Delete func(ctx context.Context, request DeleteSchemaRequest) error

+ DeleteByFullName func(ctx context.Context, fullName string) error

+ Get func(ctx context.Context, request GetSchemaRequest) (*SchemaInfo, error)

+ GetByFullName func(ctx context.Context, fullName string) (*SchemaInfo, error)

+ GetByName func(ctx context.Context, name string) (*SchemaInfo, error)

+ Impl func() SchemasService

+ List func(ctx context.Context, request ListSchemasRequest) ...

+ ListAll func(ctx context.Context, request ListSchemasRequest) ([]SchemaInfo, error)

+ SchemaInfoNameToFullNameMap func(ctx context.Context, request ListSchemasRequest) (map[string]string, error)

+ Update func(ctx context.Context, request UpdateSchema) (*SchemaInfo, error)

+ WithImpl func(impl SchemasService) SchemasInterface

+ type StorageCredentialsInterface interface

+ Create func(ctx context.Context, request CreateStorageCredential) (*StorageCredentialInfo, error)

+ Delete func(ctx context.Context, request DeleteStorageCredentialRequest) error

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

+ Get func(ctx context.Context, request GetStorageCredentialRequest) (*StorageCredentialInfo, error)

+ GetByName func(ctx context.Context, name string) (*StorageCredentialInfo, error)

+ Impl func() StorageCredentialsService

+ List func(ctx context.Context, request ListStorageCredentialsRequest) ...

+ ListAll func(ctx context.Context, request ListStorageCredentialsRequest) ([]StorageCredentialInfo, error)

+ StorageCredentialInfoNameToIdMap func(ctx context.Context, request ListStorageCredentialsRequest) (map[string]string, error)

+ Update func(ctx context.Context, request UpdateStorageCredential) (*StorageCredentialInfo, error)

+ Validate func(ctx context.Context, request ValidateStorageCredential) (*ValidateStorageCredentialResponse, error)

+ WithImpl func(impl StorageCredentialsService) StorageCredentialsInterface

+ type SystemSchemasInterface interface

+ Disable func(ctx context.Context, request DisableRequest) error

+ DisableByMetastoreIdAndSchemaName func(ctx context.Context, metastoreId string, schemaName DisableSchemaName) error

+ Enable func(ctx context.Context, request EnableRequest) error

+ Impl func() SystemSchemasService

+ List func(ctx context.Context, request ListSystemSchemasRequest) ...

+ ListAll func(ctx context.Context, request ListSystemSchemasRequest) ([]SystemSchemaInfo, error)

+ ListByMetastoreId func(ctx context.Context, metastoreId string) (*ListSystemSchemasResponse, error)

+ WithImpl func(impl SystemSchemasService) SystemSchemasInterface

+ type TableConstraintsInterface interface

+ Create func(ctx context.Context, request CreateTableConstraint) (*TableConstraint, error)

+ Delete func(ctx context.Context, request DeleteTableConstraintRequest) error

+ DeleteByFullName func(ctx context.Context, fullName string) error

+ Impl func() TableConstraintsService

+ WithImpl func(impl TableConstraintsService) TableConstraintsInterface

+ type TablesInterface interface

+ Delete func(ctx context.Context, request DeleteTableRequest) error

+ DeleteByFullName func(ctx context.Context, fullName string) error

+ Get func(ctx context.Context, request GetTableRequest) (*TableInfo, error)

+ GetByFullName func(ctx context.Context, fullName string) (*TableInfo, error)

+ GetByName func(ctx context.Context, name string) (*TableInfo, error)

+ Impl func() TablesService

+ List func(ctx context.Context, request ListTablesRequest) *listing.PaginatingIterator[ListTablesRequest, *ListTablesResponse, TableInfo]

+ ListAll func(ctx context.Context, request ListTablesRequest) ([]TableInfo, error)

+ ListSummaries func(ctx context.Context, request ListSummariesRequest) ...

+ ListSummariesAll func(ctx context.Context, request ListSummariesRequest) ([]TableSummary, error)

+ TableInfoNameToTableIdMap func(ctx context.Context, request ListTablesRequest) (map[string]string, error)

+ Update func(ctx context.Context, request UpdateTableRequest) error

+ WithImpl func(impl TablesService) TablesInterface

+ type VolumesInterface interface

+ Create func(ctx context.Context, request CreateVolumeRequestContent) (*VolumeInfo, error)

+ Delete func(ctx context.Context, request DeleteVolumeRequest) error

+ DeleteByFullNameArg func(ctx context.Context, fullNameArg string) error

+ GetByName func(ctx context.Context, name string) (*VolumeInfo, error)

+ Impl func() VolumesService

+ List func(ctx context.Context, request ListVolumesRequest) ...

+ ListAll func(ctx context.Context, request ListVolumesRequest) ([]VolumeInfo, error)

+ Read func(ctx context.Context, request ReadVolumeRequest) (*VolumeInfo, error)

+ ReadByFullNameArg func(ctx context.Context, fullNameArg string) (*VolumeInfo, error)

+ Update func(ctx context.Context, request UpdateVolumeRequestContent) (*VolumeInfo, error)

+ VolumeInfoNameToVolumeIdMap func(ctx context.Context, request ListVolumesRequest) (map[string]string, error)

+ WithImpl func(impl VolumesService) VolumesInterface

+ type WorkspaceBindingsInterface interface

+ Get func(ctx context.Context, request GetWorkspaceBindingRequest) (*CurrentWorkspaceBindings, error)

+ GetBindings func(ctx context.Context, request GetBindingsRequest) (*WorkspaceBindingsResponse, error)

+ GetBindingsBySecurableTypeAndSecurableName func(ctx context.Context, securableType string, securableName string) (*WorkspaceBindingsResponse, error)

+ GetByName func(ctx context.Context, name string) (*CurrentWorkspaceBindings, error)

+ Impl func() WorkspaceBindingsService

+ Update func(ctx context.Context, request UpdateWorkspaceBindings) (*CurrentWorkspaceBindings, error)

+ UpdateBindings func(ctx context.Context, request UpdateWorkspaceBindingsParameters) (*WorkspaceBindingsResponse, error)

+ WithImpl func(impl WorkspaceBindingsService) WorkspaceBindingsInterface

v0.28.0

Dec 15, 2023

v0.27.0

Dec 12, 2023

Changes in this version

+ type CloudflareApiToken struct

+ AccessKeyId string

+ AccountId string

+ SecretAccessKey string

type CreateStorageCredential

+ CloudflareApiToken *CloudflareApiToken

type StorageCredentialInfo

+ CloudflareApiToken *CloudflareApiToken

type UpdateCatalog

+ NewName string

type UpdateConnection

+ NewName string

type UpdateExternalLocation

+ NewName string

type UpdateMetastore

+ NewName string

type UpdateRegisteredModelRequest

+ NewName string

type UpdateSchema

+ NewName string

type UpdateStorageCredential

+ CloudflareApiToken *CloudflareApiToken

+ NewName string

type UpdateVolumeRequestContent

+ NewName string

type ValidateStorageCredential

+ CloudflareApiToken *CloudflareApiToken

v0.26.2

Dec 7, 2023

v0.26.1

Nov 30, 2023

v0.26.0

Nov 29, 2023

Changes in this version

type TableInfo

+ PipelineId string

type UpdateCatalog

+ EnablePredictiveOptimization EnablePredictiveOptimization

type UpdateSchema

+ EnablePredictiveOptimization EnablePredictiveOptimization

v0.25.0

Nov 10, 2023

Changes in this version

+ type CreateFunctionRequest struct

+ FunctionInfo CreateFunction

+ type DependencyList struct

+ Dependencies []Dependency

+ type FunctionParameterInfos struct

+ Parameters []FunctionParameterInfo

type UpdateExternalLocation

+ SkipValidation bool

v0.24.0

Oct 24, 2023

Changes in this version

type CatalogsAPI

+ func (a *CatalogsAPI) List(ctx context.Context) *listing.PaginatingIterator[struct{}, *ListCatalogsResponse, CatalogInfo]

type ConnectionsAPI

+ func (a *ConnectionsAPI) List(ctx context.Context) ...

type ExternalLocationsAPI

+ func (a *ExternalLocationsAPI) List(ctx context.Context) ...

type MetastoresAPI

+ func (a *MetastoresAPI) List(ctx context.Context) *listing.PaginatingIterator[struct{}, *ListMetastoresResponse, MetastoreInfo]

type ModelVersionsAPI

+ func (a *ModelVersionsAPI) List(ctx context.Context, request ListModelVersionsRequest) ...

type Privilege

+ const PrivilegeCreateExternalVolume

+ const PrivilegeCreateVolume

+ const PrivilegeReadVolume

+ const PrivilegeWriteVolume

type RegisteredModelsAPI

+ func (a *RegisteredModelsAPI) List(ctx context.Context, request ListRegisteredModelsRequest) ...

type SchemasAPI

+ func (a *SchemasAPI) List(ctx context.Context, request ListSchemasRequest) ...

type SystemSchemasAPI

+ func (a *SystemSchemasAPI) List(ctx context.Context, request ListSystemSchemasRequest) ...

type TablesAPI

+ func (a *TablesAPI) List(ctx context.Context, request ListTablesRequest) *listing.PaginatingIterator[ListTablesRequest, *ListTablesResponse, TableInfo]

type VolumesAPI

+ func (a *VolumesAPI) List(ctx context.Context, request ListVolumesRequest) ...

v0.23.0

Oct 12, 2023

Changes in this version

type AccountStorageCredentialsAPI

+ func (a *AccountStorageCredentialsAPI) DeleteByMetastoreIdAndStorageCredentialName(ctx context.Context, metastoreId string, storageCredentialName string) error

+ func (a *AccountStorageCredentialsAPI) GetByMetastoreIdAndStorageCredentialName(ctx context.Context, metastoreId string, storageCredentialName string) (*AccountsStorageCredentialInfo, error)

type AccountsUpdateStorageCredential

+ StorageCredentialName string

type ArtifactAllowlistInfo

+ ForceSendFields []string

+ func (s *ArtifactAllowlistInfo) UnmarshalJSON(b []byte) error

+ func (s ArtifactAllowlistInfo) MarshalJSON() ([]byte, error)

type AwsIamRole

+ ForceSendFields []string

+ func (s *AwsIamRole) UnmarshalJSON(b []byte) error

+ func (s AwsIamRole) MarshalJSON() ([]byte, error)

type AzureManagedIdentity

+ ForceSendFields []string

+ func (s *AzureManagedIdentity) UnmarshalJSON(b []byte) error

+ func (s AzureManagedIdentity) MarshalJSON() ([]byte, error)

type CatalogInfo

+ ForceSendFields []string

+ func (s *CatalogInfo) UnmarshalJSON(b []byte) error

+ func (s CatalogInfo) MarshalJSON() ([]byte, error)

type ColumnInfo

+ ForceSendFields []string

+ func (s *ColumnInfo) UnmarshalJSON(b []byte) error

+ func (s ColumnInfo) MarshalJSON() ([]byte, error)

type ColumnMask

+ ForceSendFields []string

+ func (s *ColumnMask) UnmarshalJSON(b []byte) error

+ func (s ColumnMask) MarshalJSON() ([]byte, error)

type ConnectionInfo

+ ForceSendFields []string

+ func (s *ConnectionInfo) UnmarshalJSON(b []byte) error

+ func (s ConnectionInfo) MarshalJSON() ([]byte, error)

type CreateCatalog

+ ForceSendFields []string

+ func (s *CreateCatalog) UnmarshalJSON(b []byte) error

+ func (s CreateCatalog) MarshalJSON() ([]byte, error)

type CreateConnection

+ ForceSendFields []string

+ func (s *CreateConnection) UnmarshalJSON(b []byte) error

+ func (s CreateConnection) MarshalJSON() ([]byte, error)

type CreateExternalLocation

+ ForceSendFields []string

+ func (s *CreateExternalLocation) UnmarshalJSON(b []byte) error

+ func (s CreateExternalLocation) MarshalJSON() ([]byte, error)

type CreateFunction

+ ForceSendFields []string

+ func (s *CreateFunction) UnmarshalJSON(b []byte) error

+ func (s CreateFunction) MarshalJSON() ([]byte, error)

type CreateMetastore

+ ForceSendFields []string

+ func (s *CreateMetastore) UnmarshalJSON(b []byte) error

+ func (s CreateMetastore) MarshalJSON() ([]byte, error)

type CreateRegisteredModelRequest

+ ForceSendFields []string

+ func (s *CreateRegisteredModelRequest) UnmarshalJSON(b []byte) error

+ func (s CreateRegisteredModelRequest) MarshalJSON() ([]byte, error)

type CreateSchema

+ ForceSendFields []string

+ func (s *CreateSchema) UnmarshalJSON(b []byte) error

+ func (s CreateSchema) MarshalJSON() ([]byte, error)

type CreateStorageCredential

+ ForceSendFields []string

+ func (s *CreateStorageCredential) UnmarshalJSON(b []byte) error

+ func (s CreateStorageCredential) MarshalJSON() ([]byte, error)

type CreateVolumeRequestContent

+ ForceSendFields []string

+ func (s *CreateVolumeRequestContent) UnmarshalJSON(b []byte) error

+ func (s CreateVolumeRequestContent) MarshalJSON() ([]byte, error)

type DatabricksGcpServiceAccountResponse

+ ForceSendFields []string

+ func (s *DatabricksGcpServiceAccountResponse) UnmarshalJSON(b []byte) error

+ func (s DatabricksGcpServiceAccountResponse) MarshalJSON() ([]byte, error)

type DeleteAccountMetastoreRequest

+ ForceSendFields []string

+ func (s *DeleteAccountMetastoreRequest) UnmarshalJSON(b []byte) error

+ func (s DeleteAccountMetastoreRequest) MarshalJSON() ([]byte, error)

type DeleteAccountStorageCredentialRequest

+ ForceSendFields []string

+ StorageCredentialName string

+ func (s *DeleteAccountStorageCredentialRequest) UnmarshalJSON(b []byte) error

+ func (s DeleteAccountStorageCredentialRequest) MarshalJSON() ([]byte, error)

type DeleteCatalogRequest

+ ForceSendFields []string

+ func (s *DeleteCatalogRequest) UnmarshalJSON(b []byte) error

+ func (s DeleteCatalogRequest) MarshalJSON() ([]byte, error)

type DeleteExternalLocationRequest

+ ForceSendFields []string

+ func (s *DeleteExternalLocationRequest) UnmarshalJSON(b []byte) error

+ func (s DeleteExternalLocationRequest) MarshalJSON() ([]byte, error)

type DeleteFunctionRequest

+ ForceSendFields []string

+ func (s *DeleteFunctionRequest) UnmarshalJSON(b []byte) error

+ func (s DeleteFunctionRequest) MarshalJSON() ([]byte, error)

type DeleteMetastoreRequest

+ ForceSendFields []string

+ func (s *DeleteMetastoreRequest) UnmarshalJSON(b []byte) error

+ func (s DeleteMetastoreRequest) MarshalJSON() ([]byte, error)

type DeleteStorageCredentialRequest

+ ForceSendFields []string

+ func (s *DeleteStorageCredentialRequest) UnmarshalJSON(b []byte) error

+ func (s DeleteStorageCredentialRequest) MarshalJSON() ([]byte, error)

type EffectivePredictiveOptimizationFlag

+ ForceSendFields []string

+ func (s *EffectivePredictiveOptimizationFlag) UnmarshalJSON(b []byte) error

+ func (s EffectivePredictiveOptimizationFlag) MarshalJSON() ([]byte, error)

type EffectivePrivilege

+ ForceSendFields []string

+ func (s *EffectivePrivilege) UnmarshalJSON(b []byte) error

+ func (s EffectivePrivilege) MarshalJSON() ([]byte, error)

type EffectivePrivilegeAssignment

+ ForceSendFields []string

+ func (s *EffectivePrivilegeAssignment) UnmarshalJSON(b []byte) error

+ func (s EffectivePrivilegeAssignment) MarshalJSON() ([]byte, error)

type ExternalLocationInfo

+ ForceSendFields []string

+ func (s *ExternalLocationInfo) UnmarshalJSON(b []byte) error

+ func (s ExternalLocationInfo) MarshalJSON() ([]byte, error)

type FunctionInfo

+ ForceSendFields []string

+ func (s *FunctionInfo) UnmarshalJSON(b []byte) error

+ func (s FunctionInfo) MarshalJSON() ([]byte, error)

type FunctionParameterInfo

+ ForceSendFields []string

+ func (s *FunctionParameterInfo) UnmarshalJSON(b []byte) error

+ func (s FunctionParameterInfo) MarshalJSON() ([]byte, error)

type GetAccountStorageCredentialRequest

+ StorageCredentialName string

+ type GetBindingsRequest struct

+ SecurableName string

+ SecurableType string

type GetEffectiveRequest

+ ForceSendFields []string

+ func (s *GetEffectiveRequest) UnmarshalJSON(b []byte) error

+ func (s GetEffectiveRequest) MarshalJSON() ([]byte, error)

type GetGrantRequest

+ ForceSendFields []string

+ func (s *GetGrantRequest) UnmarshalJSON(b []byte) error

+ func (s GetGrantRequest) MarshalJSON() ([]byte, error)

type GetMetastoreSummaryResponse

+ ForceSendFields []string

+ func (s *GetMetastoreSummaryResponse) UnmarshalJSON(b []byte) error

+ func (s GetMetastoreSummaryResponse) MarshalJSON() ([]byte, error)

type GetTableRequest

+ ForceSendFields []string

+ func (s *GetTableRequest) UnmarshalJSON(b []byte) error

+ func (s GetTableRequest) MarshalJSON() ([]byte, error)

type ListModelVersionsRequest

+ ForceSendFields []string

+ func (s *ListModelVersionsRequest) UnmarshalJSON(b []byte) error

+ func (s ListModelVersionsRequest) MarshalJSON() ([]byte, error)

type ListModelVersionsResponse

+ ForceSendFields []string

+ func (s *ListModelVersionsResponse) UnmarshalJSON(b []byte) error

+ func (s ListModelVersionsResponse) MarshalJSON() ([]byte, error)

type ListRegisteredModelsRequest

+ ForceSendFields []string

+ func (s *ListRegisteredModelsRequest) UnmarshalJSON(b []byte) error

+ func (s ListRegisteredModelsRequest) MarshalJSON() ([]byte, error)

type ListRegisteredModelsResponse

+ ForceSendFields []string

+ func (s *ListRegisteredModelsResponse) UnmarshalJSON(b []byte) error

+ func (s ListRegisteredModelsResponse) MarshalJSON() ([]byte, error)

type ListSummariesRequest

+ ForceSendFields []string

+ func (s *ListSummariesRequest) UnmarshalJSON(b []byte) error

+ func (s ListSummariesRequest) MarshalJSON() ([]byte, error)

type ListTableSummariesResponse

+ ForceSendFields []string

+ func (s *ListTableSummariesResponse) UnmarshalJSON(b []byte) error

+ func (s ListTableSummariesResponse) MarshalJSON() ([]byte, error)

type ListTablesRequest

+ ForceSendFields []string

+ func (s *ListTablesRequest) UnmarshalJSON(b []byte) error

+ func (s ListTablesRequest) MarshalJSON() ([]byte, error)

type ListTablesResponse

+ ForceSendFields []string

+ func (s *ListTablesResponse) UnmarshalJSON(b []byte) error

+ func (s ListTablesResponse) MarshalJSON() ([]byte, error)

type MetastoreAssignment

+ ForceSendFields []string

+ func (s *MetastoreAssignment) UnmarshalJSON(b []byte) error

+ func (s MetastoreAssignment) MarshalJSON() ([]byte, error)

type MetastoreInfo

+ ForceSendFields []string

+ func (s *MetastoreInfo) UnmarshalJSON(b []byte) error

+ func (s MetastoreInfo) MarshalJSON() ([]byte, error)

type ModelVersionInfo

+ ForceSendFields []string

+ func (s *ModelVersionInfo) UnmarshalJSON(b []byte) error

+ func (s ModelVersionInfo) MarshalJSON() ([]byte, error)

type PermissionsChange

+ ForceSendFields []string

+ func (s *PermissionsChange) UnmarshalJSON(b []byte) error

+ func (s PermissionsChange) MarshalJSON() ([]byte, error)

type PrivilegeAssignment

+ ForceSendFields []string

+ func (s *PrivilegeAssignment) UnmarshalJSON(b []byte) error

+ func (s PrivilegeAssignment) MarshalJSON() ([]byte, error)

type RegisteredModelAlias

+ ForceSendFields []string

+ func (s *RegisteredModelAlias) UnmarshalJSON(b []byte) error

+ func (s RegisteredModelAlias) MarshalJSON() ([]byte, error)

type RegisteredModelInfo

+ ForceSendFields []string

+ func (s *RegisteredModelInfo) UnmarshalJSON(b []byte) error

+ func (s RegisteredModelInfo) MarshalJSON() ([]byte, error)

type SchemaInfo

+ ForceSendFields []string

+ func (s *SchemaInfo) UnmarshalJSON(b []byte) error

+ func (s SchemaInfo) MarshalJSON() ([]byte, error)

type SseEncryptionDetails

+ ForceSendFields []string

+ func (s *SseEncryptionDetails) UnmarshalJSON(b []byte) error

+ func (s SseEncryptionDetails) MarshalJSON() ([]byte, error)

type StorageCredentialInfo

+ ForceSendFields []string

+ func (s *StorageCredentialInfo) UnmarshalJSON(b []byte) error

+ func (s StorageCredentialInfo) MarshalJSON() ([]byte, error)

type SystemSchemaInfo

+ ForceSendFields []string

+ func (s *SystemSchemaInfo) UnmarshalJSON(b []byte) error

+ func (s SystemSchemaInfo) MarshalJSON() ([]byte, error)

type TableInfo

+ ForceSendFields []string

+ func (s *TableInfo) UnmarshalJSON(b []byte) error

+ func (s TableInfo) MarshalJSON() ([]byte, error)

type TableSummary

+ ForceSendFields []string

+ func (s *TableSummary) UnmarshalJSON(b []byte) error

+ func (s TableSummary) MarshalJSON() ([]byte, error)

type UpdateCatalog

+ ForceSendFields []string

+ func (s *UpdateCatalog) UnmarshalJSON(b []byte) error

+ func (s UpdateCatalog) MarshalJSON() ([]byte, error)

type UpdateConnection

+ ForceSendFields []string

+ Owner string

+ func (s *UpdateConnection) UnmarshalJSON(b []byte) error

+ func (s UpdateConnection) MarshalJSON() ([]byte, error)

type UpdateExternalLocation

+ ForceSendFields []string

+ func (s *UpdateExternalLocation) UnmarshalJSON(b []byte) error

+ func (s UpdateExternalLocation) MarshalJSON() ([]byte, error)

type UpdateFunction

+ ForceSendFields []string

+ func (s *UpdateFunction) UnmarshalJSON(b []byte) error

+ func (s UpdateFunction) MarshalJSON() ([]byte, error)

type UpdateMetastore

+ ForceSendFields []string

+ func (s *UpdateMetastore) UnmarshalJSON(b []byte) error

+ func (s UpdateMetastore) MarshalJSON() ([]byte, error)

type UpdateMetastoreAssignment

+ ForceSendFields []string

+ func (s *UpdateMetastoreAssignment) UnmarshalJSON(b []byte) error

+ func (s UpdateMetastoreAssignment) MarshalJSON() ([]byte, error)

type UpdateModelVersionRequest

+ ForceSendFields []string

+ func (s *UpdateModelVersionRequest) UnmarshalJSON(b []byte) error

+ func (s UpdateModelVersionRequest) MarshalJSON() ([]byte, error)

type UpdatePredictiveOptimizationResponse

+ ForceSendFields []string

+ func (s *UpdatePredictiveOptimizationResponse) UnmarshalJSON(b []byte) error

+ func (s UpdatePredictiveOptimizationResponse) MarshalJSON() ([]byte, error)

type UpdateRegisteredModelRequest

+ ForceSendFields []string

+ func (s *UpdateRegisteredModelRequest) UnmarshalJSON(b []byte) error

+ func (s UpdateRegisteredModelRequest) MarshalJSON() ([]byte, error)

type UpdateSchema

+ ForceSendFields []string

+ func (s *UpdateSchema) UnmarshalJSON(b []byte) error

+ func (s UpdateSchema) MarshalJSON() ([]byte, error)

type UpdateStorageCredential

+ ForceSendFields []string

+ func (s *UpdateStorageCredential) UnmarshalJSON(b []byte) error

+ func (s UpdateStorageCredential) MarshalJSON() ([]byte, error)

type UpdateTableRequest

+ ForceSendFields []string

+ func (s *UpdateTableRequest) UnmarshalJSON(b []byte) error

+ func (s UpdateTableRequest) MarshalJSON() ([]byte, error)

type UpdateVolumeRequestContent

+ ForceSendFields []string

+ func (s *UpdateVolumeRequestContent) UnmarshalJSON(b []byte) error

+ func (s UpdateVolumeRequestContent) MarshalJSON() ([]byte, error)

+ type UpdateWorkspaceBindingsParameters struct

+ Add []WorkspaceBinding

+ Remove []WorkspaceBinding

+ SecurableName string

+ SecurableType string

type ValidateStorageCredential

+ ForceSendFields []string

+ func (s *ValidateStorageCredential) UnmarshalJSON(b []byte) error

+ func (s ValidateStorageCredential) MarshalJSON() ([]byte, error)

type ValidateStorageCredentialResponse

+ ForceSendFields []string

+ func (s *ValidateStorageCredentialResponse) UnmarshalJSON(b []byte) error

+ func (s ValidateStorageCredentialResponse) MarshalJSON() ([]byte, error)

type ValidationResult

+ ForceSendFields []string

+ func (s *ValidationResult) UnmarshalJSON(b []byte) error

+ func (s ValidationResult) MarshalJSON() ([]byte, error)

type VolumeInfo

+ ForceSendFields []string

+ func (s *VolumeInfo) UnmarshalJSON(b []byte) error

+ func (s VolumeInfo) MarshalJSON() ([]byte, error)

+ type WorkspaceBinding struct

+ BindingType WorkspaceBindingBindingType

+ ForceSendFields []string

+ WorkspaceId int64

+ func (s *WorkspaceBinding) UnmarshalJSON(b []byte) error

+ func (s WorkspaceBinding) MarshalJSON() ([]byte, error)

+ type WorkspaceBindingBindingType string

+ const WorkspaceBindingBindingTypeBindingTypeReadOnly

+ const WorkspaceBindingBindingTypeBindingTypeReadWrite

+ func (f *WorkspaceBindingBindingType) Set(v string) error

+ func (f *WorkspaceBindingBindingType) String() string

+ func (f *WorkspaceBindingBindingType) Type() string

type WorkspaceBindingsAPI

+ func (a *WorkspaceBindingsAPI) GetBindings(ctx context.Context, request GetBindingsRequest) (*WorkspaceBindingsResponse, error)

+ func (a *WorkspaceBindingsAPI) GetBindingsBySecurableTypeAndSecurableName(ctx context.Context, securableType string, securableName string) (*WorkspaceBindingsResponse, error)

+ func (a *WorkspaceBindingsAPI) UpdateBindings(ctx context.Context, request UpdateWorkspaceBindingsParameters) (*WorkspaceBindingsResponse, error)

+ type WorkspaceBindingsResponse struct

+ Bindings []WorkspaceBinding

type WorkspaceBindingsService

+ GetBindings func(ctx context.Context, request GetBindingsRequest) (*WorkspaceBindingsResponse, error)

+ UpdateBindings func(ctx context.Context, request UpdateWorkspaceBindingsParameters) (*WorkspaceBindingsResponse, error)

v0.22.0

Oct 3, 2023

Changes in this version

type AccountMetastoreAssignmentsAPI

+ func (a *AccountMetastoreAssignmentsAPI) ListAll(ctx context.Context, request ListAccountMetastoreAssignmentsRequest) ([]int64, error)

+ type ListAccountMetastoreAssignmentsResponse struct

+ WorkspaceIds []int64

v0.21.0

Sep 27, 2023

v0.20.0

Sep 21, 2023

Changes in this version

type Privilege

+ const PrivilegeManageAllowlist

type SecurableType

+ const SecurableTypeVolume

v0.19.2

Sep 13, 2023

v0.19.1

Sep 7, 2023

v0.19.0

Sep 4, 2023

v0.18.0

Aug 29, 2023

Changes in this version

type AccountMetastoresAPI

+ func (a *AccountMetastoresAPI) ListAll(ctx context.Context) ([]MetastoreInfo, error)

type AccountStorageCredentialsAPI

+ func (a *AccountStorageCredentialsAPI) GetByName(ctx context.Context, name string) (*StorageCredentialInfo, error)

+ func (a *AccountStorageCredentialsAPI) StorageCredentialInfoNameToIdMap(ctx context.Context, request ListAccountStorageCredentialsRequest) (map[string]string, error)

type CatalogInfo

+ BrowseOnly bool

+ FullName string

+ ProvisioningInfo *ProvisioningInfo

+ SecurableKind CatalogInfoSecurableKind

+ SecurableType string

+ type CatalogInfoSecurableKind string

+ const CatalogInfoSecurableKindCatalogDeltasharing

+ const CatalogInfoSecurableKindCatalogForeignBigquery

+ const CatalogInfoSecurableKindCatalogForeignDatabricks

+ const CatalogInfoSecurableKindCatalogForeignMysql

+ const CatalogInfoSecurableKindCatalogForeignPostgresql

+ const CatalogInfoSecurableKindCatalogForeignRedshift

+ const CatalogInfoSecurableKindCatalogForeignSnowflake

+ const CatalogInfoSecurableKindCatalogForeignSqldw

+ const CatalogInfoSecurableKindCatalogForeignSqlserver

+ const CatalogInfoSecurableKindCatalogInternal

+ const CatalogInfoSecurableKindCatalogOnline

+ const CatalogInfoSecurableKindCatalogOnlineIndex

+ const CatalogInfoSecurableKindCatalogStandard

+ const CatalogInfoSecurableKindCatalogSystem

+ const CatalogInfoSecurableKindCatalogSystemDeltasharing

+ func (f *CatalogInfoSecurableKind) Set(v string) error

+ func (f *CatalogInfoSecurableKind) String() string

+ func (f *CatalogInfoSecurableKind) Type() string

type ConnectionInfo

+ ProvisioningInfo *ProvisioningInfo

type CreateCatalog

+ Options map[string]string

+ type CreateRegisteredModelRequest struct

+ CatalogName string

+ Comment string

+ Name string

+ SchemaName string

+ StorageLocation string

+ type DeleteAliasRequest struct

+ Alias string

+ FullName string

+ type DeleteModelVersionRequest struct

+ FullName string

+ Version int

+ type DeleteRegisteredModelRequest struct

+ FullName string

+ type GetByAliasRequest struct

+ Alias string

+ FullName string

+ type GetModelVersionRequest struct

+ FullName string

+ Version int

+ type GetRegisteredModelRequest struct

+ FullName string

+ type ListModelVersionsRequest struct

+ FullName string

+ MaxResults int

+ PageToken string

+ type ListModelVersionsResponse struct

+ ModelVersions []ModelVersionInfo

+ NextPageToken string

+ type ListRegisteredModelsRequest struct

+ CatalogName string

+ MaxResults int

+ PageToken string

+ SchemaName string

+ type ListRegisteredModelsResponse struct

+ NextPageToken string

+ RegisteredModels []RegisteredModelInfo

+ type ModelVersionInfo struct

+ CatalogName string

+ Comment string

+ CreatedAt int64

+ CreatedBy string

+ Id string

+ MetastoreId string

+ ModelName string

+ ModelVersionDependencies []Dependency

+ RunId string

+ RunWorkspaceId int

+ SchemaName string

+ Source string

+ Status ModelVersionInfoStatus

+ StorageLocation string

+ UpdatedAt int64

+ UpdatedBy string

+ Version int

+ type ModelVersionInfoStatus string

+ const ModelVersionInfoStatusFailedRegistration

+ const ModelVersionInfoStatusPendingRegistration

+ const ModelVersionInfoStatusReady

+ func (f *ModelVersionInfoStatus) Set(v string) error

+ func (f *ModelVersionInfoStatus) String() string

+ func (f *ModelVersionInfoStatus) Type() string

+ type ModelVersionsAPI struct

+ func NewModelVersions(client *client.DatabricksClient) *ModelVersionsAPI

+ func (a *ModelVersionsAPI) Delete(ctx context.Context, request DeleteModelVersionRequest) error

+ func (a *ModelVersionsAPI) DeleteByFullNameAndVersion(ctx context.Context, fullName string, version int) error

+ func (a *ModelVersionsAPI) Get(ctx context.Context, request GetModelVersionRequest) (*RegisteredModelInfo, error)

+ func (a *ModelVersionsAPI) GetByAlias(ctx context.Context, request GetByAliasRequest) (*ModelVersionInfo, error)

+ func (a *ModelVersionsAPI) GetByAliasByFullNameAndAlias(ctx context.Context, fullName string, alias string) (*ModelVersionInfo, error)

+ func (a *ModelVersionsAPI) GetByFullNameAndVersion(ctx context.Context, fullName string, version int) (*RegisteredModelInfo, error)

+ func (a *ModelVersionsAPI) Impl() ModelVersionsService

+ func (a *ModelVersionsAPI) ListAll(ctx context.Context, request ListModelVersionsRequest) ([]ModelVersionInfo, error)

+ func (a *ModelVersionsAPI) ListByFullName(ctx context.Context, fullName string) (*ListModelVersionsResponse, error)

+ func (a *ModelVersionsAPI) Update(ctx context.Context, request UpdateModelVersionRequest) (*ModelVersionInfo, error)

+ func (a *ModelVersionsAPI) WithImpl(impl ModelVersionsService) *ModelVersionsAPI

+ type ModelVersionsService interface

+ Delete func(ctx context.Context, request DeleteModelVersionRequest) error

+ Get func(ctx context.Context, request GetModelVersionRequest) (*RegisteredModelInfo, error)

+ GetByAlias func(ctx context.Context, request GetByAliasRequest) (*ModelVersionInfo, error)

+ List func(ctx context.Context, request ListModelVersionsRequest) (*ListModelVersionsResponse, error)

+ Update func(ctx context.Context, request UpdateModelVersionRequest) (*ModelVersionInfo, error)

type Privilege

+ const PrivilegeCreateModel

+ type ProvisioningInfo struct

+ State ProvisioningInfoState

+ type ProvisioningInfoState string

+ const ProvisioningInfoStateActive

+ const ProvisioningInfoStateDeleting

+ const ProvisioningInfoStateFailed

+ const ProvisioningInfoStateProvisioning

+ const ProvisioningInfoStateStateUnspecified

+ func (f *ProvisioningInfoState) Set(v string) error

+ func (f *ProvisioningInfoState) String() string

+ func (f *ProvisioningInfoState) Type() string

+ type RegisteredModelAlias struct

+ AliasName string

+ VersionNum int

+ type RegisteredModelInfo struct

+ Aliases []RegisteredModelAlias

+ CatalogName string

+ Comment string

+ CreatedAt int64

+ CreatedBy string

+ FullName string

+ MetastoreId string

+ Name string

+ Owner string

+ SchemaName string

+ StorageLocation string

+ UpdatedAt int64

+ UpdatedBy string

+ type RegisteredModelsAPI struct

+ func NewRegisteredModels(client *client.DatabricksClient) *RegisteredModelsAPI

+ func (a *RegisteredModelsAPI) Create(ctx context.Context, request CreateRegisteredModelRequest) (*RegisteredModelInfo, error)

+ func (a *RegisteredModelsAPI) Delete(ctx context.Context, request DeleteRegisteredModelRequest) error

+ func (a *RegisteredModelsAPI) DeleteAlias(ctx context.Context, request DeleteAliasRequest) error

+ func (a *RegisteredModelsAPI) DeleteAliasByFullNameAndAlias(ctx context.Context, fullName string, alias string) error

+ func (a *RegisteredModelsAPI) DeleteByFullName(ctx context.Context, fullName string) error

+ func (a *RegisteredModelsAPI) Get(ctx context.Context, request GetRegisteredModelRequest) (*RegisteredModelInfo, error)

+ func (a *RegisteredModelsAPI) GetByFullName(ctx context.Context, fullName string) (*RegisteredModelInfo, error)

+ func (a *RegisteredModelsAPI) GetByName(ctx context.Context, name string) (*RegisteredModelInfo, error)

+ func (a *RegisteredModelsAPI) Impl() RegisteredModelsService

+ func (a *RegisteredModelsAPI) ListAll(ctx context.Context, request ListRegisteredModelsRequest) ([]RegisteredModelInfo, error)

+ func (a *RegisteredModelsAPI) RegisteredModelInfoNameToFullNameMap(ctx context.Context, request ListRegisteredModelsRequest) (map[string]string, error)

+ func (a *RegisteredModelsAPI) SetAlias(ctx context.Context, request SetRegisteredModelAliasRequest) (*RegisteredModelAlias, error)

+ func (a *RegisteredModelsAPI) Update(ctx context.Context, request UpdateRegisteredModelRequest) (*RegisteredModelInfo, error)

+ func (a *RegisteredModelsAPI) WithImpl(impl RegisteredModelsService) *RegisteredModelsAPI

+ type RegisteredModelsService interface

+ Create func(ctx context.Context, request CreateRegisteredModelRequest) (*RegisteredModelInfo, error)

+ Delete func(ctx context.Context, request DeleteRegisteredModelRequest) error

+ DeleteAlias func(ctx context.Context, request DeleteAliasRequest) error

+ Get func(ctx context.Context, request GetRegisteredModelRequest) (*RegisteredModelInfo, error)

+ List func(ctx context.Context, request ListRegisteredModelsRequest) (*ListRegisteredModelsResponse, error)

+ SetAlias func(ctx context.Context, request SetRegisteredModelAliasRequest) (*RegisteredModelAlias, error)

+ Update func(ctx context.Context, request UpdateRegisteredModelRequest) (*RegisteredModelInfo, error)

+ type SetRegisteredModelAliasRequest struct

+ Alias string

+ FullName string

+ VersionNum int

type UpdateCatalog

+ Options map[string]string

+ type UpdateModelVersionRequest struct

+ Comment string

+ FullName string

+ Version int

+ type UpdateRegisteredModelRequest struct

+ Comment string

+ FullName string

+ Name string

+ Owner string

v0.17.0

Aug 18, 2023

Changes in this version

+ type ArtifactAllowlistInfo struct

+ ArtifactMatchers *ArtifactMatcher

+ CreatedAt int64

+ CreatedBy string

+ MetastoreId string

+ type ArtifactAllowlistsAPI struct

+ func NewArtifactAllowlists(client *client.DatabricksClient) *ArtifactAllowlistsAPI

+ func (a *ArtifactAllowlistsAPI) Get(ctx context.Context, request GetArtifactAllowlistRequest) (*ArtifactAllowlistInfo, error)

+ func (a *ArtifactAllowlistsAPI) GetByArtifactType(ctx context.Context, artifactType ArtifactType) (*ArtifactAllowlistInfo, error)

+ func (a *ArtifactAllowlistsAPI) Impl() ArtifactAllowlistsService

+ func (a *ArtifactAllowlistsAPI) Update(ctx context.Context, request SetArtifactAllowlist) (*ArtifactAllowlistInfo, error)

+ func (a *ArtifactAllowlistsAPI) WithImpl(impl ArtifactAllowlistsService) *ArtifactAllowlistsAPI

+ type ArtifactAllowlistsService interface

+ Get func(ctx context.Context, request GetArtifactAllowlistRequest) (*ArtifactAllowlistInfo, error)

+ Update func(ctx context.Context, request SetArtifactAllowlist) (*ArtifactAllowlistInfo, error)

+ type ArtifactMatcher struct

+ Artifact string

+ MatchType MatchType

+ type ArtifactType string

+ const ArtifactTypeInitScript

+ const ArtifactTypeLibraryJar

+ const ArtifactTypeLibraryMaven

+ func (f *ArtifactType) Set(v string) error

+ func (f *ArtifactType) String() string

+ func (f *ArtifactType) Type() string

type CatalogInfo

+ EffectivePredictiveOptimizationFlag *EffectivePredictiveOptimizationFlag

+ EnablePredictiveOptimization EnablePredictiveOptimization

+ type EffectivePredictiveOptimizationFlag struct

+ InheritedFromName string

+ InheritedFromType EffectivePredictiveOptimizationFlagInheritedFromType

+ Value EnablePredictiveOptimization

+ type EffectivePredictiveOptimizationFlagInheritedFromType string

+ const EffectivePredictiveOptimizationFlagInheritedFromTypeCatalog

+ const EffectivePredictiveOptimizationFlagInheritedFromTypeSchema

+ func (f *EffectivePredictiveOptimizationFlagInheritedFromType) Set(v string) error

+ func (f *EffectivePredictiveOptimizationFlagInheritedFromType) String() string

+ func (f *EffectivePredictiveOptimizationFlagInheritedFromType) Type() string

+ type EnablePredictiveOptimization string

+ const EnablePredictiveOptimizationDisable

+ const EnablePredictiveOptimizationEnable

+ const EnablePredictiveOptimizationInherit

+ func (f *EnablePredictiveOptimization) Set(v string) error

+ func (f *EnablePredictiveOptimization) String() string

+ func (f *EnablePredictiveOptimization) Type() string

+ type GetArtifactAllowlistRequest struct

+ ArtifactType ArtifactType

+ type ListSecurableTagsRequest struct

+ FullName string

+ SecurableType ListSecurableType

+ type ListSecurableType string

+ const ListSecurableTypeCatalog

+ const ListSecurableTypeSchema

+ const ListSecurableTypeTable

+ func (f *ListSecurableType) Set(v string) error

+ func (f *ListSecurableType) String() string

+ func (f *ListSecurableType) Type() string

+ type ListSubentityTagsRequest struct

+ FullName string

+ SecurableType ListSecurableType

+ SubentityName string

+ type MatchType string

+ const MatchTypePrefixMatch

+ func (f *MatchType) Set(v string) error

+ func (f *MatchType) String() string

+ func (f *MatchType) Type() string

type Privilege

+ const PrivilegeApplyTag

type SchemaInfo

+ EffectivePredictiveOptimizationFlag *EffectivePredictiveOptimizationFlag

+ EnablePredictiveOptimization EnablePredictiveOptimization

+ type SecurableTagsAPI struct

+ func NewSecurableTags(client *client.DatabricksClient) *SecurableTagsAPI

+ func (a *SecurableTagsAPI) Impl() SecurableTagsService

+ func (a *SecurableTagsAPI) ListAll(ctx context.Context, request ListSecurableTagsRequest) ([]TagSecurableAssignment, error)

+ func (a *SecurableTagsAPI) ListBySecurableTypeAndFullName(ctx context.Context, securableType ListSecurableType, fullName string) (*TagSecurableAssignmentsList, error)

+ func (a *SecurableTagsAPI) Update(ctx context.Context, request UpdateTags) (*TagSecurableAssignmentsList, error)

+ func (a *SecurableTagsAPI) WithImpl(impl SecurableTagsService) *SecurableTagsAPI

+ type SecurableTagsService interface

+ List func(ctx context.Context, request ListSecurableTagsRequest) (*TagSecurableAssignmentsList, error)

+ Update func(ctx context.Context, request UpdateTags) (*TagSecurableAssignmentsList, error)

+ type SetArtifactAllowlist struct

+ ArtifactMatchers ArtifactMatcher

+ ArtifactType ArtifactType

+ type SubentityTagsAPI struct

+ func NewSubentityTags(client *client.DatabricksClient) *SubentityTagsAPI

+ func (a *SubentityTagsAPI) Impl() SubentityTagsService

+ func (a *SubentityTagsAPI) ListAll(ctx context.Context, request ListSubentityTagsRequest) ([]TagsSubentityAssignment, error)

+ func (a *SubentityTagsAPI) ListBySecurableTypeAndFullNameAndSubentityName(ctx context.Context, securableType ListSecurableType, fullName string, ...) (*TagSubentityAssignmentsList, error)

+ func (a *SubentityTagsAPI) Update(ctx context.Context, request UpdateTags) (*TagSubentityAssignmentsList, error)

+ func (a *SubentityTagsAPI) WithImpl(impl SubentityTagsService) *SubentityTagsAPI

+ type SubentityTagsService interface

+ List func(ctx context.Context, request ListSubentityTagsRequest) (*TagSubentityAssignmentsList, error)

+ Update func(ctx context.Context, request UpdateTags) (*TagSubentityAssignmentsList, error)

type TableInfo

+ EffectivePredictiveOptimizationFlag *EffectivePredictiveOptimizationFlag

+ EnablePredictiveOptimization EnablePredictiveOptimization

+ type TagChanges struct

+ AddTags []TagKeyValuePair

+ Remove []string

+ type TagKeyValuePair struct

+ Key string

+ Value string

+ type TagSecurable struct

+ FullName string

+ Type string

+ type TagSecurableAssignment struct

+ Securable TagSecurable

+ TagKeyValuePairs []TagKeyValuePair

+ type TagSecurableAssignmentsList struct

+ TagAssignments []TagSecurableAssignment

+ type TagSubentity struct

+ FullName string

+ Subentity string

+ Type string

+ type TagSubentityAssignmentsList struct

+ TagAssignments []TagsSubentityAssignment

+ type TagsSubentityAssignment struct

+ Securable TagSubentity

+ Subentity string

+ TagKeyValuePairs []TagKeyValuePair

+ type UpdateSecurableType string

+ const UpdateSecurableTypeCatalog

+ const UpdateSecurableTypeSchema

+ const UpdateSecurableTypeTable

+ func (f *UpdateSecurableType) Set(v string) error

+ func (f *UpdateSecurableType) String() string

+ func (f *UpdateSecurableType) Type() string

+ type UpdateTags struct

+ Changes TagChanges

+ FullName string

+ SecurableType UpdateSecurableType

+ SubentityName string

v0.16.0

Aug 14, 2023

Changes in this version

+ type AccountsStorageCredentialInfo struct

+ CredentialInfo *StorageCredentialInfo

type ConnectionInfo

+ Options map[string]string

+ Properties map[string]string

+ ProvisioningState ProvisioningState

+ SecurableKind ConnectionInfoSecurableKind

+ SecurableType string

+ type ConnectionInfoSecurableKind string

+ const ConnectionInfoSecurableKindConnectionBigquery

+ const ConnectionInfoSecurableKindConnectionDatabricks

+ const ConnectionInfoSecurableKindConnectionMysql

+ const ConnectionInfoSecurableKindConnectionOnlineCatalog

+ const ConnectionInfoSecurableKindConnectionPostgresql

+ const ConnectionInfoSecurableKindConnectionRedshift

+ const ConnectionInfoSecurableKindConnectionSnowflake

+ const ConnectionInfoSecurableKindConnectionSqldw

+ const ConnectionInfoSecurableKindConnectionSqlserver

+ func (f *ConnectionInfoSecurableKind) Set(v string) error

+ func (f *ConnectionInfoSecurableKind) String() string

+ func (f *ConnectionInfoSecurableKind) Type() string

type CreateConnection

+ Options map[string]string

+ Properties map[string]string

+ type ProvisioningState string

+ const ProvisioningStateActive

+ const ProvisioningStateDeleting

+ const ProvisioningStateFailed

+ const ProvisioningStateProvisioning

+ const ProvisioningStateStateUnspecified

+ func (f *ProvisioningState) Set(v string) error

+ func (f *ProvisioningState) String() string

+ func (f *ProvisioningState) Type() string

type UpdateConnection

+ Options map[string]string

v0.15.0

Aug 7, 2023

v0.14.1

Jul 27, 2023

v0.14.0

Jul 26, 2023

Changes in this version

type CreateCatalog

+ ConnectionName string

type CreateExternalLocation

+ AccessPoint string

+ EncryptionDetails *EncryptionDetails

+ type EncryptionDetails struct

+ SseEncryptionDetails *SseEncryptionDetails

type ExternalLocationInfo

+ AccessPoint string

+ EncryptionDetails *EncryptionDetails

type Privilege

+ const PrivilegeCreateConnection

+ const PrivilegeCreateForeignCatalog

+ const PrivilegeUseConnection

type SecurableType

+ const SecurableTypeConnection

+ type SseEncryptionDetails struct

+ Algorithm SseEncryptionDetailsAlgorithm

+ AwsKmsKeyArn string

+ type SseEncryptionDetailsAlgorithm string

+ const SseEncryptionDetailsAlgorithmAwsSseKms

+ const SseEncryptionDetailsAlgorithmAwsSseS3

+ func (f *SseEncryptionDetailsAlgorithm) Set(v string) error

+ func (f *SseEncryptionDetailsAlgorithm) String() string

+ func (f *SseEncryptionDetailsAlgorithm) Type() string

type TableInfo

+ AccessPoint string

+ EncryptionDetails *EncryptionDetails

type UpdateExternalLocation

+ AccessPoint string

+ EncryptionDetails *EncryptionDetails

type VolumeInfo

+ AccessPoint string

+ EncryptionDetails *EncryptionDetails

v0.13.0

Jul 18, 2023

Changes in this version

type DeleteAccountMetastoreRequest

+ Force bool

type DeleteAccountStorageCredentialRequest

+ Force bool

type MetastoresAPI

+ func (a *MetastoresAPI) EnableOptimization(ctx context.Context, request UpdatePredictiveOptimization) (*UpdatePredictiveOptimizationResponse, error)

type MetastoresService

+ EnableOptimization func(ctx context.Context, request UpdatePredictiveOptimization) (*UpdatePredictiveOptimizationResponse, error)

type TablesAPI

+ func (a *TablesAPI) Update(ctx context.Context, request UpdateTableRequest) error

type TablesService

+ Update func(ctx context.Context, request UpdateTableRequest) error

+ type UpdatePredictiveOptimization struct

+ Enable bool

+ MetastoreId string

+ type UpdatePredictiveOptimizationResponse struct

+ State bool

+ UserId int64

+ Username string

+ type UpdateTableRequest struct

+ FullName string

+ Owner string

v0.12.0

Jun 28, 2023

Changes in this version

type SecurableType

+ const SecurableTypePipeline

v0.11.0

Jun 28, 2023

Changes in this version

type CatalogInfo

+ ConnectionName string

+ Options map[string]string

+ type DisableSchemaName string

+ const DisableSchemaNameAccess

+ const DisableSchemaNameBilling

+ const DisableSchemaNameLineage

+ const DisableSchemaNameOperationalData

+ func (f *DisableSchemaName) Set(v string) error

+ func (f *DisableSchemaName) String() string

+ func (f *DisableSchemaName) Type() string

+ type EnableRequest struct

+ MetastoreId string

+ SchemaName EnableSchemaName

+ type EnableSchemaName string

+ const EnableSchemaNameAccess

+ const EnableSchemaNameBilling

+ const EnableSchemaNameLineage

+ const EnableSchemaNameOperationalData

+ func (f *EnableSchemaName) Set(v string) error

+ func (f *EnableSchemaName) String() string

+ func (f *EnableSchemaName) Type() string

type Privilege

+ const PrivilegeUseMarketplaceAssets

+ type SecurableOptionsMap map[string]string

type SystemSchemaInfoState

+ const SystemSchemaInfoStateAvailable

+ const SystemSchemaInfoStateDisableInitialized

+ const SystemSchemaInfoStateEnableCompleted

+ const SystemSchemaInfoStateEnableInitialized

v0.10.1

Jun 21, 2023

v0.10.0

Jun 15, 2023

Changes in this version

+ type AccountsCreateMetastore struct

+ MetastoreInfo *CreateMetastore

+ type AccountsCreateMetastoreAssignment struct

+ MetastoreAssignment *CreateMetastoreAssignment

+ MetastoreId string

+ WorkspaceId int64

+ type AccountsCreateStorageCredential struct

+ CredentialInfo *CreateStorageCredential

+ MetastoreId string

+ type AccountsMetastoreAssignment struct

+ MetastoreAssignment *MetastoreAssignment

+ type AccountsMetastoreInfo struct

+ MetastoreInfo *MetastoreInfo

+ type AccountsUpdateMetastore struct

+ MetastoreId string

+ MetastoreInfo *UpdateMetastore

+ type AccountsUpdateMetastoreAssignment struct

+ MetastoreAssignment *UpdateMetastoreAssignment

+ MetastoreId string

+ WorkspaceId int64

+ type AccountsUpdateStorageCredential struct

+ CredentialInfo *UpdateStorageCredential

+ MetastoreId string

+ Name string

+ type AzureManagedIdentity struct

+ AccessConnectorId string

+ CredentialId string

+ ManagedIdentityId string

+ type ConnectionInfo struct

+ Comment string

+ ConnectionId string

+ ConnectionType ConnectionType

+ CreatedAt int64

+ CreatedBy string

+ CredentialType CredentialType

+ FullName string

+ MetastoreId string

+ Name string

+ OptionsKvpairs *OptionsKvPairs

+ Owner string

+ PropertiesKvpairs map[string]string

+ ReadOnly bool

+ UpdatedAt int64

+ UpdatedBy string

+ Url string

+ type ConnectionType string

+ const ConnectionTypeDatabricks

+ const ConnectionTypeMysql

+ const ConnectionTypePostgresql

+ const ConnectionTypeRedshift

+ const ConnectionTypeSnowflake

+ const ConnectionTypeSqldw

+ const ConnectionTypeSqlserver

+ func (f *ConnectionType) Set(v string) error

+ func (f *ConnectionType) String() string

+ func (f *ConnectionType) Type() string

+ type ConnectionsAPI struct

+ func NewConnections(client *client.DatabricksClient) *ConnectionsAPI

+ func (a *ConnectionsAPI) ConnectionInfoNameToFullNameMap(ctx context.Context) (map[string]string, error)

+ func (a *ConnectionsAPI) Create(ctx context.Context, request CreateConnection) (*ConnectionInfo, error)

+ func (a *ConnectionsAPI) Delete(ctx context.Context, request DeleteConnectionRequest) error

+ func (a *ConnectionsAPI) DeleteByNameArg(ctx context.Context, nameArg string) error

+ func (a *ConnectionsAPI) Get(ctx context.Context, request GetConnectionRequest) (*ConnectionInfo, error)

+ func (a *ConnectionsAPI) GetByName(ctx context.Context, name string) (*ConnectionInfo, error)

+ func (a *ConnectionsAPI) GetByNameArg(ctx context.Context, nameArg string) (*ConnectionInfo, error)

+ func (a *ConnectionsAPI) Impl() ConnectionsService

+ func (a *ConnectionsAPI) ListAll(ctx context.Context) ([]ConnectionInfo, error)

+ func (a *ConnectionsAPI) Update(ctx context.Context, request UpdateConnection) (*ConnectionInfo, error)

+ func (a *ConnectionsAPI) WithImpl(impl ConnectionsService) *ConnectionsAPI

+ type ConnectionsService interface

+ Create func(ctx context.Context, request CreateConnection) (*ConnectionInfo, error)

+ Delete func(ctx context.Context, request DeleteConnectionRequest) error

+ Get func(ctx context.Context, request GetConnectionRequest) (*ConnectionInfo, error)

+ List func(ctx context.Context) (*ListConnectionsResponse, error)

+ Update func(ctx context.Context, request UpdateConnection) (*ConnectionInfo, error)

+ type CreateConnection struct

+ Comment string

+ ConnectionType ConnectionType

+ Name string

+ OptionsKvpairs OptionsKvPairs

+ Owner string

+ PropertiesKvpairs map[string]string

+ ReadOnly bool

+ type CreateMetastoreAssignmentsResponseItem struct

+ Message string

+ MetastoreAssignment *MetastoreAssignment

+ StatusCode int

type CreateStorageCredential

+ AzureManagedIdentity *AzureManagedIdentity

+ DatabricksGcpServiceAccount any

+ type CredentialType string

+ const CredentialTypeUsernamePassword

+ func (f *CredentialType) Set(v string) error

+ func (f *CredentialType) String() string

+ func (f *CredentialType) Type() string

+ type DatabricksGcpServiceAccountResponse struct

+ CredentialId string

+ Email string

+ type DeleteConnectionRequest struct

+ NameArg string

+ type DisableRequest struct

+ MetastoreId string

+ SchemaName string

type FunctionsAPI

+ func (a *FunctionsAPI) FunctionInfoNameToFullNameMap(ctx context.Context, request ListFunctionsRequest) (map[string]string, error)

+ func (a *FunctionsAPI) ListAll(ctx context.Context, request ListFunctionsRequest) ([]FunctionInfo, error)

+ type GetConnectionRequest struct

+ NameArg string

+ type ListConnectionsResponse struct

+ Connections []ConnectionInfo

type ListFunctionsResponse

+ Functions []FunctionInfo

+ type ListSystemSchemasRequest struct

+ MetastoreId string

+ type ListSystemSchemasResponse struct

+ Schemas []SystemSchemaInfo

+ type OptionsKvPairs struct

+ Host string

+ type PropertiesKvPairs map[string]string

type StorageCredentialInfo

+ AzureManagedIdentity *AzureManagedIdentity

+ DatabricksGcpServiceAccount *DatabricksGcpServiceAccountResponse

+ type SystemSchemaInfo struct

+ Schema string

+ State SystemSchemaInfoState

+ type SystemSchemaInfoState string

+ const SystemSchemaInfoStateDisableinitialized

+ const SystemSchemaInfoStateEnablecompleted

+ const SystemSchemaInfoStateEnableinitialized

+ const SystemSchemaInfoStateUnavailable

+ func (f *SystemSchemaInfoState) Set(v string) error

+ func (f *SystemSchemaInfoState) String() string

+ func (f *SystemSchemaInfoState) Type() string

+ type SystemSchemasAPI struct

+ func NewSystemSchemas(client *client.DatabricksClient) *SystemSchemasAPI

+ func (a *SystemSchemasAPI) Disable(ctx context.Context, request DisableRequest) error

+ func (a *SystemSchemasAPI) DisableByMetastoreIdAndSchemaName(ctx context.Context, metastoreId string, schemaName string) error

+ func (a *SystemSchemasAPI) Enable(ctx context.Context) error

+ func (a *SystemSchemasAPI) Impl() SystemSchemasService

+ func (a *SystemSchemasAPI) ListAll(ctx context.Context, request ListSystemSchemasRequest) ([]SystemSchemaInfo, error)

+ func (a *SystemSchemasAPI) ListByMetastoreId(ctx context.Context, metastoreId string) (*ListSystemSchemasResponse, error)

+ func (a *SystemSchemasAPI) WithImpl(impl SystemSchemasService) *SystemSchemasAPI

+ type SystemSchemasService interface

+ Disable func(ctx context.Context, request DisableRequest) error

+ Enable func(ctx context.Context) error

+ List func(ctx context.Context, request ListSystemSchemasRequest) (*ListSystemSchemasResponse, error)

type TablesAPI

+ func (a *TablesAPI) ListSummariesAll(ctx context.Context, request ListSummariesRequest) ([]TableSummary, error)

+ type UpdateConnection struct

+ Name string

+ NameArg string

+ OptionsKvpairs OptionsKvPairs

type UpdateStorageCredential

+ AzureManagedIdentity *AzureManagedIdentity

+ DatabricksGcpServiceAccount any

type ValidateStorageCredential

+ AzureManagedIdentity *AzureManagedIdentity

+ DatabricksGcpServiceAccount any

v0.9.0

May 22, 2023

Changes in this version

type AccountStorageCredentialsAPI

+ func (a *AccountStorageCredentialsAPI) Delete(ctx context.Context, request DeleteAccountStorageCredentialRequest) error

+ func (a *AccountStorageCredentialsAPI) DeleteByMetastoreId(ctx context.Context, metastoreId string) error

+ func (a *AccountStorageCredentialsAPI) Update(ctx context.Context, request UpdateStorageCredential) (*StorageCredentialInfo, error)

type AccountStorageCredentialsService

+ Delete func(ctx context.Context, request DeleteAccountStorageCredentialRequest) error

+ Update func(ctx context.Context, request UpdateStorageCredential) (*StorageCredentialInfo, error)

type CatalogInfo

+ IsolationMode IsolationMode

+ type CurrentWorkspaceBindings struct

+ Workspaces []int64

+ type DeleteAccountStorageCredentialRequest struct

+ MetastoreId string

+ Name string

+ type DeltaRuntimePropertiesKvPairs struct

+ DeltaRuntimeProperties map[string]string

+ type GetWorkspaceBindingRequest struct

+ Name string

+ type IsolationMode string

+ const IsolationModeIsolated

+ const IsolationModeOpen

+ func (im *IsolationMode) Set(v string) error

+ func (im *IsolationMode) String() string

+ func (im *IsolationMode) Type() string

+ type ListStorageCredentialsResponse struct

+ StorageCredentials []StorageCredentialInfo

type StorageCredentialsAPI

+ func (a *StorageCredentialsAPI) ListAll(ctx context.Context) ([]StorageCredentialInfo, error)

type UpdateCatalog

+ IsolationMode IsolationMode

type UpdateStorageCredential

+ MetastoreId string

+ type UpdateWorkspaceBindings struct

+ AssignWorkspaces []int64

+ Name string

+ UnassignWorkspaces []int64

+ type WorkspaceBindingsAPI struct

+ func NewWorkspaceBindings(client *client.DatabricksClient) *WorkspaceBindingsAPI

+ func (a *WorkspaceBindingsAPI) Get(ctx context.Context, request GetWorkspaceBindingRequest) (*CurrentWorkspaceBindings, error)

+ func (a *WorkspaceBindingsAPI) GetByName(ctx context.Context, name string) (*CurrentWorkspaceBindings, error)

+ func (a *WorkspaceBindingsAPI) Impl() WorkspaceBindingsService

+ func (a *WorkspaceBindingsAPI) Update(ctx context.Context, request UpdateWorkspaceBindings) (*CurrentWorkspaceBindings, error)

+ func (a *WorkspaceBindingsAPI) WithImpl(impl WorkspaceBindingsService) *WorkspaceBindingsAPI

+ type WorkspaceBindingsService interface

+ Get func(ctx context.Context, request GetWorkspaceBindingRequest) (*CurrentWorkspaceBindings, error)

+ Update func(ctx context.Context, request UpdateWorkspaceBindings) (*CurrentWorkspaceBindings, error)

v0.8.1

May 11, 2023

v0.8.0

Apr 20, 2023

Changes in this version

+ type AccountMetastoreAssignmentsAPI struct

+ func NewAccountMetastoreAssignments(client *client.DatabricksClient) *AccountMetastoreAssignmentsAPI

+ func (a *AccountMetastoreAssignmentsAPI) Create(ctx context.Context, request CreateMetastoreAssignment) (*MetastoreAssignment, error)

+ func (a *AccountMetastoreAssignmentsAPI) Delete(ctx context.Context, request DeleteAccountMetastoreAssignmentRequest) error

+ func (a *AccountMetastoreAssignmentsAPI) DeleteByWorkspaceIdAndMetastoreId(ctx context.Context, workspaceId int64, metastoreId string) error

+ func (a *AccountMetastoreAssignmentsAPI) Get(ctx context.Context, request GetAccountMetastoreAssignmentRequest) (*MetastoreAssignment, error)

+ func (a *AccountMetastoreAssignmentsAPI) GetByWorkspaceId(ctx context.Context, workspaceId int64) (*MetastoreAssignment, error)

+ func (a *AccountMetastoreAssignmentsAPI) Impl() AccountMetastoreAssignmentsService

+ func (a *AccountMetastoreAssignmentsAPI) List(ctx context.Context, request ListAccountMetastoreAssignmentsRequest) ([]MetastoreAssignment, error)

+ func (a *AccountMetastoreAssignmentsAPI) ListByMetastoreId(ctx context.Context, metastoreId string) ([]MetastoreAssignment, error)

+ func (a *AccountMetastoreAssignmentsAPI) Update(ctx context.Context, request UpdateMetastoreAssignment) (*MetastoreAssignment, error)

+ func (a *AccountMetastoreAssignmentsAPI) WithImpl(impl AccountMetastoreAssignmentsService) *AccountMetastoreAssignmentsAPI

+ type AccountMetastoreAssignmentsService interface

+ Create func(ctx context.Context, request CreateMetastoreAssignment) (*MetastoreAssignment, error)

+ Delete func(ctx context.Context, request DeleteAccountMetastoreAssignmentRequest) error

+ Get func(ctx context.Context, request GetAccountMetastoreAssignmentRequest) (*MetastoreAssignment, error)

+ List func(ctx context.Context, request ListAccountMetastoreAssignmentsRequest) ([]MetastoreAssignment, error)

+ Update func(ctx context.Context, request UpdateMetastoreAssignment) (*MetastoreAssignment, error)

+ type AccountMetastoresAPI struct

+ func NewAccountMetastores(client *client.DatabricksClient) *AccountMetastoresAPI

+ func (a *AccountMetastoresAPI) Create(ctx context.Context, request CreateMetastore) (*MetastoreInfo, error)

+ func (a *AccountMetastoresAPI) Delete(ctx context.Context, request DeleteAccountMetastoreRequest) error

+ func (a *AccountMetastoresAPI) DeleteByMetastoreId(ctx context.Context, metastoreId string) error

+ func (a *AccountMetastoresAPI) Get(ctx context.Context, request GetAccountMetastoreRequest) (*MetastoreInfo, error)

+ func (a *AccountMetastoresAPI) GetByMetastoreId(ctx context.Context, metastoreId string) (*MetastoreInfo, error)

+ func (a *AccountMetastoresAPI) Impl() AccountMetastoresService

+ func (a *AccountMetastoresAPI) List(ctx context.Context) (*ListMetastoresResponse, error)

+ func (a *AccountMetastoresAPI) Update(ctx context.Context, request UpdateMetastore) (*MetastoreInfo, error)

+ func (a *AccountMetastoresAPI) WithImpl(impl AccountMetastoresService) *AccountMetastoresAPI

+ type AccountMetastoresService interface

+ Create func(ctx context.Context, request CreateMetastore) (*MetastoreInfo, error)

+ Delete func(ctx context.Context, request DeleteAccountMetastoreRequest) error

+ Get func(ctx context.Context, request GetAccountMetastoreRequest) (*MetastoreInfo, error)

+ List func(ctx context.Context) (*ListMetastoresResponse, error)

+ Update func(ctx context.Context, request UpdateMetastore) (*MetastoreInfo, error)

+ type AccountStorageCredentialsAPI struct

+ func NewAccountStorageCredentials(client *client.DatabricksClient) *AccountStorageCredentialsAPI

+ func (a *AccountStorageCredentialsAPI) Create(ctx context.Context, request CreateStorageCredential) (*StorageCredentialInfo, error)

+ func (a *AccountStorageCredentialsAPI) Get(ctx context.Context, request GetAccountStorageCredentialRequest) (*StorageCredentialInfo, error)

+ func (a *AccountStorageCredentialsAPI) GetByMetastoreId(ctx context.Context, metastoreId string) (*StorageCredentialInfo, error)

+ func (a *AccountStorageCredentialsAPI) Impl() AccountStorageCredentialsService

+ func (a *AccountStorageCredentialsAPI) List(ctx context.Context, request ListAccountStorageCredentialsRequest) ([]StorageCredentialInfo, error)

+ func (a *AccountStorageCredentialsAPI) ListByMetastoreId(ctx context.Context, metastoreId string) ([]StorageCredentialInfo, error)

+ func (a *AccountStorageCredentialsAPI) WithImpl(impl AccountStorageCredentialsService) *AccountStorageCredentialsAPI

+ type AccountStorageCredentialsService interface

+ Create func(ctx context.Context, request CreateStorageCredential) (*StorageCredentialInfo, error)

+ Get func(ctx context.Context, request GetAccountStorageCredentialRequest) (*StorageCredentialInfo, error)

+ List func(ctx context.Context, request ListAccountStorageCredentialsRequest) ([]StorageCredentialInfo, error)

+ type AwsIamRole struct

+ ExternalId string

+ RoleArn string

+ UnityCatalogIamArn string

+ type AzureServicePrincipal struct

+ ApplicationId string

+ ClientSecret string

+ DirectoryId string

+ type CatalogInfo struct

+ CatalogType CatalogType

+ Comment string

+ CreatedAt int64

+ CreatedBy string

+ EffectiveAutoMaintenanceFlag *EffectiveAutoMaintenanceFlag

+ EnableAutoMaintenance EnableAutoMaintenance

+ MetastoreId string

+ Name string

+ Owner string

+ Properties map[string]string

+ ProviderName string

+ ShareName string

+ StorageLocation string

+ StorageRoot string

+ UpdatedAt int64

+ UpdatedBy string

+ type CatalogType string

+ const CatalogTypeDeltasharingCatalog

+ const CatalogTypeManagedCatalog

+ const CatalogTypeSystemCatalog

+ func (ct *CatalogType) Set(v string) error

+ func (ct *CatalogType) String() string

+ func (ct *CatalogType) Type() string

+ type CatalogsAPI struct

+ func NewCatalogs(client *client.DatabricksClient) *CatalogsAPI

+ func (a *CatalogsAPI) Create(ctx context.Context, request CreateCatalog) (*CatalogInfo, error)

+ func (a *CatalogsAPI) Delete(ctx context.Context, request DeleteCatalogRequest) error

+ func (a *CatalogsAPI) DeleteByName(ctx context.Context, name string) error

+ func (a *CatalogsAPI) Get(ctx context.Context, request GetCatalogRequest) (*CatalogInfo, error)

+ func (a *CatalogsAPI) GetByName(ctx context.Context, name string) (*CatalogInfo, error)

+ func (a *CatalogsAPI) Impl() CatalogsService

+ func (a *CatalogsAPI) ListAll(ctx context.Context) ([]CatalogInfo, error)

+ func (a *CatalogsAPI) Update(ctx context.Context, request UpdateCatalog) (*CatalogInfo, error)

+ func (a *CatalogsAPI) WithImpl(impl CatalogsService) *CatalogsAPI

+ type CatalogsService interface

+ Create func(ctx context.Context, request CreateCatalog) (*CatalogInfo, error)

+ Delete func(ctx context.Context, request DeleteCatalogRequest) error

+ Get func(ctx context.Context, request GetCatalogRequest) (*CatalogInfo, error)

+ List func(ctx context.Context) (*ListCatalogsResponse, error)

+ Update func(ctx context.Context, request UpdateCatalog) (*CatalogInfo, error)

+ type ColumnInfo struct

+ Comment string

+ Mask *ColumnMask

+ Name string

+ Nullable bool

+ PartitionIndex int

+ Position int

+ TypeIntervalType string

+ TypeJson string

+ TypeName ColumnTypeName

+ TypePrecision int

+ TypeScale int

+ TypeText string

+ type ColumnMask struct

+ FunctionName string

+ UsingColumnNames []string

+ type ColumnTypeName string

+ const ColumnTypeNameArray

+ const ColumnTypeNameBinary

+ const ColumnTypeNameBoolean

+ const ColumnTypeNameByte

+ const ColumnTypeNameChar

+ const ColumnTypeNameDate

+ const ColumnTypeNameDecimal

+ const ColumnTypeNameDouble

+ const ColumnTypeNameFloat

+ const ColumnTypeNameInt

+ const ColumnTypeNameInterval

+ const ColumnTypeNameLong

+ const ColumnTypeNameMap

+ const ColumnTypeNameNull

+ const ColumnTypeNameShort

+ const ColumnTypeNameString

+ const ColumnTypeNameStruct

+ const ColumnTypeNameTableType

+ const ColumnTypeNameTimestamp

+ const ColumnTypeNameTimestampNtz

+ const ColumnTypeNameUserDefinedType

+ func (ctn *ColumnTypeName) Set(v string) error

+ func (ctn *ColumnTypeName) String() string

+ func (ctn *ColumnTypeName) Type() string

+ type CreateCatalog struct

+ Comment string

+ Name string

+ Properties map[string]string

+ ProviderName string

+ ShareName string

+ StorageRoot string

+ type CreateExternalLocation struct

+ Comment string

+ CredentialName string

+ Name string

+ ReadOnly bool

+ SkipValidation bool

+ Url string

+ type CreateFunction struct

+ CatalogName string

+ Comment string

+ DataType ColumnTypeName

+ ExternalLanguage string

+ ExternalName string

+ FullDataType string

+ InputParams []FunctionParameterInfo

+ IsDeterministic bool

+ IsNullCall bool

+ Name string

+ ParameterStyle CreateFunctionParameterStyle

+ Properties map[string]string

+ ReturnParams []FunctionParameterInfo

+ RoutineBody CreateFunctionRoutineBody

+ RoutineDefinition string

+ RoutineDependencies []Dependency

+ SchemaName string

+ SecurityType CreateFunctionSecurityType

+ SpecificName string

+ SqlDataAccess CreateFunctionSqlDataAccess

+ SqlPath string

+ type CreateFunctionParameterStyle string

+ const CreateFunctionParameterStyleS

+ func (cfps *CreateFunctionParameterStyle) Set(v string) error

+ func (cfps *CreateFunctionParameterStyle) String() string

+ func (cfps *CreateFunctionParameterStyle) Type() string

+ type CreateFunctionRoutineBody string

+ const CreateFunctionRoutineBodyExternal

+ const CreateFunctionRoutineBodySql

+ func (cfrb *CreateFunctionRoutineBody) Set(v string) error

+ func (cfrb *CreateFunctionRoutineBody) String() string

+ func (cfrb *CreateFunctionRoutineBody) Type() string

+ type CreateFunctionSecurityType string

+ const CreateFunctionSecurityTypeDefiner

+ func (cfst *CreateFunctionSecurityType) Set(v string) error

+ func (cfst *CreateFunctionSecurityType) String() string

+ func (cfst *CreateFunctionSecurityType) Type() string

+ type CreateFunctionSqlDataAccess string

+ const CreateFunctionSqlDataAccessContainsSql

+ const CreateFunctionSqlDataAccessNoSql

+ const CreateFunctionSqlDataAccessReadsSqlData

+ func (cfsda *CreateFunctionSqlDataAccess) Set(v string) error

+ func (cfsda *CreateFunctionSqlDataAccess) String() string

+ func (cfsda *CreateFunctionSqlDataAccess) Type() string

+ type CreateMetastore struct

+ Name string

+ Region string

+ StorageRoot string

+ type CreateMetastoreAssignment struct

+ DefaultCatalogName string

+ MetastoreId string

+ WorkspaceId int64

+ type CreateSchema struct

+ CatalogName string

+ Comment string

+ Name string

+ Properties map[string]string

+ StorageRoot string

+ type CreateStorageCredential struct

+ AwsIamRole *AwsIamRole

+ AzureServicePrincipal *AzureServicePrincipal

+ Comment string

+ GcpServiceAccountKey *GcpServiceAccountKey

+ MetastoreId string

+ Name string

+ ReadOnly bool

+ SkipValidation bool

+ type CreateTableConstraint struct

+ Constraint TableConstraint

+ FullNameArg string

+ type CreateVolumeRequestContent struct

+ CatalogName string

+ Comment string

+ Name string

+ SchemaName string

+ StorageLocation string

+ VolumeType VolumeType

+ type DataSourceFormat string

+ const DataSourceFormatAvro

+ const DataSourceFormatCsv

+ const DataSourceFormatDelta

+ const DataSourceFormatDeltasharing

+ const DataSourceFormatJson

+ const DataSourceFormatOrc

+ const DataSourceFormatParquet

+ const DataSourceFormatText

+ const DataSourceFormatUnityCatalog

+ func (dsf *DataSourceFormat) Set(v string) error

+ func (dsf *DataSourceFormat) String() string

+ func (dsf *DataSourceFormat) Type() string

+ type DeleteAccountMetastoreAssignmentRequest struct

+ MetastoreId string

+ WorkspaceId int64

+ type DeleteAccountMetastoreRequest struct

+ MetastoreId string

+ type DeleteCatalogRequest struct

+ Force bool

+ Name string

+ type DeleteExternalLocationRequest struct

+ Force bool

+ Name string

+ type DeleteFunctionRequest struct

+ Force bool

+ Name string

+ type DeleteMetastoreRequest struct

+ Force bool

+ Id string

+ type DeleteSchemaRequest struct

+ FullName string

+ type DeleteStorageCredentialRequest struct

+ Force bool

+ Name string

+ type DeleteTableConstraintRequest struct

+ Cascade bool

+ ConstraintName string

+ FullName string

+ type DeleteTableRequest struct

+ FullName string

+ type DeleteVolumeRequest struct

+ FullNameArg string

+ type Dependency struct

+ Function *FunctionDependency

+ Table *TableDependency

+ type EffectiveAutoMaintenanceFlag struct

+ InheritedFromName string

+ InheritedFromType EffectiveAutoMaintenanceFlagInheritedFromType

+ Value EnableAutoMaintenance

+ type EffectiveAutoMaintenanceFlagInheritedFromType string

+ const EffectiveAutoMaintenanceFlagInheritedFromTypeCatalog

+ const EffectiveAutoMaintenanceFlagInheritedFromTypeSchema

+ func (eamfift *EffectiveAutoMaintenanceFlagInheritedFromType) Set(v string) error

+ func (eamfift *EffectiveAutoMaintenanceFlagInheritedFromType) String() string

+ func (eamfift *EffectiveAutoMaintenanceFlagInheritedFromType) Type() string

+ type EffectivePermissionsList struct

+ PrivilegeAssignments []EffectivePrivilegeAssignment

+ type EffectivePrivilege struct

+ InheritedFromName string

+ InheritedFromType SecurableType

+ Privilege Privilege

+ type EffectivePrivilegeAssignment struct

+ Principal string

+ Privileges []EffectivePrivilege

+ type EnableAutoMaintenance string

+ const EnableAutoMaintenanceDisable

+ const EnableAutoMaintenanceEnable

+ const EnableAutoMaintenanceInherit

+ func (eam *EnableAutoMaintenance) Set(v string) error

+ func (eam *EnableAutoMaintenance) String() string

+ func (eam *EnableAutoMaintenance) Type() string

+ type ExternalLocationInfo struct

+ Comment string

+ CreatedAt int64

+ CreatedBy string

+ CredentialId string

+ CredentialName string

+ MetastoreId string

+ Name string

+ Owner string

+ ReadOnly bool

+ UpdatedAt int64

+ UpdatedBy string

+ Url string

+ type ExternalLocationsAPI struct

+ func NewExternalLocations(client *client.DatabricksClient) *ExternalLocationsAPI

+ func (a *ExternalLocationsAPI) Create(ctx context.Context, request CreateExternalLocation) (*ExternalLocationInfo, error)

+ func (a *ExternalLocationsAPI) Delete(ctx context.Context, request DeleteExternalLocationRequest) error

+ func (a *ExternalLocationsAPI) DeleteByName(ctx context.Context, name string) error

+ func (a *ExternalLocationsAPI) Get(ctx context.Context, request GetExternalLocationRequest) (*ExternalLocationInfo, error)

+ func (a *ExternalLocationsAPI) GetByName(ctx context.Context, name string) (*ExternalLocationInfo, error)

+ func (a *ExternalLocationsAPI) Impl() ExternalLocationsService

+ func (a *ExternalLocationsAPI) ListAll(ctx context.Context) ([]ExternalLocationInfo, error)

+ func (a *ExternalLocationsAPI) Update(ctx context.Context, request UpdateExternalLocation) (*ExternalLocationInfo, error)

+ func (a *ExternalLocationsAPI) WithImpl(impl ExternalLocationsService) *ExternalLocationsAPI

+ type ExternalLocationsService interface

+ Create func(ctx context.Context, request CreateExternalLocation) (*ExternalLocationInfo, error)

+ Delete func(ctx context.Context, request DeleteExternalLocationRequest) error

+ Get func(ctx context.Context, request GetExternalLocationRequest) (*ExternalLocationInfo, error)

+ List func(ctx context.Context) (*ListExternalLocationsResponse, error)

+ Update func(ctx context.Context, request UpdateExternalLocation) (*ExternalLocationInfo, error)

+ type ForeignKeyConstraint struct

+ ChildColumns []string

+ Name string

+ ParentColumns []string

+ ParentTable string

+ type FunctionDependency struct

+ FunctionFullName string

+ type FunctionInfo struct

+ CatalogName string

+ Comment string

+ CreatedAt int64

+ CreatedBy string

+ DataType ColumnTypeName

+ ExternalLanguage string

+ ExternalName string

+ FullDataType string

+ FullName string

+ FunctionId string

+ InputParams []FunctionParameterInfo

+ IsDeterministic bool

+ IsNullCall bool

+ MetastoreId string

+ Name string

+ Owner string

+ ParameterStyle FunctionInfoParameterStyle

+ Properties map[string]string

+ ReturnParams []FunctionParameterInfo

+ RoutineBody FunctionInfoRoutineBody

+ RoutineDefinition string

+ RoutineDependencies []Dependency

+ SchemaName string

+ SecurityType FunctionInfoSecurityType

+ SpecificName string

+ SqlDataAccess FunctionInfoSqlDataAccess

+ SqlPath string

+ UpdatedAt int64

+ UpdatedBy string

+ type FunctionInfoParameterStyle string

+ const FunctionInfoParameterStyleS

+ func (fips *FunctionInfoParameterStyle) Set(v string) error

+ func (fips *FunctionInfoParameterStyle) String() string

+ func (fips *FunctionInfoParameterStyle) Type() string

+ type FunctionInfoRoutineBody string

+ const FunctionInfoRoutineBodyExternal

+ const FunctionInfoRoutineBodySql

+ func (firb *FunctionInfoRoutineBody) Set(v string) error

+ func (firb *FunctionInfoRoutineBody) String() string

+ func (firb *FunctionInfoRoutineBody) Type() string

+ type FunctionInfoSecurityType string

+ const FunctionInfoSecurityTypeDefiner

+ func (fist *FunctionInfoSecurityType) Set(v string) error

+ func (fist *FunctionInfoSecurityType) String() string

+ func (fist *FunctionInfoSecurityType) Type() string

+ type FunctionInfoSqlDataAccess string

+ const FunctionInfoSqlDataAccessContainsSql

+ const FunctionInfoSqlDataAccessNoSql

+ const FunctionInfoSqlDataAccessReadsSqlData

+ func (fisda *FunctionInfoSqlDataAccess) Set(v string) error

+ func (fisda *FunctionInfoSqlDataAccess) String() string

+ func (fisda *FunctionInfoSqlDataAccess) Type() string

+ type FunctionParameterInfo struct

+ Comment string

+ Name string

+ ParameterDefault string

+ ParameterMode FunctionParameterMode

+ ParameterType FunctionParameterType

+ Position int

+ TypeIntervalType string

+ TypeJson string

+ TypeName ColumnTypeName

+ TypePrecision int

+ TypeScale int

+ TypeText string

+ type FunctionParameterMode string

+ const FunctionParameterModeIn

+ func (fpm *FunctionParameterMode) Set(v string) error

+ func (fpm *FunctionParameterMode) String() string

+ func (fpm *FunctionParameterMode) Type() string

+ type FunctionParameterType string

+ const FunctionParameterTypeColumn

+ const FunctionParameterTypeParam

+ func (fpt *FunctionParameterType) Set(v string) error

+ func (fpt *FunctionParameterType) String() string

+ func (fpt *FunctionParameterType) Type() string

+ type FunctionsAPI struct

+ func NewFunctions(client *client.DatabricksClient) *FunctionsAPI

+ func (a *FunctionsAPI) Create(ctx context.Context, request CreateFunction) (*FunctionInfo, error)

+ func (a *FunctionsAPI) Delete(ctx context.Context, request DeleteFunctionRequest) error

+ func (a *FunctionsAPI) DeleteByName(ctx context.Context, name string) error

+ func (a *FunctionsAPI) Get(ctx context.Context, request GetFunctionRequest) (*FunctionInfo, error)

+ func (a *FunctionsAPI) GetByName(ctx context.Context, name string) (*FunctionInfo, error)

+ func (a *FunctionsAPI) Impl() FunctionsService

+ func (a *FunctionsAPI) List(ctx context.Context, request ListFunctionsRequest) (*ListFunctionsResponse, error)

+ func (a *FunctionsAPI) Update(ctx context.Context, request UpdateFunction) (*FunctionInfo, error)

+ func (a *FunctionsAPI) WithImpl(impl FunctionsService) *FunctionsAPI

+ type FunctionsService interface

+ Create func(ctx context.Context, request CreateFunction) (*FunctionInfo, error)

+ Delete func(ctx context.Context, request DeleteFunctionRequest) error

+ Get func(ctx context.Context, request GetFunctionRequest) (*FunctionInfo, error)

+ List func(ctx context.Context, request ListFunctionsRequest) (*ListFunctionsResponse, error)

+ Update func(ctx context.Context, request UpdateFunction) (*FunctionInfo, error)

+ type GcpServiceAccountKey struct

+ Email string

+ PrivateKey string

+ PrivateKeyId string

+ type GetAccountMetastoreAssignmentRequest struct

+ WorkspaceId int64

+ type GetAccountMetastoreRequest struct

+ MetastoreId string

+ type GetAccountStorageCredentialRequest struct

+ MetastoreId string

+ Name string

+ type GetCatalogRequest struct

+ Name string

+ type GetEffectiveRequest struct

+ FullName string

+ Principal string

+ SecurableType SecurableType

+ type GetExternalLocationRequest struct

+ Name string

+ type GetFunctionRequest struct

+ Name string

+ type GetGrantRequest struct

+ FullName string

+ Principal string

+ SecurableType SecurableType

+ type GetMetastoreRequest struct

+ Id string

+ type GetMetastoreSummaryResponse struct

+ Cloud string

+ CreatedAt int64

+ CreatedBy string

+ DefaultDataAccessConfigId string

+ DeltaSharingOrganizationName string

+ DeltaSharingRecipientTokenLifetimeInSeconds int64

+ DeltaSharingScope GetMetastoreSummaryResponseDeltaSharingScope

+ GlobalMetastoreId string

+ MetastoreId string

+ Name string

+ Owner string

+ PrivilegeModelVersion string

+ Region string

+ StorageRoot string

+ StorageRootCredentialId string

+ StorageRootCredentialName string

+ UpdatedAt int64

+ UpdatedBy string

+ type GetMetastoreSummaryResponseDeltaSharingScope string

+ const GetMetastoreSummaryResponseDeltaSharingScopeInternal

+ const GetMetastoreSummaryResponseDeltaSharingScopeInternalAndExternal

+ func (gmsrdss *GetMetastoreSummaryResponseDeltaSharingScope) Set(v string) error

+ func (gmsrdss *GetMetastoreSummaryResponseDeltaSharingScope) String() string

+ func (gmsrdss *GetMetastoreSummaryResponseDeltaSharingScope) Type() string

+ type GetSchemaRequest struct

+ FullName string

+ type GetStorageCredentialRequest struct

+ Name string

+ type GetTableRequest struct

+ FullName string

+ IncludeDeltaMetadata bool

+ type GrantsAPI struct

+ func NewGrants(client *client.DatabricksClient) *GrantsAPI

+ func (a *GrantsAPI) Get(ctx context.Context, request GetGrantRequest) (*PermissionsList, error)

+ func (a *GrantsAPI) GetBySecurableTypeAndFullName(ctx context.Context, securableType SecurableType, fullName string) (*PermissionsList, error)

+ func (a *GrantsAPI) GetEffective(ctx context.Context, request GetEffectiveRequest) (*EffectivePermissionsList, error)

+ func (a *GrantsAPI) GetEffectiveBySecurableTypeAndFullName(ctx context.Context, securableType SecurableType, fullName string) (*EffectivePermissionsList, error)

+ func (a *GrantsAPI) Impl() GrantsService

+ func (a *GrantsAPI) Update(ctx context.Context, request UpdatePermissions) (*PermissionsList, error)

+ func (a *GrantsAPI) WithImpl(impl GrantsService) *GrantsAPI

+ type GrantsService interface

+ Get func(ctx context.Context, request GetGrantRequest) (*PermissionsList, error)

+ GetEffective func(ctx context.Context, request GetEffectiveRequest) (*EffectivePermissionsList, error)

+ Update func(ctx context.Context, request UpdatePermissions) (*PermissionsList, error)

+ type ListAccountMetastoreAssignmentsRequest struct

+ MetastoreId string

+ type ListAccountStorageCredentialsRequest struct

+ MetastoreId string

+ type ListCatalogsResponse struct

+ Catalogs []CatalogInfo

+ type ListExternalLocationsResponse struct

+ ExternalLocations []ExternalLocationInfo

+ type ListFunctionsRequest struct

+ CatalogName string

+ SchemaName string

+ type ListFunctionsResponse struct

+ Schemas []FunctionInfo

+ type ListMetastoresResponse struct

+ Metastores []MetastoreInfo

+ type ListSchemasRequest struct

+ CatalogName string

+ type ListSchemasResponse struct

+ Schemas []SchemaInfo

+ type ListSummariesRequest struct

+ CatalogName string

+ MaxResults int

+ PageToken string

+ SchemaNamePattern string

+ TableNamePattern string

+ type ListTableSummariesResponse struct

+ NextPageToken string

+ Tables []TableSummary

+ type ListTablesRequest struct

+ CatalogName string

+ IncludeDeltaMetadata bool

+ MaxResults int

+ PageToken string

+ SchemaName string

+ type ListTablesResponse struct

+ NextPageToken string

+ Tables []TableInfo

+ type ListVolumesRequest struct

+ CatalogName string

+ SchemaName string

+ type ListVolumesResponseContent struct

+ Volumes []VolumeInfo

+ type MetastoreAssignment struct

+ DefaultCatalogName string

+ MetastoreId string

+ WorkspaceId string

+ type MetastoreInfo struct

+ Cloud string

+ CreatedAt int64

+ CreatedBy string

+ DefaultDataAccessConfigId string

+ DeltaSharingOrganizationName string

+ DeltaSharingRecipientTokenLifetimeInSeconds int64

+ DeltaSharingScope MetastoreInfoDeltaSharingScope

+ GlobalMetastoreId string

+ MetastoreId string

+ Name string

+ Owner string

+ PrivilegeModelVersion string

+ Region string

+ StorageRoot string

+ StorageRootCredentialId string

+ StorageRootCredentialName string

+ UpdatedAt int64

+ UpdatedBy string

+ type MetastoreInfoDeltaSharingScope string

+ const MetastoreInfoDeltaSharingScopeInternal

+ const MetastoreInfoDeltaSharingScopeInternalAndExternal

+ func (midss *MetastoreInfoDeltaSharingScope) Set(v string) error

+ func (midss *MetastoreInfoDeltaSharingScope) String() string

+ func (midss *MetastoreInfoDeltaSharingScope) Type() string

+ type MetastoresAPI struct

+ func NewMetastores(client *client.DatabricksClient) *MetastoresAPI

+ func (a *MetastoresAPI) Assign(ctx context.Context, request CreateMetastoreAssignment) error

+ func (a *MetastoresAPI) Create(ctx context.Context, request CreateMetastore) (*MetastoreInfo, error)

+ func (a *MetastoresAPI) Current(ctx context.Context) (*MetastoreAssignment, error)

+ func (a *MetastoresAPI) Delete(ctx context.Context, request DeleteMetastoreRequest) error

+ func (a *MetastoresAPI) DeleteById(ctx context.Context, id string) error

+ func (a *MetastoresAPI) Get(ctx context.Context, request GetMetastoreRequest) (*MetastoreInfo, error)

+ func (a *MetastoresAPI) GetById(ctx context.Context, id string) (*MetastoreInfo, error)

+ func (a *MetastoresAPI) GetByName(ctx context.Context, name string) (*MetastoreInfo, error)

+ func (a *MetastoresAPI) Impl() MetastoresService

+ func (a *MetastoresAPI) ListAll(ctx context.Context) ([]MetastoreInfo, error)

+ func (a *MetastoresAPI) Maintenance(ctx context.Context, request UpdateAutoMaintenance) (*UpdateAutoMaintenanceResponse, error)

+ func (a *MetastoresAPI) MetastoreInfoNameToMetastoreIdMap(ctx context.Context) (map[string]string, error)

+ func (a *MetastoresAPI) Summary(ctx context.Context) (*GetMetastoreSummaryResponse, error)

+ func (a *MetastoresAPI) Unassign(ctx context.Context, request UnassignRequest) error

+ func (a *MetastoresAPI) UnassignByWorkspaceId(ctx context.Context, workspaceId int64) error

+ func (a *MetastoresAPI) Update(ctx context.Context, request UpdateMetastore) (*MetastoreInfo, error)

+ func (a *MetastoresAPI) UpdateAssignment(ctx context.Context, request UpdateMetastoreAssignment) error

+ func (a *MetastoresAPI) WithImpl(impl MetastoresService) *MetastoresAPI

+ type MetastoresService interface

+ Assign func(ctx context.Context, request CreateMetastoreAssignment) error

+ Create func(ctx context.Context, request CreateMetastore) (*MetastoreInfo, error)

+ Current func(ctx context.Context) (*MetastoreAssignment, error)

+ Delete func(ctx context.Context, request DeleteMetastoreRequest) error

+ Get func(ctx context.Context, request GetMetastoreRequest) (*MetastoreInfo, error)

+ List func(ctx context.Context) (*ListMetastoresResponse, error)

+ Maintenance func(ctx context.Context, request UpdateAutoMaintenance) (*UpdateAutoMaintenanceResponse, error)

+ Summary func(ctx context.Context) (*GetMetastoreSummaryResponse, error)

+ Unassign func(ctx context.Context, request UnassignRequest) error

+ Update func(ctx context.Context, request UpdateMetastore) (*MetastoreInfo, error)

+ UpdateAssignment func(ctx context.Context, request UpdateMetastoreAssignment) error

+ type NamedTableConstraint struct

+ Name string

+ type PermissionsChange struct

+ Add []Privilege

+ Principal string

+ Remove []Privilege

+ type PermissionsList struct

+ PrivilegeAssignments []PrivilegeAssignment

+ type PrimaryKeyConstraint struct

+ ChildColumns []string

+ Name string

+ type Privilege string

+ const PrivilegeAllPrivileges

+ const PrivilegeCreate

+ const PrivilegeCreateCatalog

+ const PrivilegeCreateExternalLocation

+ const PrivilegeCreateExternalTable

+ const PrivilegeCreateFunction

+ const PrivilegeCreateManagedStorage

+ const PrivilegeCreateMaterializedView

+ const PrivilegeCreateProvider

+ const PrivilegeCreateRecipient

+ const PrivilegeCreateSchema

+ const PrivilegeCreateShare

+ const PrivilegeCreateStorageCredential

+ const PrivilegeCreateTable

+ const PrivilegeCreateView

+ const PrivilegeExecute

+ const PrivilegeModify

+ const PrivilegeReadFiles

+ const PrivilegeReadPrivateFiles

+ const PrivilegeRefresh

+ const PrivilegeSelect

+ const PrivilegeSetSharePermission

+ const PrivilegeUsage

+ const PrivilegeUseCatalog

+ const PrivilegeUseProvider

+ const PrivilegeUseRecipient

+ const PrivilegeUseSchema

+ const PrivilegeUseShare

+ const PrivilegeWriteFiles

+ const PrivilegeWritePrivateFiles

+ func (p *Privilege) Set(v string) error

+ func (p *Privilege) String() string

+ func (p *Privilege) Type() string

+ type PrivilegeAssignment struct

+ Principal string

+ Privileges []Privilege

+ type ReadVolumeRequest struct

+ FullNameArg string

+ type SchemaInfo struct

+ CatalogName string

+ CatalogType string

+ Comment string

+ CreatedAt int64

+ CreatedBy string

+ EffectiveAutoMaintenanceFlag *EffectiveAutoMaintenanceFlag

+ EnableAutoMaintenance EnableAutoMaintenance

+ FullName string

+ MetastoreId string

+ Name string

+ Owner string

+ Properties map[string]string

+ StorageLocation string

+ StorageRoot string

+ UpdatedAt int64

+ UpdatedBy string

+ type SchemasAPI struct

+ func NewSchemas(client *client.DatabricksClient) *SchemasAPI

+ func (a *SchemasAPI) Create(ctx context.Context, request CreateSchema) (*SchemaInfo, error)

+ func (a *SchemasAPI) Delete(ctx context.Context, request DeleteSchemaRequest) error

+ func (a *SchemasAPI) DeleteByFullName(ctx context.Context, fullName string) error

+ func (a *SchemasAPI) Get(ctx context.Context, request GetSchemaRequest) (*SchemaInfo, error)

+ func (a *SchemasAPI) GetByFullName(ctx context.Context, fullName string) (*SchemaInfo, error)

+ func (a *SchemasAPI) GetByName(ctx context.Context, name string) (*SchemaInfo, error)

+ func (a *SchemasAPI) Impl() SchemasService

+ func (a *SchemasAPI) ListAll(ctx context.Context, request ListSchemasRequest) ([]SchemaInfo, error)

+ func (a *SchemasAPI) SchemaInfoNameToFullNameMap(ctx context.Context, request ListSchemasRequest) (map[string]string, error)

+ func (a *SchemasAPI) Update(ctx context.Context, request UpdateSchema) (*SchemaInfo, error)

+ func (a *SchemasAPI) WithImpl(impl SchemasService) *SchemasAPI

+ type SchemasService interface

+ Create func(ctx context.Context, request CreateSchema) (*SchemaInfo, error)

+ Delete func(ctx context.Context, request DeleteSchemaRequest) error

+ Get func(ctx context.Context, request GetSchemaRequest) (*SchemaInfo, error)

+ List func(ctx context.Context, request ListSchemasRequest) (*ListSchemasResponse, error)

+ Update func(ctx context.Context, request UpdateSchema) (*SchemaInfo, error)

+ type SecurablePropertiesMap map[string]string

+ type SecurableType string

+ const SecurableTypeCatalog

+ const SecurableTypeExternalLocation

+ const SecurableTypeFunction

+ const SecurableTypeMetastore

+ const SecurableTypeProvider

+ const SecurableTypeRecipient

+ const SecurableTypeSchema

+ const SecurableTypeShare

+ const SecurableTypeStorageCredential

+ const SecurableTypeTable

+ func (st *SecurableType) Set(v string) error

+ func (st *SecurableType) String() string

+ func (st *SecurableType) Type() string

+ type StorageCredentialInfo struct

+ AwsIamRole *AwsIamRole

+ AzureServicePrincipal *AzureServicePrincipal

+ Comment string

+ CreatedAt int64

+ CreatedBy string

+ GcpServiceAccountKey *GcpServiceAccountKey

+ Id string

+ MetastoreId string

+ Name string

+ Owner string

+ ReadOnly bool

+ UpdatedAt int64

+ UpdatedBy string

+ UsedForManagedStorage bool

+ type StorageCredentialsAPI struct

+ func NewStorageCredentials(client *client.DatabricksClient) *StorageCredentialsAPI

+ func (a *StorageCredentialsAPI) Create(ctx context.Context, request CreateStorageCredential) (*StorageCredentialInfo, error)

+ func (a *StorageCredentialsAPI) Delete(ctx context.Context, request DeleteStorageCredentialRequest) error

+ func (a *StorageCredentialsAPI) DeleteByName(ctx context.Context, name string) error

+ func (a *StorageCredentialsAPI) Get(ctx context.Context, request GetStorageCredentialRequest) (*StorageCredentialInfo, error)

+ func (a *StorageCredentialsAPI) GetByName(ctx context.Context, name string) (*StorageCredentialInfo, error)

+ func (a *StorageCredentialsAPI) Impl() StorageCredentialsService

+ func (a *StorageCredentialsAPI) List(ctx context.Context) ([]StorageCredentialInfo, error)

+ func (a *StorageCredentialsAPI) StorageCredentialInfoNameToIdMap(ctx context.Context) (map[string]string, error)

+ func (a *StorageCredentialsAPI) Update(ctx context.Context, request UpdateStorageCredential) (*StorageCredentialInfo, error)

+ func (a *StorageCredentialsAPI) Validate(ctx context.Context, request ValidateStorageCredential) (*ValidateStorageCredentialResponse, error)

+ func (a *StorageCredentialsAPI) WithImpl(impl StorageCredentialsService) *StorageCredentialsAPI

+ type StorageCredentialsService interface

+ Create func(ctx context.Context, request CreateStorageCredential) (*StorageCredentialInfo, error)

+ Delete func(ctx context.Context, request DeleteStorageCredentialRequest) error

+ Get func(ctx context.Context, request GetStorageCredentialRequest) (*StorageCredentialInfo, error)

+ List func(ctx context.Context) ([]StorageCredentialInfo, error)

+ Update func(ctx context.Context, request UpdateStorageCredential) (*StorageCredentialInfo, error)

+ Validate func(ctx context.Context, request ValidateStorageCredential) (*ValidateStorageCredentialResponse, error)

+ type TableConstraint struct

+ ForeignKeyConstraint *ForeignKeyConstraint

+ NamedTableConstraint *NamedTableConstraint

+ PrimaryKeyConstraint *PrimaryKeyConstraint

+ type TableConstraintList struct

+ TableConstraints []TableConstraint

+ type TableConstraintsAPI struct

+ func NewTableConstraints(client *client.DatabricksClient) *TableConstraintsAPI

+ func (a *TableConstraintsAPI) Create(ctx context.Context, request CreateTableConstraint) (*TableConstraint, error)

+ func (a *TableConstraintsAPI) Delete(ctx context.Context, request DeleteTableConstraintRequest) error

+ func (a *TableConstraintsAPI) DeleteByFullName(ctx context.Context, fullName string) error

+ func (a *TableConstraintsAPI) Impl() TableConstraintsService

+ func (a *TableConstraintsAPI) WithImpl(impl TableConstraintsService) *TableConstraintsAPI

+ type TableConstraintsService interface

+ Create func(ctx context.Context, request CreateTableConstraint) (*TableConstraint, error)

+ Delete func(ctx context.Context, request DeleteTableConstraintRequest) error

+ type TableDependency struct

+ TableFullName string

+ type TableInfo struct

+ CatalogName string

+ Columns []ColumnInfo

+ Comment string

+ CreatedAt int64

+ CreatedBy string

+ DataAccessConfigurationId string

+ DataSourceFormat DataSourceFormat

+ DeletedAt int64

+ DeltaRuntimePropertiesKvpairs any

+ EffectiveAutoMaintenanceFlag *EffectiveAutoMaintenanceFlag

+ EnableAutoMaintenance EnableAutoMaintenance

+ FullName string

+ MetastoreId string

+ Name string

+ Owner string

+ Properties map[string]string

+ RowFilter *TableRowFilter

+ SchemaName string

+ SqlPath string

+ StorageCredentialName string

+ StorageLocation string

+ TableConstraints *TableConstraintList

+ TableId string

+ TableType TableType

+ UpdatedAt int64

+ UpdatedBy string

+ ViewDefinition string

+ ViewDependencies []Dependency

+ type TableRowFilter struct

+ InputColumnNames []string

+ Name string

+ type TableSummary struct

+ FullName string

+ TableType TableType

+ type TableType string

+ const TableTypeExternal

+ const TableTypeManaged

+ const TableTypeMaterializedView

+ const TableTypeStreamingTable

+ const TableTypeView

+ func (tt *TableType) Set(v string) error

+ func (tt *TableType) String() string

+ func (tt *TableType) Type() string

+ type TablesAPI struct

+ func NewTables(client *client.DatabricksClient) *TablesAPI

+ func (a *TablesAPI) Delete(ctx context.Context, request DeleteTableRequest) error

+ func (a *TablesAPI) DeleteByFullName(ctx context.Context, fullName string) error

+ func (a *TablesAPI) Get(ctx context.Context, request GetTableRequest) (*TableInfo, error)

+ func (a *TablesAPI) GetByFullName(ctx context.Context, fullName string) (*TableInfo, error)

+ func (a *TablesAPI) GetByName(ctx context.Context, name string) (*TableInfo, error)

+ func (a *TablesAPI) Impl() TablesService

+ func (a *TablesAPI) ListAll(ctx context.Context, request ListTablesRequest) ([]TableInfo, error)

+ func (a *TablesAPI) ListSummaries(ctx context.Context, request ListSummariesRequest) (*ListTableSummariesResponse, error)

+ func (a *TablesAPI) TableInfoNameToTableIdMap(ctx context.Context, request ListTablesRequest) (map[string]string, error)

+ func (a *TablesAPI) WithImpl(impl TablesService) *TablesAPI

+ type TablesService interface

+ Delete func(ctx context.Context, request DeleteTableRequest) error

+ Get func(ctx context.Context, request GetTableRequest) (*TableInfo, error)

+ List func(ctx context.Context, request ListTablesRequest) (*ListTablesResponse, error)

+ ListSummaries func(ctx context.Context, request ListSummariesRequest) (*ListTableSummariesResponse, error)

+ type UnassignRequest struct

+ MetastoreId string

+ WorkspaceId int64

+ type UpdateAutoMaintenance struct

+ Enable bool

+ MetastoreId string

+ type UpdateAutoMaintenanceResponse struct

+ State bool

+ UserId int64

+ Username string

+ type UpdateCatalog struct

+ Comment string

+ Name string

+ Owner string

+ Properties map[string]string

+ type UpdateExternalLocation struct

+ Comment string

+ CredentialName string

+ Force bool

+ Name string

+ Owner string

+ ReadOnly bool

+ Url string

+ type UpdateFunction struct

+ Name string

+ Owner string

+ type UpdateMetastore struct

+ DeltaSharingOrganizationName string

+ DeltaSharingRecipientTokenLifetimeInSeconds int64

+ DeltaSharingScope UpdateMetastoreDeltaSharingScope

+ Id string

+ MetastoreId string

+ Name string

+ Owner string

+ PrivilegeModelVersion string

+ StorageRootCredentialId string

+ type UpdateMetastoreAssignment struct

+ DefaultCatalogName string

+ MetastoreId string

+ WorkspaceId int64

+ type UpdateMetastoreDeltaSharingScope string

+ const UpdateMetastoreDeltaSharingScopeInternal

+ const UpdateMetastoreDeltaSharingScopeInternalAndExternal

+ func (umdss *UpdateMetastoreDeltaSharingScope) Set(v string) error

+ func (umdss *UpdateMetastoreDeltaSharingScope) String() string

+ func (umdss *UpdateMetastoreDeltaSharingScope) Type() string

+ type UpdatePermissions struct

+ Changes []PermissionsChange

+ FullName string

+ SecurableType SecurableType

+ type UpdateSchema struct

+ Comment string

+ FullName string

+ Name string

+ Owner string

+ Properties map[string]string

+ type UpdateStorageCredential struct

+ AwsIamRole *AwsIamRole

+ AzureServicePrincipal *AzureServicePrincipal

+ Comment string

+ Force bool

+ GcpServiceAccountKey *GcpServiceAccountKey

+ Name string

+ Owner string

+ ReadOnly bool

+ SkipValidation bool

+ type UpdateVolumeRequestContent struct

+ Comment string

+ FullNameArg string

+ Name string

+ Owner string

+ type ValidateStorageCredential struct

+ AwsIamRole *AwsIamRole

+ AzureServicePrincipal *AzureServicePrincipal

+ ExternalLocationName string

+ GcpServiceAccountKey *GcpServiceAccountKey

+ ReadOnly bool

+ StorageCredentialName any

+ Url string

+ type ValidateStorageCredentialResponse struct

+ IsDir bool

+ Results []ValidationResult

+ type ValidationResult struct

+ Message string

+ Operation ValidationResultOperation

+ Result ValidationResultResult

+ type ValidationResultOperation string

+ const ValidationResultOperationDelete

+ const ValidationResultOperationList

+ const ValidationResultOperationRead

+ const ValidationResultOperationWrite

+ func (vro *ValidationResultOperation) Set(v string) error

+ func (vro *ValidationResultOperation) String() string

+ func (vro *ValidationResultOperation) Type() string

+ type ValidationResultResult string

+ const ValidationResultResultFail

+ const ValidationResultResultPass

+ const ValidationResultResultSkip

+ func (vrr *ValidationResultResult) Set(v string) error

+ func (vrr *ValidationResultResult) String() string

+ func (vrr *ValidationResultResult) Type() string

+ type VolumeInfo struct

+ CatalogName string

+ Comment string

+ CreatedAt int64

+ CreatedBy string

+ FullName string

+ MetastoreId string

+ Name string

+ Owner string

+ SchemaName string

+ StorageLocation string

+ UpdatedAt int64

+ UpdatedBy string

+ VolumeId string

+ VolumeType VolumeType

+ type VolumeType string

+ const VolumeTypeExternal

+ const VolumeTypeManaged

+ func (vt *VolumeType) Set(v string) error

+ func (vt *VolumeType) String() string

+ func (vt *VolumeType) Type() string

+ type VolumesAPI struct

+ func NewVolumes(client *client.DatabricksClient) *VolumesAPI

+ func (a *VolumesAPI) Create(ctx context.Context, request CreateVolumeRequestContent) (*VolumeInfo, error)

+ func (a *VolumesAPI) Delete(ctx context.Context, request DeleteVolumeRequest) error

+ func (a *VolumesAPI) DeleteByFullNameArg(ctx context.Context, fullNameArg string) error

+ func (a *VolumesAPI) GetByName(ctx context.Context, name string) (*VolumeInfo, error)

+ func (a *VolumesAPI) Impl() VolumesService

+ func (a *VolumesAPI) ListAll(ctx context.Context, request ListVolumesRequest) ([]VolumeInfo, error)

+ func (a *VolumesAPI) Read(ctx context.Context, request ReadVolumeRequest) (*VolumeInfo, error)

+ func (a *VolumesAPI) ReadByFullNameArg(ctx context.Context, fullNameArg string) (*VolumeInfo, error)

+ func (a *VolumesAPI) Update(ctx context.Context, request UpdateVolumeRequestContent) (*VolumeInfo, error)

+ func (a *VolumesAPI) VolumeInfoNameToVolumeIdMap(ctx context.Context, request ListVolumesRequest) (map[string]string, error)

+ func (a *VolumesAPI) WithImpl(impl VolumesService) *VolumesAPI

+ type VolumesService interface

+ Create func(ctx context.Context, request CreateVolumeRequestContent) (*VolumeInfo, error)

+ Delete func(ctx context.Context, request DeleteVolumeRequest) error

+ List func(ctx context.Context, request ListVolumesRequest) (*ListVolumesResponseContent, error)

+ Read func(ctx context.Context, request ReadVolumeRequest) (*VolumeInfo, error)

+ Update func(ctx context.Context, request UpdateVolumeRequestContent) (*VolumeInfo, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL