Versions in this module Expand all Collapse all v0 v0.1.5 Jun 29, 2021 Changes in this version + type ClustersAPI struct + Client DBClient + func (a ClustersAPI) Create(cluster models.NewCluster) (models.ClusterInfo, error) + func (a ClustersAPI) Delete(clusterID string) error + func (a ClustersAPI) Edit(clusterInfo models.ClusterInfo) error + func (a ClustersAPI) Events(clusterID string, startTime, endTime int64, order models.ListOrder, ...) (ClustersEventsResponse, error) + func (a ClustersAPI) Get(clusterID string) (models.ClusterInfo, error) + func (a ClustersAPI) List() ([]models.ClusterInfo, error) + func (a ClustersAPI) ListNodeTypes() ([]models.NodeType, error) + func (a ClustersAPI) ListZones() (ClustersListZonesResponse, error) + func (a ClustersAPI) PermanentDelete(clusterID string) error + func (a ClustersAPI) Pin(clusterID string) error + func (a ClustersAPI) Resize(clusterID string, clusterSize models.ClusterSize) error + func (a ClustersAPI) Restart(clusterID string) error + func (a ClustersAPI) SparkVersions() ([]models.SparkVersion, error) + func (a ClustersAPI) Start(clusterID string) error + func (a ClustersAPI) Terminate(clusterID string) error + func (a ClustersAPI) Unpin(clusterID string) error + func (in *ClustersAPI) DeepCopy() *ClustersAPI + func (in *ClustersAPI) DeepCopyInto(out *ClustersAPI) + type ClustersEventsResponse struct + Events []models.ClusterEvent + NextPage struct{ ... } + TotalCount int32 + func (in *ClustersEventsResponse) DeepCopy() *ClustersEventsResponse + func (in *ClustersEventsResponse) DeepCopyInto(out *ClustersEventsResponse) + type ClustersListZonesResponse struct + DefaultZone string + Zones []string + func (in *ClustersListZonesResponse) DeepCopy() *ClustersListZonesResponse + func (in *ClustersListZonesResponse) DeepCopyInto(out *ClustersListZonesResponse) + type DBClient struct + Option databricks.DBClientOption + func (c *DBClient) Init(option databricks.DBClientOption) DBClient + func (c DBClient) Clusters() ClustersAPI + func (c DBClient) Dbfs() DbfsAPI + func (c DBClient) Groups() GroupsAPI + func (c DBClient) InstanceProfiles() InstanceProfilesAPI + func (c DBClient) Jobs() JobsAPI + func (c DBClient) Libraries() LibrariesAPI + func (c DBClient) Scim() ScimAPI + func (c DBClient) Secrets() SecretsAPI + func (c DBClient) Token() TokenAPI + func (c DBClient) Workspace() WorkspaceAPI + func (in *DBClient) DeepCopy() *DBClient + func (in *DBClient) DeepCopyInto(out *DBClient) + type DbfsAPI struct + Client DBClient + func (a DbfsAPI) AddBlock(handle int64, data []byte) error + func (a DbfsAPI) Close(handle int64) error + func (a DbfsAPI) Create(path string, overwrite bool) (DbfsCreateResponse, error) + func (a DbfsAPI) Delete(path string, recursive bool) error + func (a DbfsAPI) GetStatus(path string) (models.FileInfo, error) + func (a DbfsAPI) List(path string) ([]models.FileInfo, error) + func (a DbfsAPI) Mkdirs(path string) error + func (a DbfsAPI) Move(sourcePath, destinationPath string) error + func (a DbfsAPI) Put(path string, contents []byte, overwrite bool) error + func (a DbfsAPI) Read(path string, offset, length int64) (DbfsReadResponse, error) + func (in *DbfsAPI) DeepCopy() *DbfsAPI + func (in *DbfsAPI) DeepCopyInto(out *DbfsAPI) + type DbfsCreateResponse struct + Handle int64 + func (in *DbfsCreateResponse) DeepCopy() *DbfsCreateResponse + func (in *DbfsCreateResponse) DeepCopyInto(out *DbfsCreateResponse) + type DbfsListResponse struct + Files []models.FileInfo + func (in *DbfsListResponse) DeepCopy() *DbfsListResponse + func (in *DbfsListResponse) DeepCopyInto(out *DbfsListResponse) + type DbfsReadResponse struct + BytesRead int64 + Data []byte + func (in *DbfsReadResponse) DeepCopy() *DbfsReadResponse + func (in *DbfsReadResponse) DeepCopyInto(out *DbfsReadResponse) + type GroupsAPI struct + Client DBClient + func (a GroupsAPI) AddMember(principalName models.PrincipalName, parentName string) error + func (a GroupsAPI) Create(groupName string) (GroupsCreateResponse, error) + func (a GroupsAPI) Delete(groupName string) error + func (a GroupsAPI) List() ([]string, error) + func (a GroupsAPI) ListMembers(groupName string) ([]models.PrincipalName, error) + func (a GroupsAPI) ListParents(principalName models.PrincipalName) ([]string, error) + func (a GroupsAPI) RemoveMember(principalName models.PrincipalName, parentName string) error + func (in *GroupsAPI) DeepCopy() *GroupsAPI + func (in *GroupsAPI) DeepCopyInto(out *GroupsAPI) + type GroupsCreateResponse struct + GroupName string + func (in *GroupsCreateResponse) DeepCopy() *GroupsCreateResponse + func (in *GroupsCreateResponse) DeepCopyInto(out *GroupsCreateResponse) + type InstanceProfilesAPI struct + Client DBClient + func (a InstanceProfilesAPI) Add(instanceProfileArn string, skipValidation bool) error + func (a InstanceProfilesAPI) List() ([]models.InstanceProfile, error) + func (a InstanceProfilesAPI) Remove(instanceProfileArn string) error + func (in *InstanceProfilesAPI) DeepCopy() *InstanceProfilesAPI + func (in *InstanceProfilesAPI) DeepCopyInto(out *InstanceProfilesAPI) + type JobsAPI struct + Client DBClient + func (a JobsAPI) Create(jobSettings models.JobSettings) (models.Job, error) + func (a JobsAPI) Delete(jobID int64) error + func (a JobsAPI) Get(jobID int64) (models.Job, error) + func (a JobsAPI) List() ([]models.Job, error) + func (a JobsAPI) Reset(jobID int64, jobSettings models.JobSettings) error + func (a JobsAPI) RunNow(jobID int64, runParameters models.RunParameters) (models.Run, error) + func (a JobsAPI) RunsCancel(runID int64) error + func (a JobsAPI) RunsDelete(runID int64) error + func (a JobsAPI) RunsExport(runID int64) ([]models.ViewItem, error) + func (a JobsAPI) RunsGet(runID int64) (models.Run, error) + func (a JobsAPI) RunsGetOutput(runID int64) (JobsRunsGetOutputResponse, error) + func (a JobsAPI) RunsList(activeOnly, completedOnly bool, jobID int64, offset, limit int32) (JobsRunsListResponse, error) + func (a JobsAPI) RunsSubmit(runName string, clusterSpec models.ClusterSpec, jobTask models.JobTask, ...) (models.Run, error) + func (in *JobsAPI) DeepCopy() *JobsAPI + func (in *JobsAPI) DeepCopyInto(out *JobsAPI) + type JobsRunsGetOutputResponse struct + Error string + Metadata models.Run + NotebookOutput models.NotebookOutput + func (in *JobsRunsGetOutputResponse) DeepCopy() *JobsRunsGetOutputResponse + func (in *JobsRunsGetOutputResponse) DeepCopyInto(out *JobsRunsGetOutputResponse) + type JobsRunsListResponse struct + HasMore bool + Runs []models.Run + func (in *JobsRunsListResponse) DeepCopy() *JobsRunsListResponse + func (in *JobsRunsListResponse) DeepCopyInto(out *JobsRunsListResponse) + type LibrariesAPI struct + Client DBClient + func (a LibrariesAPI) AllClusterStatuses() ([]models.ClusterLibraryStatuses, error) + func (a LibrariesAPI) ClusterStatus(clusterID string) (LibrariesClusterStatusResponse, error) + func (a LibrariesAPI) Install(clusterID string, libraries []models.Library) error + func (a LibrariesAPI) Uninstall(clusterID string, libraries []models.Library) error + func (in *LibrariesAPI) DeepCopy() *LibrariesAPI + func (in *LibrariesAPI) DeepCopyInto(out *LibrariesAPI) + type LibrariesClusterStatusResponse struct + ClusterID string + LibraryStatuses []models.LibraryFullStatus + func (in *LibrariesClusterStatusResponse) DeepCopy() *LibrariesClusterStatusResponse + func (in *LibrariesClusterStatusResponse) DeepCopyInto(out *LibrariesClusterStatusResponse) + type ScimAPI struct + Client DBClient + func (in *ScimAPI) DeepCopy() *ScimAPI + func (in *ScimAPI) DeepCopyInto(out *ScimAPI) + type SecretsAPI struct + Client DBClient + func (a SecretsAPI) Create(lifetimeSeconds int64, comment string) (TokenCreateResponse, error) + func (a SecretsAPI) CreateSecretScope(scope, initialManagePrincipal string) error + func (a SecretsAPI) DeleteSecret(scope, key string) error + func (a SecretsAPI) DeleteSecretACL(scope, principal string) error + func (a SecretsAPI) DeleteSecretScope(scope string) error + func (a SecretsAPI) GetSecretACL(scope, principal string) (models.AclItem, error) + func (a SecretsAPI) List() ([]models.PublicTokenInfo, error) + func (a SecretsAPI) ListSecretACLs(scope string) ([]models.AclItem, error) + func (a SecretsAPI) ListSecretScopes() ([]models.SecretScope, error) + func (a SecretsAPI) ListSecrets(scope string) ([]models.SecretMetadata, error) + func (a SecretsAPI) PutSecret(bytesValue []byte, scope, key string) error + func (a SecretsAPI) PutSecretACL(scope, principal string, permission models.AclPermission) error + func (a SecretsAPI) PutSecretString(stringValue, scope, key string) error + func (a SecretsAPI) Revoke(tokenID string) error + func (in *SecretsAPI) DeepCopy() *SecretsAPI + func (in *SecretsAPI) DeepCopyInto(out *SecretsAPI) + type TokenAPI struct + Client DBClient + func (in *TokenAPI) DeepCopy() *TokenAPI + func (in *TokenAPI) DeepCopyInto(out *TokenAPI) + type TokenCreateResponse struct + TokenInfo models.PublicTokenInfo + TokenValue string + func (in *TokenCreateResponse) DeepCopy() *TokenCreateResponse + func (in *TokenCreateResponse) DeepCopyInto(out *TokenCreateResponse) + type WorkspaceAPI struct + Client DBClient + func (a WorkspaceAPI) Delete(path string, recursive bool) error + func (a WorkspaceAPI) Export(path string, format models.ExportFormat, directDownload bool) ([]byte, error) + func (a WorkspaceAPI) GetStatus(path string) (models.ObjectInfo, error) + func (a WorkspaceAPI) Import(path string, format models.ExportFormat, language models.Language, ...) error + func (a WorkspaceAPI) List(path string) ([]models.ObjectInfo, error) + func (a WorkspaceAPI) Mkdirs(path string) error + func (in *WorkspaceAPI) DeepCopy() *WorkspaceAPI + func (in *WorkspaceAPI) DeepCopyInto(out *WorkspaceAPI)