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 httpmodels.CreateReq) (httpmodels.CreateResp, error) + func (a ClustersAPI) Delete(clusterID string) error + func (a ClustersAPI) Edit(editReq httpmodels.EditReq) error + func (a ClustersAPI) Events(clusterID string, startTime, endTime int64, order models.ListOrder, ...) (httpmodels.EventsResp, error) + func (a ClustersAPI) Get(clusterID string) (httpmodels.GetResp, error) + func (a ClustersAPI) List() ([]httpmodels.GetResp, error) + func (a ClustersAPI) ListNodeTypes() ([]httpmodels.ListNodeTypesRespItem, 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() ([]httpmodels.SparkVersionsRespItem, error) + func (a ClustersAPI) Start(clusterID string) error + func (a ClustersAPI) Terminate(clusterID string) error + func (a ClustersAPI) Unpin(clusterID string) error + 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) InstancePools() InstancePoolsAPI + 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 + 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) + type DbfsCreateResponse struct + Handle int64 + type DbfsListResponse struct + Files []models.FileInfo + type DbfsReadResponse struct + BytesRead int64 + Data []byte + 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 + type GroupsCreateResponse struct + GroupName string + type InstancePoolsAPI struct + Client DBClient + 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) + type JobsListResponse = struct + Jobs []models.Job + type JobsRunsGetOutputResponse struct + Error string + Metadata models.Run + NotebookOutput models.NotebookOutput + type JobsRunsListResponse struct + HasMore bool + Runs []models.Run + 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 + type LibrariesClusterStatusResponse struct + ClusterID string + LibraryStatuses []models.LibraryFullStatus + type ScimAPI struct + Client DBClient + 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 + type TokenAPI struct + Client DBClient + type TokenCreateResponse struct + TokenInfo models.PublicTokenInfo + TokenValue string + 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