Versions in this module Expand all Collapse all v0 v0.13.3 Jul 20, 2023 v0.13.2 Jul 20, 2023 Changes in this version + type AwsCredentials struct + StsRole *StsRole + type AwsKeyInfo struct + KeyAlias string + KeyArn string + KeyRegion string + ReuseKeyForClusterVolumes bool + type CloudResourceContainer struct + Gcp *CustomerFacingGcpCloudResourceContainer + type CreateAwsKeyInfo struct + KeyAlias string + KeyArn string + ReuseKeyForClusterVolumes bool + type CreateCredentialAwsCredentials struct + StsRole *CreateCredentialStsRole + type CreateCredentialRequest struct + AwsCredentials CreateCredentialAwsCredentials + CredentialsName string + type CreateCredentialStsRole struct + RoleArn string + type CreateCustomerManagedKeyRequest struct + AwsKeyInfo *CreateAwsKeyInfo + GcpKeyInfo *CreateGcpKeyInfo + UseCases []KeyUseCase + type CreateGcpKeyInfo struct + KmsKeyId string + type CreateNetworkRequest struct + GcpNetworkInfo *GcpNetworkInfo + NetworkName string + SecurityGroupIds []string + SubnetIds []string + VpcEndpoints *NetworkVpcEndpoints + VpcId string + type CreateStorageConfigurationRequest struct + RootBucketInfo RootBucketInfo + StorageConfigurationName string + type CreateVpcEndpointRequest struct + AwsVpcEndpointId string + GcpVpcEndpointInfo *GcpVpcEndpointInfo + Region string + VpcEndpointName string + type CreateWorkspaceRequest struct + AwsRegion string + Cloud string + CloudResourceContainer *CloudResourceContainer + CredentialsId string + DeploymentName string + Location string + ManagedServicesCustomerManagedKeyId string + NetworkId string + PricingTier PricingTier + PrivateAccessSettingsId string + StorageConfigurationId string + StorageCustomerManagedKeyId string + WorkspaceName string + type Credential struct + AccountId string + AwsCredentials *AwsCredentials + CreationTime int64 + CredentialsId string + CredentialsName string + type CredentialsAPI struct + func NewCredentials(client *client.DatabricksClient) *CredentialsAPI + func (a *CredentialsAPI) Create(ctx context.Context, request CreateCredentialRequest) (*Credential, error) + func (a *CredentialsAPI) CredentialCredentialsNameToCredentialsIdMap(ctx context.Context) (map[string]string, error) + func (a *CredentialsAPI) Delete(ctx context.Context, request DeleteCredentialRequest) error + func (a *CredentialsAPI) DeleteByCredentialsId(ctx context.Context, credentialsId string) error + func (a *CredentialsAPI) Get(ctx context.Context, request GetCredentialRequest) (*Credential, error) + func (a *CredentialsAPI) GetByCredentialsId(ctx context.Context, credentialsId string) (*Credential, error) + func (a *CredentialsAPI) GetByCredentialsName(ctx context.Context, name string) (*Credential, error) + func (a *CredentialsAPI) Impl() CredentialsService + func (a *CredentialsAPI) List(ctx context.Context) ([]Credential, error) + func (a *CredentialsAPI) WithImpl(impl CredentialsService) *CredentialsAPI + type CredentialsService interface + Create func(ctx context.Context, request CreateCredentialRequest) (*Credential, error) + Delete func(ctx context.Context, request DeleteCredentialRequest) error + Get func(ctx context.Context, request GetCredentialRequest) (*Credential, error) + List func(ctx context.Context) ([]Credential, error) + type CustomerFacingGcpCloudResourceContainer struct + ProjectId string + type CustomerManagedKey struct + AccountId string + AwsKeyInfo *AwsKeyInfo + CreationTime int64 + CustomerManagedKeyId string + GcpKeyInfo *GcpKeyInfo + UseCases []KeyUseCase + type DeleteCredentialRequest struct + CredentialsId string + type DeleteEncryptionKeyRequest struct + CustomerManagedKeyId string + type DeleteNetworkRequest struct + NetworkId string + type DeletePrivateAccesRequest struct + PrivateAccessSettingsId string + type DeleteStorageRequest struct + StorageConfigurationId string + type DeleteVpcEndpointRequest struct + VpcEndpointId string + type DeleteWorkspaceRequest struct + WorkspaceId int64 + type EncryptionKeysAPI struct + func NewEncryptionKeys(client *client.DatabricksClient) *EncryptionKeysAPI + func (a *EncryptionKeysAPI) Create(ctx context.Context, request CreateCustomerManagedKeyRequest) (*CustomerManagedKey, error) + func (a *EncryptionKeysAPI) Delete(ctx context.Context, request DeleteEncryptionKeyRequest) error + func (a *EncryptionKeysAPI) DeleteByCustomerManagedKeyId(ctx context.Context, customerManagedKeyId string) error + func (a *EncryptionKeysAPI) Get(ctx context.Context, request GetEncryptionKeyRequest) (*CustomerManagedKey, error) + func (a *EncryptionKeysAPI) GetByCustomerManagedKeyId(ctx context.Context, customerManagedKeyId string) (*CustomerManagedKey, error) + func (a *EncryptionKeysAPI) Impl() EncryptionKeysService + func (a *EncryptionKeysAPI) List(ctx context.Context) ([]CustomerManagedKey, error) + func (a *EncryptionKeysAPI) WithImpl(impl EncryptionKeysService) *EncryptionKeysAPI + type EncryptionKeysService interface + Create func(ctx context.Context, request CreateCustomerManagedKeyRequest) (*CustomerManagedKey, error) + Delete func(ctx context.Context, request DeleteEncryptionKeyRequest) error + Get func(ctx context.Context, request GetEncryptionKeyRequest) (*CustomerManagedKey, error) + List func(ctx context.Context) ([]CustomerManagedKey, error) + type EndpointUseCase string + const EndpointUseCaseDataplaneRelayAccess + const EndpointUseCaseWorkspaceAccess + func (f *EndpointUseCase) Set(v string) error + func (f *EndpointUseCase) String() string + func (f *EndpointUseCase) Type() string + type ErrorType string + const ErrorTypeCredentials + const ErrorTypeNetworkAcl + const ErrorTypeSecurityGroup + const ErrorTypeSubnet + const ErrorTypeVpc + func (f *ErrorType) Set(v string) error + func (f *ErrorType) String() string + func (f *ErrorType) Type() string + type GcpKeyInfo struct + KmsKeyId string + type GcpManagedNetworkConfig struct + GkeClusterPodIpRange string + GkeClusterServiceIpRange string + SubnetCidr string + type GcpNetworkInfo struct + NetworkProjectId string + PodIpRangeName string + ServiceIpRangeName string + SubnetId string + SubnetRegion string + VpcId string + type GcpVpcEndpointInfo struct + EndpointRegion string + ProjectId string + PscConnectionId string + PscEndpointName string + ServiceAttachmentId string + type GetCredentialRequest struct + CredentialsId string + type GetEncryptionKeyRequest struct + CustomerManagedKeyId string + type GetNetworkRequest struct + NetworkId string + type GetPrivateAccesRequest struct + PrivateAccessSettingsId string + type GetStorageRequest struct + StorageConfigurationId string + type GetVpcEndpointRequest struct + VpcEndpointId string + type GetWorkspaceRequest struct + WorkspaceId int64 + type GkeConfig struct + ConnectivityType GkeConfigConnectivityType + MasterIpRange string + type GkeConfigConnectivityType string + const GkeConfigConnectivityTypePrivateNodePublicMaster + const GkeConfigConnectivityTypePublicNodePublicMaster + func (f *GkeConfigConnectivityType) Set(v string) error + func (f *GkeConfigConnectivityType) String() string + func (f *GkeConfigConnectivityType) Type() string + type KeyUseCase string + const KeyUseCaseManagedServices + const KeyUseCaseStorage + func (f *KeyUseCase) Set(v string) error + func (f *KeyUseCase) String() string + func (f *KeyUseCase) Type() string + type Network struct + AccountId string + CreationTime int64 + ErrorMessages []NetworkHealth + GcpNetworkInfo *GcpNetworkInfo + NetworkId string + NetworkName string + SecurityGroupIds []string + SubnetIds []string + VpcEndpoints *NetworkVpcEndpoints + VpcId string + VpcStatus VpcStatus + WarningMessages []NetworkWarning + WorkspaceId int64 + type NetworkHealth struct + ErrorMessage string + ErrorType ErrorType + type NetworkVpcEndpoints struct + DataplaneRelay []string + RestApi []string + type NetworkWarning struct + WarningMessage string + WarningType WarningType + type NetworksAPI struct + func NewNetworks(client *client.DatabricksClient) *NetworksAPI + func (a *NetworksAPI) Create(ctx context.Context, request CreateNetworkRequest) (*Network, error) + func (a *NetworksAPI) Delete(ctx context.Context, request DeleteNetworkRequest) error + func (a *NetworksAPI) DeleteByNetworkId(ctx context.Context, networkId string) error + func (a *NetworksAPI) Get(ctx context.Context, request GetNetworkRequest) (*Network, error) + func (a *NetworksAPI) GetByNetworkId(ctx context.Context, networkId string) (*Network, error) + func (a *NetworksAPI) GetByNetworkName(ctx context.Context, name string) (*Network, error) + func (a *NetworksAPI) Impl() NetworksService + func (a *NetworksAPI) List(ctx context.Context) ([]Network, error) + func (a *NetworksAPI) NetworkNetworkNameToNetworkIdMap(ctx context.Context) (map[string]string, error) + func (a *NetworksAPI) WithImpl(impl NetworksService) *NetworksAPI + type NetworksService interface + Create func(ctx context.Context, request CreateNetworkRequest) (*Network, error) + Delete func(ctx context.Context, request DeleteNetworkRequest) error + Get func(ctx context.Context, request GetNetworkRequest) (*Network, error) + List func(ctx context.Context) ([]Network, error) + type PricingTier string + const PricingTierCommunityEdition + const PricingTierDedicated + const PricingTierEnterprise + const PricingTierPremium + const PricingTierStandard + const PricingTierUnknown + func (f *PricingTier) Set(v string) error + func (f *PricingTier) String() string + func (f *PricingTier) Type() string + type PrivateAccessAPI struct + func NewPrivateAccess(client *client.DatabricksClient) *PrivateAccessAPI + func (a *PrivateAccessAPI) Create(ctx context.Context, request UpsertPrivateAccessSettingsRequest) (*PrivateAccessSettings, error) + func (a *PrivateAccessAPI) Delete(ctx context.Context, request DeletePrivateAccesRequest) error + func (a *PrivateAccessAPI) DeleteByPrivateAccessSettingsId(ctx context.Context, privateAccessSettingsId string) error + func (a *PrivateAccessAPI) Get(ctx context.Context, request GetPrivateAccesRequest) (*PrivateAccessSettings, error) + func (a *PrivateAccessAPI) GetByPrivateAccessSettingsId(ctx context.Context, privateAccessSettingsId string) (*PrivateAccessSettings, error) + func (a *PrivateAccessAPI) GetByPrivateAccessSettingsName(ctx context.Context, name string) (*PrivateAccessSettings, error) + func (a *PrivateAccessAPI) Impl() PrivateAccessService + func (a *PrivateAccessAPI) List(ctx context.Context) ([]PrivateAccessSettings, error) + func (a *PrivateAccessAPI) PrivateAccessSettingsPrivateAccessSettingsNameToPrivateAccessSettingsIdMap(ctx context.Context) (map[string]string, error) + func (a *PrivateAccessAPI) Replace(ctx context.Context, request UpsertPrivateAccessSettingsRequest) error + func (a *PrivateAccessAPI) WithImpl(impl PrivateAccessService) *PrivateAccessAPI + type PrivateAccessLevel string + const PrivateAccessLevelAccount + const PrivateAccessLevelEndpoint + func (f *PrivateAccessLevel) Set(v string) error + func (f *PrivateAccessLevel) String() string + func (f *PrivateAccessLevel) Type() string + type PrivateAccessService interface + Create func(ctx context.Context, request UpsertPrivateAccessSettingsRequest) (*PrivateAccessSettings, error) + Delete func(ctx context.Context, request DeletePrivateAccesRequest) error + Get func(ctx context.Context, request GetPrivateAccesRequest) (*PrivateAccessSettings, error) + List func(ctx context.Context) ([]PrivateAccessSettings, error) + Replace func(ctx context.Context, request UpsertPrivateAccessSettingsRequest) error + type PrivateAccessSettings struct + AccountId string + AllowedVpcEndpointIds []string + PrivateAccessLevel PrivateAccessLevel + PrivateAccessSettingsId string + PrivateAccessSettingsName string + PublicAccessEnabled bool + Region string + type RootBucketInfo struct + BucketName string + type StorageAPI struct + func NewStorage(client *client.DatabricksClient) *StorageAPI + func (a *StorageAPI) Create(ctx context.Context, request CreateStorageConfigurationRequest) (*StorageConfiguration, error) + func (a *StorageAPI) Delete(ctx context.Context, request DeleteStorageRequest) error + func (a *StorageAPI) DeleteByStorageConfigurationId(ctx context.Context, storageConfigurationId string) error + func (a *StorageAPI) Get(ctx context.Context, request GetStorageRequest) (*StorageConfiguration, error) + func (a *StorageAPI) GetByStorageConfigurationId(ctx context.Context, storageConfigurationId string) (*StorageConfiguration, error) + func (a *StorageAPI) GetByStorageConfigurationName(ctx context.Context, name string) (*StorageConfiguration, error) + func (a *StorageAPI) Impl() StorageService + func (a *StorageAPI) List(ctx context.Context) ([]StorageConfiguration, error) + func (a *StorageAPI) StorageConfigurationStorageConfigurationNameToStorageConfigurationIdMap(ctx context.Context) (map[string]string, error) + func (a *StorageAPI) WithImpl(impl StorageService) *StorageAPI + type StorageConfiguration struct + AccountId string + CreationTime int64 + RootBucketInfo *RootBucketInfo + StorageConfigurationId string + StorageConfigurationName string + type StorageService interface + Create func(ctx context.Context, request CreateStorageConfigurationRequest) (*StorageConfiguration, error) + Delete func(ctx context.Context, request DeleteStorageRequest) error + Get func(ctx context.Context, request GetStorageRequest) (*StorageConfiguration, error) + List func(ctx context.Context) ([]StorageConfiguration, error) + type StsRole struct + ExternalId string + RoleArn string + type UpdateWorkspaceRequest struct + AwsRegion string + CredentialsId string + ManagedServicesCustomerManagedKeyId string + NetworkId string + StorageConfigurationId string + StorageCustomerManagedKeyId string + WorkspaceId int64 + type UpsertPrivateAccessSettingsRequest struct + AllowedVpcEndpointIds []string + PrivateAccessLevel PrivateAccessLevel + PrivateAccessSettingsId string + PrivateAccessSettingsName string + PublicAccessEnabled bool + Region string + type VpcEndpoint struct + AccountId string + AwsAccountId string + AwsEndpointServiceId string + AwsVpcEndpointId string + GcpVpcEndpointInfo *GcpVpcEndpointInfo + Region string + State string + UseCase EndpointUseCase + VpcEndpointId string + VpcEndpointName string + type VpcEndpointsAPI struct + func NewVpcEndpoints(client *client.DatabricksClient) *VpcEndpointsAPI + func (a *VpcEndpointsAPI) Create(ctx context.Context, request CreateVpcEndpointRequest) (*VpcEndpoint, error) + func (a *VpcEndpointsAPI) Delete(ctx context.Context, request DeleteVpcEndpointRequest) error + func (a *VpcEndpointsAPI) DeleteByVpcEndpointId(ctx context.Context, vpcEndpointId string) error + func (a *VpcEndpointsAPI) Get(ctx context.Context, request GetVpcEndpointRequest) (*VpcEndpoint, error) + func (a *VpcEndpointsAPI) GetByVpcEndpointId(ctx context.Context, vpcEndpointId string) (*VpcEndpoint, error) + func (a *VpcEndpointsAPI) GetByVpcEndpointName(ctx context.Context, name string) (*VpcEndpoint, error) + func (a *VpcEndpointsAPI) Impl() VpcEndpointsService + func (a *VpcEndpointsAPI) List(ctx context.Context) ([]VpcEndpoint, error) + func (a *VpcEndpointsAPI) VpcEndpointVpcEndpointNameToVpcEndpointIdMap(ctx context.Context) (map[string]string, error) + func (a *VpcEndpointsAPI) WithImpl(impl VpcEndpointsService) *VpcEndpointsAPI + type VpcEndpointsService interface + Create func(ctx context.Context, request CreateVpcEndpointRequest) (*VpcEndpoint, error) + Delete func(ctx context.Context, request DeleteVpcEndpointRequest) error + Get func(ctx context.Context, request GetVpcEndpointRequest) (*VpcEndpoint, error) + List func(ctx context.Context) ([]VpcEndpoint, error) + type VpcStatus string + const VpcStatusBroken + const VpcStatusUnattached + const VpcStatusValid + const VpcStatusWarned + func (f *VpcStatus) Set(v string) error + func (f *VpcStatus) String() string + func (f *VpcStatus) Type() string + type WaitGetWorkspaceRunning struct + Response *R + WorkspaceId int64 + func (w *WaitGetWorkspaceRunning[R]) Get() (*Workspace, error) + func (w *WaitGetWorkspaceRunning[R]) GetWithTimeout(timeout time.Duration) (*Workspace, error) + func (w *WaitGetWorkspaceRunning[R]) OnProgress(callback func(*Workspace)) *WaitGetWorkspaceRunning[R] + type WarningType string + const WarningTypeSecurityGroup + const WarningTypeSubnet + func (f *WarningType) Set(v string) error + func (f *WarningType) String() string + func (f *WarningType) Type() string + type Workspace struct + AccountId string + AwsRegion string + Cloud string + CloudResourceContainer *CloudResourceContainer + CreationTime int64 + CredentialsId string + DeploymentName string + GcpManagedNetworkConfig *GcpManagedNetworkConfig + GkeConfig *GkeConfig + Location string + ManagedServicesCustomerManagedKeyId string + NetworkId string + PricingTier PricingTier + PrivateAccessSettingsId string + StorageConfigurationId string + StorageCustomerManagedKeyId string + WorkspaceId int64 + WorkspaceName string + WorkspaceStatus WorkspaceStatus + WorkspaceStatusMessage string + type WorkspaceStatus string + const WorkspaceStatusBanned + const WorkspaceStatusCancelling + const WorkspaceStatusFailed + const WorkspaceStatusNotProvisioned + const WorkspaceStatusProvisioning + const WorkspaceStatusRunning + func (f *WorkspaceStatus) Set(v string) error + func (f *WorkspaceStatus) String() string + func (f *WorkspaceStatus) Type() string + type WorkspacesAPI struct + func NewWorkspaces(client *client.DatabricksClient) *WorkspacesAPI + func (a *WorkspacesAPI) Create(ctx context.Context, createWorkspaceRequest CreateWorkspaceRequest) (*WaitGetWorkspaceRunning[Workspace], error) + func (a *WorkspacesAPI) CreateAndWait(ctx context.Context, createWorkspaceRequest CreateWorkspaceRequest, ...) (*Workspace, error) + func (a *WorkspacesAPI) Delete(ctx context.Context, request DeleteWorkspaceRequest) error + func (a *WorkspacesAPI) DeleteByWorkspaceId(ctx context.Context, workspaceId int64) error + func (a *WorkspacesAPI) Get(ctx context.Context, request GetWorkspaceRequest) (*Workspace, error) + func (a *WorkspacesAPI) GetByWorkspaceId(ctx context.Context, workspaceId int64) (*Workspace, error) + func (a *WorkspacesAPI) GetByWorkspaceName(ctx context.Context, name string) (*Workspace, error) + func (a *WorkspacesAPI) Impl() WorkspacesService + func (a *WorkspacesAPI) List(ctx context.Context) ([]Workspace, error) + func (a *WorkspacesAPI) Update(ctx context.Context, updateWorkspaceRequest UpdateWorkspaceRequest) (*WaitGetWorkspaceRunning[any], error) + func (a *WorkspacesAPI) UpdateAndWait(ctx context.Context, updateWorkspaceRequest UpdateWorkspaceRequest, ...) (*Workspace, error) + func (a *WorkspacesAPI) WaitGetWorkspaceRunning(ctx context.Context, workspaceId int64, timeout time.Duration, ...) (*Workspace, error) + func (a *WorkspacesAPI) WithImpl(impl WorkspacesService) *WorkspacesAPI + func (a *WorkspacesAPI) WorkspaceWorkspaceNameToWorkspaceIdMap(ctx context.Context) (map[string]int64, error) + type WorkspacesService interface + Create func(ctx context.Context, request CreateWorkspaceRequest) (*Workspace, error) + Delete func(ctx context.Context, request DeleteWorkspaceRequest) error + Get func(ctx context.Context, request GetWorkspaceRequest) (*Workspace, error) + List func(ctx context.Context) ([]Workspace, error) + Update func(ctx context.Context, request UpdateWorkspaceRequest) error