database

package

Go to main page

Versions in this module

v0

v0.95.0

Dec 17, 2025

v0.94.0

Dec 11, 2025

v0.93.0

Dec 3, 2025

Changes in this version

type DeleteSyncedDatabaseTableRequest

+ ForceSendFields []string

+ PurgeData bool

v0.92.0

Nov 20, 2025

Changes in this version

type NewPipelineSpec

+ BudgetPolicyId string

v0.91.0

Nov 13, 2025

v0.90.0

Nov 3, 2025

v0.89.0

Oct 30, 2025

v0.88.0

Oct 23, 2025

v0.87.0

Oct 20, 2025

v0.86.0

Oct 13, 2025

Changes in this version

type CreateDatabaseInstanceRoleRequest

+ DatabaseInstanceName string

+ ForceSendFields []string

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

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

+ type CustomTag struct

+ ForceSendFields []string

+ Key string

+ Value string

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

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

type DatabaseInstance

+ CustomTags []CustomTag

+ EffectiveCustomTags []CustomTag

+ EffectiveUsagePolicyId string

+ UsagePolicyId string

type DatabaseInstanceRole

+ EffectiveAttributes *DatabaseInstanceRoleAttributes

+ InstanceName string

v0.85.0

Sep 23, 2025

v0.84.0

Sep 18, 2025

Changes in this version

type DatabaseInstance

+ EffectiveCapacity string

v0.83.0

Sep 8, 2025

v0.82.0

Aug 31, 2025

Changes in this version

type DatabaseInstance

+ EffectiveEnablePgNativeLogin bool

+ EnablePgNativeLogin bool

v0.81.0

Aug 20, 2025

v0.80.0

Aug 13, 2025

Changes in this version

type DatabaseAPI

+ func (a *DatabaseAPI) ListDatabaseCatalogs(ctx context.Context, request ListDatabaseCatalogsRequest) listing.Iterator[DatabaseCatalog]

+ func (a *DatabaseAPI) ListDatabaseCatalogsAll(ctx context.Context, request ListDatabaseCatalogsRequest) ([]DatabaseCatalog, error)

+ func (a *DatabaseAPI) ListDatabaseCatalogsByInstanceName(ctx context.Context, instanceName string) (*ListDatabaseCatalogsResponse, error)

+ func (a *DatabaseAPI) ListSyncedDatabaseTables(ctx context.Context, request ListSyncedDatabaseTablesRequest) listing.Iterator[SyncedDatabaseTable]

+ func (a *DatabaseAPI) ListSyncedDatabaseTablesAll(ctx context.Context, request ListSyncedDatabaseTablesRequest) ([]SyncedDatabaseTable, error)

+ func (a *DatabaseAPI) ListSyncedDatabaseTablesByInstanceName(ctx context.Context, instanceName string) (*ListSyncedDatabaseTablesResponse, error)

+ func (a *DatabaseAPI) UpdateDatabaseCatalog(ctx context.Context, request UpdateDatabaseCatalogRequest) (*DatabaseCatalog, error)

+ func (a *DatabaseAPI) UpdateSyncedDatabaseTable(ctx context.Context, request UpdateSyncedDatabaseTableRequest) (*SyncedDatabaseTable, error)

type DatabaseInterface

+ ListDatabaseCatalogs func(ctx context.Context, request ListDatabaseCatalogsRequest) listing.Iterator[DatabaseCatalog]

+ ListDatabaseCatalogsAll func(ctx context.Context, request ListDatabaseCatalogsRequest) ([]DatabaseCatalog, error)

+ ListDatabaseCatalogsByInstanceName func(ctx context.Context, instanceName string) (*ListDatabaseCatalogsResponse, error)

+ ListSyncedDatabaseTables func(ctx context.Context, request ListSyncedDatabaseTablesRequest) listing.Iterator[SyncedDatabaseTable]

+ ListSyncedDatabaseTablesAll func(ctx context.Context, request ListSyncedDatabaseTablesRequest) ([]SyncedDatabaseTable, error)

+ ListSyncedDatabaseTablesByInstanceName func(ctx context.Context, instanceName string) (*ListSyncedDatabaseTablesResponse, error)

+ UpdateDatabaseCatalog func(ctx context.Context, request UpdateDatabaseCatalogRequest) (*DatabaseCatalog, error)

+ UpdateSyncedDatabaseTable func(ctx context.Context, request UpdateSyncedDatabaseTableRequest) (*SyncedDatabaseTable, error)

type DatabaseService

+ ListDatabaseCatalogs func(ctx context.Context, request ListDatabaseCatalogsRequest) (*ListDatabaseCatalogsResponse, error)

+ ListSyncedDatabaseTables func(ctx context.Context, request ListSyncedDatabaseTablesRequest) (*ListSyncedDatabaseTablesResponse, error)

+ UpdateDatabaseCatalog func(ctx context.Context, request UpdateDatabaseCatalogRequest) (*DatabaseCatalog, error)

+ UpdateSyncedDatabaseTable func(ctx context.Context, request UpdateSyncedDatabaseTableRequest) (*SyncedDatabaseTable, error)

+ type ListDatabaseCatalogsRequest struct

+ ForceSendFields []string

+ InstanceName string

+ PageSize int

+ PageToken string

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

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

+ type ListDatabaseCatalogsResponse struct

+ DatabaseCatalogs []DatabaseCatalog

+ ForceSendFields []string

+ NextPageToken string

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

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

+ type ListSyncedDatabaseTablesRequest struct

+ ForceSendFields []string

+ InstanceName string

+ PageSize int

+ PageToken string

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

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

+ type ListSyncedDatabaseTablesResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ SyncedTables []SyncedDatabaseTable

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

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

+ type UpdateDatabaseCatalogRequest struct

+ DatabaseCatalog DatabaseCatalog

+ Name string

+ UpdateMask string

+ type UpdateSyncedDatabaseTableRequest struct

+ Name string

+ SyncedTable SyncedDatabaseTable

+ UpdateMask string

v0.79.0

Aug 6, 2025

Changes in this version

type SyncedDatabaseTable

+ EffectiveDatabaseInstanceName string

+ EffectiveLogicalDatabaseName string

v0.78.0

Jul 31, 2025

Changes in this version

type DatabaseAPI

+ func (a *DatabaseAPI) CreateDatabaseInstanceAndWait(ctx context.Context, ...) (*DatabaseInstance, error)

+ func (a *DatabaseAPI) WaitGetDatabaseInstanceDatabaseAvailable(ctx context.Context, name string, timeout time.Duration, ...) (*DatabaseInstance, error)

type DatabaseInterface

+ CreateDatabaseInstanceAndWait func(ctx context.Context, ...) (*DatabaseInstance, error)

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

+ type WaitGetDatabaseInstanceDatabaseAvailable struct

+ Name string

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

+ Response *R

+ func (w *WaitGetDatabaseInstanceDatabaseAvailable[R]) Get() (*DatabaseInstance, error)

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

+ func (w *WaitGetDatabaseInstanceDatabaseAvailable[R]) OnProgress(callback func(*DatabaseInstance)) *WaitGetDatabaseInstanceDatabaseAvailable[R]

v0.77.0

Jul 24, 2025

Changes in this version

+ type ProvisioningPhase string

+ const ProvisioningPhaseProvisioningPhaseIndexScan

+ const ProvisioningPhaseProvisioningPhaseIndexSort

+ const ProvisioningPhaseProvisioningPhaseMain

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

+ func (f *ProvisioningPhase) String() string

+ func (f *ProvisioningPhase) Type() string

+ func (f *ProvisioningPhase) Values() []ProvisioningPhase

type SyncedTablePipelineProgress

+ ProvisioningPhase ProvisioningPhase

v0.76.0

Jul 17, 2025

v0.75.0

Jul 10, 2025

v0.74.0

Jul 3, 2025

Changes in this version

+ type CreateDatabaseInstanceRoleRequest struct

+ DatabaseInstanceRole DatabaseInstanceRole

+ InstanceName string

type DatabaseAPI

+ func (a *DatabaseAPI) CreateDatabaseInstanceRole(ctx context.Context, request CreateDatabaseInstanceRoleRequest) (*DatabaseInstanceRole, error)

+ func (a *DatabaseAPI) DeleteDatabaseInstanceRole(ctx context.Context, request DeleteDatabaseInstanceRoleRequest) error

+ func (a *DatabaseAPI) DeleteDatabaseInstanceRoleByInstanceNameAndName(ctx context.Context, instanceName string, name string) error

+ func (a *DatabaseAPI) GetDatabaseInstanceRole(ctx context.Context, request GetDatabaseInstanceRoleRequest) (*DatabaseInstanceRole, error)

+ func (a *DatabaseAPI) GetDatabaseInstanceRoleByInstanceNameAndName(ctx context.Context, instanceName string, name string) (*DatabaseInstanceRole, error)

+ func (a *DatabaseAPI) ListDatabaseInstanceRoles(ctx context.Context, request ListDatabaseInstanceRolesRequest) listing.Iterator[DatabaseInstanceRole]

+ func (a *DatabaseAPI) ListDatabaseInstanceRolesAll(ctx context.Context, request ListDatabaseInstanceRolesRequest) ([]DatabaseInstanceRole, error)

+ func (a *DatabaseAPI) ListDatabaseInstanceRolesByInstanceName(ctx context.Context, instanceName string) (*ListDatabaseInstanceRolesResponse, error)

type DatabaseInstance

+ ChildInstanceRefs []DatabaseInstanceRef

+ EffectiveEnableReadableSecondaries bool

+ EffectiveNodeCount int

+ EffectiveRetentionWindowInDays int

+ EnableReadableSecondaries bool

+ NodeCount int

+ ParentInstanceRef *DatabaseInstanceRef

+ ReadOnlyDns string

+ RetentionWindowInDays int

+ type DatabaseInstanceRef struct

+ BranchTime string

+ EffectiveLsn string

+ ForceSendFields []string

+ Lsn string

+ Name string

+ Uid string

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

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

+ type DatabaseInstanceRole struct

+ Attributes *DatabaseInstanceRoleAttributes

+ ForceSendFields []string

+ IdentityType DatabaseInstanceRoleIdentityType

+ MembershipRole DatabaseInstanceRoleMembershipRole

+ Name string

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

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

+ type DatabaseInstanceRoleAttributes struct

+ Bypassrls bool

+ Createdb bool

+ Createrole bool

+ ForceSendFields []string

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

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

+ type DatabaseInstanceRoleIdentityType string

+ const DatabaseInstanceRoleIdentityTypeGroup

+ const DatabaseInstanceRoleIdentityTypePgOnly

+ const DatabaseInstanceRoleIdentityTypeServicePrincipal

+ const DatabaseInstanceRoleIdentityTypeUser

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

+ func (f *DatabaseInstanceRoleIdentityType) String() string

+ func (f *DatabaseInstanceRoleIdentityType) Type() string

+ func (f *DatabaseInstanceRoleIdentityType) Values() []DatabaseInstanceRoleIdentityType

+ type DatabaseInstanceRoleMembershipRole string

+ const DatabaseInstanceRoleMembershipRoleDatabricksSuperuser

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

+ func (f *DatabaseInstanceRoleMembershipRole) String() string

+ func (f *DatabaseInstanceRoleMembershipRole) Type() string

+ func (f *DatabaseInstanceRoleMembershipRole) Values() []DatabaseInstanceRoleMembershipRole

type DatabaseInterface

+ CreateDatabaseInstanceRole func(ctx context.Context, request CreateDatabaseInstanceRoleRequest) (*DatabaseInstanceRole, error)

+ DeleteDatabaseInstanceRole func(ctx context.Context, request DeleteDatabaseInstanceRoleRequest) error

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

+ GetDatabaseInstanceRole func(ctx context.Context, request GetDatabaseInstanceRoleRequest) (*DatabaseInstanceRole, error)

+ GetDatabaseInstanceRoleByInstanceNameAndName func(ctx context.Context, instanceName string, name string) (*DatabaseInstanceRole, error)

+ ListDatabaseInstanceRoles func(ctx context.Context, request ListDatabaseInstanceRolesRequest) listing.Iterator[DatabaseInstanceRole]

+ ListDatabaseInstanceRolesAll func(ctx context.Context, request ListDatabaseInstanceRolesRequest) ([]DatabaseInstanceRole, error)

+ ListDatabaseInstanceRolesByInstanceName func(ctx context.Context, instanceName string) (*ListDatabaseInstanceRolesResponse, error)

type DatabaseService

+ CreateDatabaseInstanceRole func(ctx context.Context, request CreateDatabaseInstanceRoleRequest) (*DatabaseInstanceRole, error)

+ DeleteDatabaseInstanceRole func(ctx context.Context, request DeleteDatabaseInstanceRoleRequest) error

+ GetDatabaseInstanceRole func(ctx context.Context, request GetDatabaseInstanceRoleRequest) (*DatabaseInstanceRole, error)

+ ListDatabaseInstanceRoles func(ctx context.Context, request ListDatabaseInstanceRolesRequest) (*ListDatabaseInstanceRolesResponse, error)

+ type DeleteDatabaseInstanceRoleRequest struct

+ AllowMissing bool

+ ForceSendFields []string

+ InstanceName string

+ Name string

+ ReassignOwnedTo string

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

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

+ type DeleteDatabaseInstanceRoleResponse struct

+ type DeltaTableSyncInfo struct

+ DeltaCommitTimestamp string

+ DeltaCommitVersion int64

+ ForceSendFields []string

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

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

type GenerateDatabaseCredentialRequest

+ Claims []RequestedClaims

+ type GetDatabaseInstanceRoleRequest struct

+ InstanceName string

+ Name string

+ type ListDatabaseInstanceRolesRequest struct

+ ForceSendFields []string

+ InstanceName string

+ PageSize int

+ PageToken string

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

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

+ type ListDatabaseInstanceRolesResponse struct

+ DatabaseInstanceRoles []DatabaseInstanceRole

+ ForceSendFields []string

+ NextPageToken string

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

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

+ type RequestedClaims struct

+ PermissionSet RequestedClaimsPermissionSet

+ Resources []RequestedResource

+ type RequestedClaimsPermissionSet string

+ const RequestedClaimsPermissionSetReadOnly

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

+ func (f *RequestedClaimsPermissionSet) String() string

+ func (f *RequestedClaimsPermissionSet) Type() string

+ func (f *RequestedClaimsPermissionSet) Values() []RequestedClaimsPermissionSet

+ type RequestedResource struct

+ ForceSendFields []string

+ TableName string

+ UnspecifiedResourceName string

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

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

+ type SyncedTablePosition struct

+ DeltaTableSyncInfo *DeltaTableSyncInfo

+ ForceSendFields []string

+ SyncEndTimestamp string

+ SyncStartTimestamp string

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

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

type SyncedTableStatus

+ LastSync *SyncedTablePosition

v0.73.1

Jun 20, 2025

v0.73.0

Jun 19, 2025

Changes in this version

type CreateDatabaseCatalogRequest

+ func (st *CreateDatabaseCatalogRequest) UnmarshalJSON(b []byte) error

+ func (st CreateDatabaseCatalogRequest) MarshalJSON() ([]byte, error)

type CreateDatabaseInstanceRequest

+ func (st *CreateDatabaseInstanceRequest) UnmarshalJSON(b []byte) error

+ func (st CreateDatabaseInstanceRequest) MarshalJSON() ([]byte, error)

type CreateDatabaseTableRequest

+ func (st *CreateDatabaseTableRequest) UnmarshalJSON(b []byte) error

+ func (st CreateDatabaseTableRequest) MarshalJSON() ([]byte, error)

type CreateSyncedDatabaseTableRequest

+ func (st *CreateSyncedDatabaseTableRequest) UnmarshalJSON(b []byte) error

+ func (st CreateSyncedDatabaseTableRequest) MarshalJSON() ([]byte, error)

type DatabaseCredential

+ ExpirationTime string

type DatabaseInstance

+ EffectiveStopped bool

type DeleteDatabaseCatalogRequest

+ func (st *DeleteDatabaseCatalogRequest) UnmarshalJSON(b []byte) error

+ func (st DeleteDatabaseCatalogRequest) MarshalJSON() ([]byte, error)

type DeleteDatabaseCatalogResponse

+ func (st *DeleteDatabaseCatalogResponse) UnmarshalJSON(b []byte) error

+ func (st DeleteDatabaseCatalogResponse) MarshalJSON() ([]byte, error)

type DeleteDatabaseInstanceResponse

+ func (st *DeleteDatabaseInstanceResponse) UnmarshalJSON(b []byte) error

+ func (st DeleteDatabaseInstanceResponse) MarshalJSON() ([]byte, error)

type DeleteDatabaseTableRequest

+ func (st *DeleteDatabaseTableRequest) UnmarshalJSON(b []byte) error

+ func (st DeleteDatabaseTableRequest) MarshalJSON() ([]byte, error)

type DeleteDatabaseTableResponse

+ func (st *DeleteDatabaseTableResponse) UnmarshalJSON(b []byte) error

+ func (st DeleteDatabaseTableResponse) MarshalJSON() ([]byte, error)

type DeleteSyncedDatabaseTableRequest

+ func (st *DeleteSyncedDatabaseTableRequest) UnmarshalJSON(b []byte) error

+ func (st DeleteSyncedDatabaseTableRequest) MarshalJSON() ([]byte, error)

type DeleteSyncedDatabaseTableResponse

+ func (st *DeleteSyncedDatabaseTableResponse) UnmarshalJSON(b []byte) error

+ func (st DeleteSyncedDatabaseTableResponse) MarshalJSON() ([]byte, error)

type GetDatabaseCatalogRequest

+ func (st *GetDatabaseCatalogRequest) UnmarshalJSON(b []byte) error

+ func (st GetDatabaseCatalogRequest) MarshalJSON() ([]byte, error)

type GetDatabaseInstanceRequest

+ func (st *GetDatabaseInstanceRequest) UnmarshalJSON(b []byte) error

+ func (st GetDatabaseInstanceRequest) MarshalJSON() ([]byte, error)

type GetDatabaseTableRequest

+ func (st *GetDatabaseTableRequest) UnmarshalJSON(b []byte) error

+ func (st GetDatabaseTableRequest) MarshalJSON() ([]byte, error)

type GetSyncedDatabaseTableRequest

+ func (st *GetSyncedDatabaseTableRequest) UnmarshalJSON(b []byte) error

+ func (st GetSyncedDatabaseTableRequest) MarshalJSON() ([]byte, error)

type SyncedTableProvisioningStatus

+ func (st *SyncedTableProvisioningStatus) UnmarshalJSON(b []byte) error

+ func (st SyncedTableProvisioningStatus) MarshalJSON() ([]byte, error)

type SyncedTableSpec

+ ExistingPipelineId string

type SyncedTableStatus

+ PipelineId string

type UpdateDatabaseInstanceRequest

+ func (st *UpdateDatabaseInstanceRequest) UnmarshalJSON(b []byte) error

+ func (st UpdateDatabaseInstanceRequest) MarshalJSON() ([]byte, error)

v0.72.0

Jun 5, 2025

Changes in this version

+ type CreateDatabaseCatalogRequest struct

+ Catalog DatabaseCatalog

+ type CreateDatabaseInstanceRequest struct

+ DatabaseInstance DatabaseInstance

+ type CreateDatabaseTableRequest struct

+ Table DatabaseTable

+ type CreateSyncedDatabaseTableRequest struct

+ SyncedTable SyncedDatabaseTable

+ type DatabaseAPI struct

+ func NewDatabase(client *client.DatabricksClient) *DatabaseAPI

+ func (a *DatabaseAPI) CreateDatabaseCatalog(ctx context.Context, request CreateDatabaseCatalogRequest) (*DatabaseCatalog, error)

+ func (a *DatabaseAPI) CreateDatabaseInstance(ctx context.Context, request CreateDatabaseInstanceRequest) (*DatabaseInstance, error)

+ func (a *DatabaseAPI) CreateDatabaseTable(ctx context.Context, request CreateDatabaseTableRequest) (*DatabaseTable, error)

+ func (a *DatabaseAPI) CreateSyncedDatabaseTable(ctx context.Context, request CreateSyncedDatabaseTableRequest) (*SyncedDatabaseTable, error)

+ func (a *DatabaseAPI) DeleteDatabaseCatalog(ctx context.Context, request DeleteDatabaseCatalogRequest) error

+ func (a *DatabaseAPI) DeleteDatabaseCatalogByName(ctx context.Context, name string) error

+ func (a *DatabaseAPI) DeleteDatabaseInstance(ctx context.Context, request DeleteDatabaseInstanceRequest) error

+ func (a *DatabaseAPI) DeleteDatabaseInstanceByName(ctx context.Context, name string) error

+ func (a *DatabaseAPI) DeleteDatabaseTable(ctx context.Context, request DeleteDatabaseTableRequest) error

+ func (a *DatabaseAPI) DeleteDatabaseTableByName(ctx context.Context, name string) error

+ func (a *DatabaseAPI) DeleteSyncedDatabaseTable(ctx context.Context, request DeleteSyncedDatabaseTableRequest) error

+ func (a *DatabaseAPI) DeleteSyncedDatabaseTableByName(ctx context.Context, name string) error

+ func (a *DatabaseAPI) FindDatabaseInstanceByUid(ctx context.Context, request FindDatabaseInstanceByUidRequest) (*DatabaseInstance, error)

+ func (a *DatabaseAPI) GenerateDatabaseCredential(ctx context.Context, request GenerateDatabaseCredentialRequest) (*DatabaseCredential, error)

+ func (a *DatabaseAPI) GetDatabaseCatalog(ctx context.Context, request GetDatabaseCatalogRequest) (*DatabaseCatalog, error)

+ func (a *DatabaseAPI) GetDatabaseCatalogByName(ctx context.Context, name string) (*DatabaseCatalog, error)

+ func (a *DatabaseAPI) GetDatabaseInstance(ctx context.Context, request GetDatabaseInstanceRequest) (*DatabaseInstance, error)

+ func (a *DatabaseAPI) GetDatabaseInstanceByName(ctx context.Context, name string) (*DatabaseInstance, error)

+ func (a *DatabaseAPI) GetDatabaseTable(ctx context.Context, request GetDatabaseTableRequest) (*DatabaseTable, error)

+ func (a *DatabaseAPI) GetDatabaseTableByName(ctx context.Context, name string) (*DatabaseTable, error)

+ func (a *DatabaseAPI) GetSyncedDatabaseTable(ctx context.Context, request GetSyncedDatabaseTableRequest) (*SyncedDatabaseTable, error)

+ func (a *DatabaseAPI) GetSyncedDatabaseTableByName(ctx context.Context, name string) (*SyncedDatabaseTable, error)

+ func (a *DatabaseAPI) ListDatabaseInstances(ctx context.Context, request ListDatabaseInstancesRequest) listing.Iterator[DatabaseInstance]

+ func (a *DatabaseAPI) ListDatabaseInstancesAll(ctx context.Context, request ListDatabaseInstancesRequest) ([]DatabaseInstance, error)

+ func (a *DatabaseAPI) UpdateDatabaseInstance(ctx context.Context, request UpdateDatabaseInstanceRequest) (*DatabaseInstance, error)

+ type DatabaseCatalog struct

+ CreateDatabaseIfNotExists bool

+ DatabaseInstanceName string

+ DatabaseName string

+ ForceSendFields []string

+ Name string

+ Uid string

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

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

+ type DatabaseCredential struct

+ ForceSendFields []string

+ Token string

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

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

+ type DatabaseInstance struct

+ Capacity string

+ CreationTime string

+ Creator string

+ ForceSendFields []string

+ Name string

+ PgVersion string

+ ReadWriteDns string

+ State DatabaseInstanceState

+ Stopped bool

+ Uid string

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

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

+ type DatabaseInstanceState string

+ const DatabaseInstanceStateAvailable

+ const DatabaseInstanceStateDeleting

+ const DatabaseInstanceStateFailingOver

+ const DatabaseInstanceStateStarting

+ const DatabaseInstanceStateStopped

+ const DatabaseInstanceStateUpdating

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

+ func (f *DatabaseInstanceState) String() string

+ func (f *DatabaseInstanceState) Type() string

+ func (f *DatabaseInstanceState) Values() []DatabaseInstanceState

+ type DatabaseInterface interface

+ CreateDatabaseCatalog func(ctx context.Context, request CreateDatabaseCatalogRequest) (*DatabaseCatalog, error)

+ CreateDatabaseInstance func(ctx context.Context, request CreateDatabaseInstanceRequest) (*DatabaseInstance, error)

+ CreateDatabaseTable func(ctx context.Context, request CreateDatabaseTableRequest) (*DatabaseTable, error)

+ CreateSyncedDatabaseTable func(ctx context.Context, request CreateSyncedDatabaseTableRequest) (*SyncedDatabaseTable, error)

+ DeleteDatabaseCatalog func(ctx context.Context, request DeleteDatabaseCatalogRequest) error

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

+ DeleteDatabaseInstance func(ctx context.Context, request DeleteDatabaseInstanceRequest) error

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

+ DeleteDatabaseTable func(ctx context.Context, request DeleteDatabaseTableRequest) error

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

+ DeleteSyncedDatabaseTable func(ctx context.Context, request DeleteSyncedDatabaseTableRequest) error

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

+ FindDatabaseInstanceByUid func(ctx context.Context, request FindDatabaseInstanceByUidRequest) (*DatabaseInstance, error)

+ GenerateDatabaseCredential func(ctx context.Context, request GenerateDatabaseCredentialRequest) (*DatabaseCredential, error)

+ GetDatabaseCatalog func(ctx context.Context, request GetDatabaseCatalogRequest) (*DatabaseCatalog, error)

+ GetDatabaseCatalogByName func(ctx context.Context, name string) (*DatabaseCatalog, error)

+ GetDatabaseInstance func(ctx context.Context, request GetDatabaseInstanceRequest) (*DatabaseInstance, error)

+ GetDatabaseInstanceByName func(ctx context.Context, name string) (*DatabaseInstance, error)

+ GetDatabaseTable func(ctx context.Context, request GetDatabaseTableRequest) (*DatabaseTable, error)

+ GetDatabaseTableByName func(ctx context.Context, name string) (*DatabaseTable, error)

+ GetSyncedDatabaseTable func(ctx context.Context, request GetSyncedDatabaseTableRequest) (*SyncedDatabaseTable, error)

+ GetSyncedDatabaseTableByName func(ctx context.Context, name string) (*SyncedDatabaseTable, error)

+ ListDatabaseInstances func(ctx context.Context, request ListDatabaseInstancesRequest) listing.Iterator[DatabaseInstance]

+ ListDatabaseInstancesAll func(ctx context.Context, request ListDatabaseInstancesRequest) ([]DatabaseInstance, error)

+ UpdateDatabaseInstance func(ctx context.Context, request UpdateDatabaseInstanceRequest) (*DatabaseInstance, error)

+ type DatabaseService interface

+ CreateDatabaseCatalog func(ctx context.Context, request CreateDatabaseCatalogRequest) (*DatabaseCatalog, error)

+ CreateDatabaseInstance func(ctx context.Context, request CreateDatabaseInstanceRequest) (*DatabaseInstance, error)

+ CreateDatabaseTable func(ctx context.Context, request CreateDatabaseTableRequest) (*DatabaseTable, error)

+ CreateSyncedDatabaseTable func(ctx context.Context, request CreateSyncedDatabaseTableRequest) (*SyncedDatabaseTable, error)

+ DeleteDatabaseCatalog func(ctx context.Context, request DeleteDatabaseCatalogRequest) error

+ DeleteDatabaseInstance func(ctx context.Context, request DeleteDatabaseInstanceRequest) error

+ DeleteDatabaseTable func(ctx context.Context, request DeleteDatabaseTableRequest) error

+ DeleteSyncedDatabaseTable func(ctx context.Context, request DeleteSyncedDatabaseTableRequest) error

+ FindDatabaseInstanceByUid func(ctx context.Context, request FindDatabaseInstanceByUidRequest) (*DatabaseInstance, error)

+ GenerateDatabaseCredential func(ctx context.Context, request GenerateDatabaseCredentialRequest) (*DatabaseCredential, error)

+ GetDatabaseCatalog func(ctx context.Context, request GetDatabaseCatalogRequest) (*DatabaseCatalog, error)

+ GetDatabaseInstance func(ctx context.Context, request GetDatabaseInstanceRequest) (*DatabaseInstance, error)

+ GetDatabaseTable func(ctx context.Context, request GetDatabaseTableRequest) (*DatabaseTable, error)

+ GetSyncedDatabaseTable func(ctx context.Context, request GetSyncedDatabaseTableRequest) (*SyncedDatabaseTable, error)

+ ListDatabaseInstances func(ctx context.Context, request ListDatabaseInstancesRequest) (*ListDatabaseInstancesResponse, error)

+ UpdateDatabaseInstance func(ctx context.Context, request UpdateDatabaseInstanceRequest) (*DatabaseInstance, error)

+ type DatabaseTable struct

+ DatabaseInstanceName string

+ ForceSendFields []string

+ LogicalDatabaseName string

+ Name string

+ TableServingUrl string

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

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

+ type DeleteDatabaseCatalogRequest struct

+ Name string

+ type DeleteDatabaseCatalogResponse struct

+ type DeleteDatabaseInstanceRequest struct

+ Force bool

+ ForceSendFields []string

+ Name string

+ Purge bool

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

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

+ type DeleteDatabaseInstanceResponse struct

+ type DeleteDatabaseTableRequest struct

+ Name string

+ type DeleteDatabaseTableResponse struct

+ type DeleteSyncedDatabaseTableRequest struct

+ Name string

+ type DeleteSyncedDatabaseTableResponse struct

+ type FindDatabaseInstanceByUidRequest struct

+ ForceSendFields []string

+ Uid string

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

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

+ type GenerateDatabaseCredentialRequest struct

+ ForceSendFields []string

+ InstanceNames []string

+ RequestId string

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

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

+ type GetDatabaseCatalogRequest struct

+ Name string

+ type GetDatabaseInstanceRequest struct

+ Name string

+ type GetDatabaseTableRequest struct

+ Name string

+ type GetSyncedDatabaseTableRequest struct

+ Name string

+ type ListDatabaseInstancesRequest struct

+ ForceSendFields []string

+ PageSize int

+ PageToken string

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

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

+ type ListDatabaseInstancesResponse struct

+ DatabaseInstances []DatabaseInstance

+ ForceSendFields []string

+ NextPageToken string

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

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

+ type NewPipelineSpec struct

+ ForceSendFields []string

+ StorageCatalog string

+ StorageSchema string

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

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

+ type ProvisioningInfoState string

+ const ProvisioningInfoStateActive

+ const ProvisioningInfoStateDegraded

+ const ProvisioningInfoStateDeleting

+ const ProvisioningInfoStateFailed

+ const ProvisioningInfoStateProvisioning

+ const ProvisioningInfoStateUpdating

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

+ func (f *ProvisioningInfoState) String() string

+ func (f *ProvisioningInfoState) Type() string

+ func (f *ProvisioningInfoState) Values() []ProvisioningInfoState

+ type SyncedDatabaseTable struct

+ DataSynchronizationStatus *SyncedTableStatus

+ DatabaseInstanceName string

+ ForceSendFields []string

+ LogicalDatabaseName string

+ Name string

+ Spec *SyncedTableSpec

+ TableServingUrl string

+ UnityCatalogProvisioningState ProvisioningInfoState

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

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

+ type SyncedTableContinuousUpdateStatus struct

+ ForceSendFields []string

+ InitialPipelineSyncProgress *SyncedTablePipelineProgress

+ LastProcessedCommitVersion int64

+ Timestamp string

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

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

+ type SyncedTableFailedStatus struct

+ ForceSendFields []string

+ LastProcessedCommitVersion int64

+ Timestamp string

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

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

+ type SyncedTablePipelineProgress struct

+ EstimatedCompletionTimeSeconds float64

+ ForceSendFields []string

+ LatestVersionCurrentlyProcessing int64

+ SyncProgressCompletion float64

+ SyncedRowCount int64

+ TotalRowCount int64

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

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

+ type SyncedTableProvisioningStatus struct

+ InitialPipelineSyncProgress *SyncedTablePipelineProgress

+ type SyncedTableSchedulingPolicy string

+ const SyncedTableSchedulingPolicyContinuous

+ const SyncedTableSchedulingPolicySnapshot

+ const SyncedTableSchedulingPolicyTriggered

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

+ func (f *SyncedTableSchedulingPolicy) String() string

+ func (f *SyncedTableSchedulingPolicy) Type() string

+ func (f *SyncedTableSchedulingPolicy) Values() []SyncedTableSchedulingPolicy

+ type SyncedTableSpec struct

+ CreateDatabaseObjectsIfMissing bool

+ ForceSendFields []string

+ NewPipelineSpec *NewPipelineSpec

+ PipelineId string

+ PrimaryKeyColumns []string

+ SchedulingPolicy SyncedTableSchedulingPolicy

+ SourceTableFullName string

+ TimeseriesKey string

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

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

+ type SyncedTableState string

+ const SyncedTableStateSyncedTableOfflineFailed

+ const SyncedTableStateSyncedTableOnline

+ const SyncedTableStateSyncedTableOnlineContinuousUpdate

+ const SyncedTableStateSyncedTableOnlineNoPendingUpdate

+ const SyncedTableStateSyncedTableOnlinePipelineFailed

+ const SyncedTableStateSyncedTableOnlineTriggeredUpdate

+ const SyncedTableStateSyncedTableOnlineUpdatingPipelineResources

+ const SyncedTableStateSyncedTableProvisioning

+ const SyncedTableStateSyncedTableProvisioningInitialSnapshot

+ const SyncedTableStateSyncedTableProvisioningPipelineResources

+ const SyncedTableStateSyncedTabledOffline

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

+ func (f *SyncedTableState) String() string

+ func (f *SyncedTableState) Type() string

+ func (f *SyncedTableState) Values() []SyncedTableState

+ type SyncedTableStatus struct

+ ContinuousUpdateStatus *SyncedTableContinuousUpdateStatus

+ DetailedState SyncedTableState

+ FailedStatus *SyncedTableFailedStatus

+ ForceSendFields []string

+ Message string

+ ProvisioningStatus *SyncedTableProvisioningStatus

+ TriggeredUpdateStatus *SyncedTableTriggeredUpdateStatus

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

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

+ type SyncedTableTriggeredUpdateStatus struct

+ ForceSendFields []string

+ LastProcessedCommitVersion int64

+ Timestamp string

+ TriggeredUpdateProgress *SyncedTablePipelineProgress

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

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

+ type UpdateDatabaseInstanceRequest struct

+ DatabaseInstance DatabaseInstance

+ Name string

+ UpdateMask string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL