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 AddBlock struct + Data string + Handle int64 + type Close struct + Handle int64 + type Create struct + Overwrite bool + Path string + type CreateResponse struct + Handle int64 + type DbfsAPI struct + func NewDbfs(client *client.DatabricksClient) *DbfsAPI + func (a *DbfsAPI) AddBlock(ctx context.Context, request AddBlock) error + func (a *DbfsAPI) Close(ctx context.Context, request Close) error + func (a *DbfsAPI) CloseByHandle(ctx context.Context, handle int64) error + func (a *DbfsAPI) Create(ctx context.Context, request Create) (*CreateResponse, error) + func (a *DbfsAPI) Delete(ctx context.Context, request Delete) error + func (a *DbfsAPI) GetStatus(ctx context.Context, request GetStatusRequest) (*FileInfo, error) + func (a *DbfsAPI) GetStatusByPath(ctx context.Context, path string) (*FileInfo, error) + func (a *DbfsAPI) Impl() DbfsService + func (a *DbfsAPI) ListAll(ctx context.Context, request ListDbfsRequest) ([]FileInfo, error) + func (a *DbfsAPI) ListByPath(ctx context.Context, path string) (*ListStatusResponse, error) + func (a *DbfsAPI) Mkdirs(ctx context.Context, request MkDirs) error + func (a *DbfsAPI) MkdirsByPath(ctx context.Context, path string) error + func (a *DbfsAPI) Move(ctx context.Context, request Move) error + func (a *DbfsAPI) Open(ctx context.Context, path string, mode FileMode) (Handle, error) + func (a *DbfsAPI) Put(ctx context.Context, request Put) error + func (a *DbfsAPI) Read(ctx context.Context, request ReadDbfsRequest) (*ReadResponse, error) + func (a *DbfsAPI) ReadFile(ctx context.Context, name string) ([]byte, error) + func (a *DbfsAPI) WithImpl(impl DbfsService) *DbfsAPI + func (a *DbfsAPI) WriteFile(ctx context.Context, name string, data []byte) error + func (a DbfsAPI) RecursiveList(ctx context.Context, path string) ([]FileInfo, error) + type DbfsService interface + AddBlock func(ctx context.Context, request AddBlock) error + Close func(ctx context.Context, request Close) error + Create func(ctx context.Context, request Create) (*CreateResponse, error) + Delete func(ctx context.Context, request Delete) error + GetStatus func(ctx context.Context, request GetStatusRequest) (*FileInfo, error) + List func(ctx context.Context, request ListDbfsRequest) (*ListStatusResponse, error) + Mkdirs func(ctx context.Context, request MkDirs) error + Move func(ctx context.Context, request Move) error + Put func(ctx context.Context, request Put) error + Read func(ctx context.Context, request ReadDbfsRequest) (*ReadResponse, error) + type Delete struct + Path string + Recursive bool + type FileInfo struct + FileSize int64 + IsDir bool + ModificationTime int64 + Path string + type FileMode int + const FileModeOverwrite + const FileModeRead + const FileModeWrite + type FilesAPI struct + func NewFiles(client *client.DatabricksClient) *FilesAPI + func (a *FilesAPI) Delete(ctx context.Context, path string) error + func (a *FilesAPI) Download(ctx context.Context, path string) (io.ReadCloser, error) + func (a *FilesAPI) ReadFile(ctx context.Context, name string) ([]byte, error) + func (a *FilesAPI) Upload(ctx context.Context, path string, r io.Reader) error + func (a *FilesAPI) WriteFile(ctx context.Context, name string, data []byte) error + type FilesService interface + type GetStatusRequest struct + Path string + type Handle interface + type ListDbfsRequest struct + Path string + type ListStatusResponse struct + Files []FileInfo + type MkDirs struct + Path string + type Move struct + DestinationPath string + SourcePath string + type Put struct + Contents string + Overwrite bool + Path string + type ReadDbfsRequest struct + Length int + Offset int + Path string + type ReadResponse struct + BytesRead int64 + Data string
Go to main page