keboola

package

Go to main page

Versions in this module

v1

v1.28.2

Feb 12, 2025

v1.28.1

Jan 29, 2025

Changes in this version

type TokenOwner

+ FileStorageProvider string

v1.28.0

Nov 11, 2024

v1.27.0

Oct 4, 2024

Changes in this version

type APIOption

+ func WithOnSuccessTimeout(timeout time.Duration) APIOption

type PublicAPI

+ func (a *PublicAPI) NewAuthorizedAPI(token string, timeout time.Duration) *AuthorizedAPI

v1.26.7

Sep 24, 2024

v1.26.6

Aug 20, 2024

Changes in this version

+ const StorageJobStatusError

+ const StorageJobStatusProcessing

+ const StorageJobStatusSuccess

+ const StorageJobStatusWaiting

v1.26.5

Jun 6, 2024

v1.26.4

May 13, 2024

v1.26.3

Apr 26, 2024

v1.26.2

Apr 4, 2024

Changes in this version

+ type Clustering struct

+ Fields []string

+ type Range struct

+ End string

+ Interval string

+ Start string

+ type RangePartitioning struct

+ Field string

+ Range Range

type TableDefinition

+ Clustering *Clustering

+ RangePartitioning *RangePartitioning

+ TimePartitioning *TimePartitioning

+ type TimePartitioning struct

+ ExpirationMs string

+ Field string

+ Type TimePartitioningType

+ type TimePartitioningType string

+ const Day

+ const Hour

+ const Month

+ const Year

+ func (t TimePartitioningType) String() string

v1.26.1

Apr 3, 2024

v1.26.0

Mar 25, 2024

Changes in this version

type FeaturesMap

+ func (m FeaturesMap) ToSlice() Features

v1.25.0

Mar 22, 2024

v1.24.0

Mar 21, 2024

v1.23.0

Mar 18, 2024

Changes in this version

+ type Columns []Column

+ func (v Columns) Names() (out []string)

type Metadata

+ func (m Metadata) ToPayload() (payload MetadataPayload)

+ type MetadataKV struct

+ Key string

+ Value string

+ type MetadataPayload struct

+ Metadata []MetadataKV

v1.22.0

Mar 14, 2024

v1.21.1

Mar 14, 2024

v1.21.0

Mar 13, 2024

Changes in this version

type BucketKey

+ func (v BucketKey) String() string

type TableKey

+ func (v TableKey) String() string

v1.20.5

Mar 12, 2024

Changes in this version

type TokenOwner

+ DefaultBackend string

+ HasBigquery bool

+ HasExasol bool

+ HasMysql bool

+ HasRedshift bool

+ HasSnowflake bool

+ HasSynapse bool

+ HasTeradata bool

v1.20.4

Mar 4, 2024

v1.20.3

Jan 26, 2024

v1.20.2

Jan 19, 2024

v1.20.1

Jan 18, 2024

v1.20.0

Jan 17, 2024

Changes in this version

type AuthorizedAPI

+ func (a *AuthorizedAPI) CreateTableDefinitionAsyncRequest(b TableKey, payload *CreateTableRequest) request.APIRequest[*StorageJob]

+ func (a *AuthorizedAPI) CreateTableDefinitionRequest(b TableKey, payload *CreateTableRequest) request.APIRequest[*Table]

+ type BaseType string

+ const TypeBoolean

+ const TypeDate

+ const TypeFloat

+ const TypeInt

+ const TypeNumeric

+ const TypeString

+ const TypeTimestamp

+ func (bt BaseType) String() string

+ type Column struct

+ Definition ColumnDefinition

+ Name string

+ type ColumnDefinition struct

+ Default string

+ Length string

+ Nullable bool

+ Type string

+ type CreateTableRequest struct

+ Name string

type Table

+ Definition TableDefinition

+ type TableDefinition struct

+ Columns []Column

+ PrimaryKeyNames []string

v1.19.0

Jan 3, 2024

Changes in this version

+ type AuthorizedAPI struct

+ func NewAuthorizedAPI(ctx context.Context, host, token string, opts ...APIOption) (*AuthorizedAPI, error)

+ func (a *AuthorizedAPI) ActivateScheduleRequest(configID ConfigID, configurationVersionID string) request.APIRequest[*Schedule]

+ func (a *AuthorizedAPI) AppendBranchMetadataRequest(key BranchKey, metadata Metadata) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) AppendConfigMetadataRequest(key ConfigKey, metadata Metadata) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) AppendMetadataRequest(key any, metadata map[string]string) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) CleanAllSchedulesRequest() request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) CleanProjectRequest() request.APIRequest[*Branch]

+ func (a *AuthorizedAPI) CleanWorkspaceInstances(ctx context.Context) error

+ func (a *AuthorizedAPI) CreateBranchAsyncRequest(branch *Branch) request.APIRequest[*StorageJob]

+ func (a *AuthorizedAPI) CreateBranchRequest(branch *Branch) request.APIRequest[*Branch]

+ func (a *AuthorizedAPI) CreateBucketRequest(bucket *Bucket) request.APIRequest[*Bucket]

+ func (a *AuthorizedAPI) CreateConfigRequest(config *ConfigWithRows) request.APIRequest[*ConfigWithRows]

+ func (a *AuthorizedAPI) CreateConfigRowRequest(row *ConfigRow) request.APIRequest[*ConfigRow]

+ func (a *AuthorizedAPI) CreateEventRequest(event *Event) request.APIRequest[*Event]

+ func (a *AuthorizedAPI) CreateFileResourceRequest(branchID BranchID, name string, opts ...CreateFileOption) request.APIRequest[*FileUploadCredentials]

+ func (a *AuthorizedAPI) CreateOldQueueJobRequest(componentID ComponentID, configID ConfigID, opts ...OldQueueJobOption) request.APIRequest[*CreateJobResult]

+ func (a *AuthorizedAPI) CreateOrUpdateTableMetadata(k TableKey, provider string, tableMetadata []TableMetadataRequest, ...) request.APIRequest[*TableMetadataResponse]

+ func (a *AuthorizedAPI) CreateQueueJobConfigDataRequest(componentID ComponentID, configID ConfigID, configData map[string]any) request.APIRequest[*QueueJob]

+ func (a *AuthorizedAPI) CreateQueueJobRequest(componentID ComponentID, configID ConfigID) request.APIRequest[*QueueJob]

+ func (a *AuthorizedAPI) CreateRequest(object Object) request.APIRequest[Object]

+ func (a *AuthorizedAPI) CreateTableFromFileRequest(tableKey TableKey, fileKey FileKey, opts ...CreateTableOption) request.APIRequest[*Table]

+ func (a *AuthorizedAPI) CreateTableRequest(k TableKey, columns []string, opts ...CreateTableOption) request.APIRequest[*Table]

+ func (a *AuthorizedAPI) CreateTokenRequest(opts ...CreateTokenOption) request.APIRequest[*Token]

+ func (a *AuthorizedAPI) CreateWorkspace(ctx context.Context, branchID BranchID, workspaceName string, ...) (*WorkspaceWithConfig, error)

+ func (a *AuthorizedAPI) CreateWorkspaceConfigRequest(branchID BranchID, name string) request.APIRequest[*ConfigWithRows]

+ func (a *AuthorizedAPI) CreateWorkspaceJobRequest(configID ConfigID, workspaceType string, opts ...CreateWorkspaceOption) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteBranchAsyncRequest(key BranchKey) request.APIRequest[*StorageJob]

+ func (a *AuthorizedAPI) DeleteBranchMetadataRequest(branch BranchKey, metaID string) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteBranchRequest(key BranchKey) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteBucketAsyncRequest(k BucketKey, opts ...DeleteOption) request.APIRequest[*StorageJob]

+ func (a *AuthorizedAPI) DeleteBucketRequest(k BucketKey, opts ...DeleteOption) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteConfigMetadataRequest(key ConfigKey, metaID string) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteConfigRequest(config ConfigKey) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteConfigRowRequest(key ConfigRowKey) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteConfigsInBranchRequest(branch BranchKey) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteFileRequest(k FileKey) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteMetadataRequest(key any, metaID string) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteRequest(key any) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteScheduleRequest(key ScheduleKey) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteSchedulesForConfigurationRequest(configID ConfigID) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteTableRequest(branchID BranchID, tableID TableID, opts ...DeleteOption) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteTokenRequest(tokenID string) request.APIRequest[*Token]

+ func (a *AuthorizedAPI) DeleteWorkspace(ctx context.Context, branchID BranchID, configID ConfigID, ...) error

+ func (a *AuthorizedAPI) DeleteWorkspaceConfigRequest(branchID BranchID, configID ConfigID) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) DeleteWorkspaceJobRequest(workspaceID WorkspaceID) request.APIRequest[request.NoResult]

+ func (a *AuthorizedAPI) GenerateIDRequest() request.APIRequest[*Ticket]

+ func (a *AuthorizedAPI) GetBranchRequest(key BranchKey) request.APIRequest[*Branch]

+ func (a *AuthorizedAPI) GetBucketRequest(k BucketKey) request.APIRequest[*Bucket]

+ func (a *AuthorizedAPI) GetConfigRequest(key ConfigKey) request.APIRequest[*Config]

+ func (a *AuthorizedAPI) GetConfigRowRequest(key ConfigRowKey) request.APIRequest[*ConfigRow]

+ func (a *AuthorizedAPI) GetDefaultBranchRequest() request.APIRequest[*Branch]

+ func (a *AuthorizedAPI) GetFileRequest(k FileKey) request.APIRequest[*File]

+ func (a *AuthorizedAPI) GetFileWithCredentialsRequest(k FileKey) request.APIRequest[*FileDownloadCredentials]

+ func (a *AuthorizedAPI) GetOldQueueJobRequest(jobID JobID, opts ...GetOldQueueJobOption) request.APIRequest[*JobDetail]

+ func (a *AuthorizedAPI) GetQueueJobRequest(key JobKey) request.APIRequest[*QueueJob]

+ func (a *AuthorizedAPI) GetStorageJobRequest(key StorageJobKey) request.APIRequest[*StorageJob]

+ func (a *AuthorizedAPI) GetTableRequest(k TableKey) request.APIRequest[*Table]

+ func (a *AuthorizedAPI) GetWorkspace(ctx context.Context, branchID BranchID, configID ConfigID) (*WorkspaceWithConfig, error)

+ func (a *AuthorizedAPI) GetWorkspaceConfigRequest(branchID BranchID, configID ConfigID) request.APIRequest[*Config]

+ func (a *AuthorizedAPI) GetWorkspaceInstanceRequest(workspaceID WorkspaceID) request.APIRequest[*Workspace]

+ func (a *AuthorizedAPI) ListBranchMetadataRequest(key BranchKey) request.APIRequest[*MetadataDetails]

+ func (a *AuthorizedAPI) ListBranchesRequest() request.APIRequest[*[]*Branch]

+ func (a *AuthorizedAPI) ListBucketsRequest(branchID BranchID, opts ...ListBucketsOption) request.APIRequest[*[]*Bucket]

+ func (a *AuthorizedAPI) ListConfigMetadataRequest(branchID BranchID) request.APIRequest[*ConfigsMetadata]

+ func (a *AuthorizedAPI) ListConfigRequest(branchID BranchID, componentID ComponentID) request.APIRequest[*[]*Config]

+ func (a *AuthorizedAPI) ListConfigsAndRowsFrom(branch BranchKey) request.APIRequest[*[]*ComponentWithConfigs]

+ func (a *AuthorizedAPI) ListFilesRequest(branchID BranchID) request.APIRequest[*[]*File]

+ func (a *AuthorizedAPI) ListSchedulesRequest() request.APIRequest[*[]*Schedule]

+ func (a *AuthorizedAPI) ListTablesRequest(branchID BranchID, opts ...ListTableOption) request.APIRequest[*[]*Table]

+ func (a *AuthorizedAPI) ListTokensRequest() request.APIRequest[*[]*Token]

+ func (a *AuthorizedAPI) ListWorkspaceConfigRequest(branchID BranchID) request.APIRequest[*[]*Config]

+ func (a *AuthorizedAPI) ListWorkspaceInstancesRequest() request.APIRequest[*[]*Workspace]

+ func (a *AuthorizedAPI) ListWorkspaces(ctx context.Context, branchID BranchID) ([]*WorkspaceWithConfig, error)

+ func (a *AuthorizedAPI) LoadDataFromFileRequest(tableKey TableKey, fileKey FileKey, opts ...LoadDataOption) request.APIRequest[*StorageJob]

+ func (a *AuthorizedAPI) NewCreateJobRequest(componentID ComponentID) *CreateQueueJobRequestBuilder

+ func (a *AuthorizedAPI) NewTableUnloadRequest(k TableKey) *TableUnloadRequestBuilder

+ func (a *AuthorizedAPI) PreviewTableRequest(k TableKey, opts ...PreviewOption) request.APIRequest[*TablePreview]

+ func (a *AuthorizedAPI) RefreshTokenRequest(tokenID string) request.APIRequest[*Token]

+ func (a *AuthorizedAPI) UpdateBranchRequest(branch *Branch, changedFields []string) request.APIRequest[*Branch]

+ func (a *AuthorizedAPI) UpdateConfigRequest(config *Config, changedFields []string) request.APIRequest[*Config]

+ func (a *AuthorizedAPI) UpdateConfigRowRequest(row *ConfigRow, changedFields []string) request.APIRequest[*ConfigRow]

+ func (a *AuthorizedAPI) UpdateRequest(object Object, changedFields []string) request.APIRequest[Object]

+ func (a *AuthorizedAPI) WaitForOldQueueJob(ctx context.Context, id JobID) (err error)

+ func (a *AuthorizedAPI) WaitForQueueJob(ctx context.Context, id JobID) (err error)

+ func (a *AuthorizedAPI) WaitForStorageJob(ctx context.Context, job *StorageJob) (err error)

+ type PublicAPI struct

+ func NewPublicAPI(ctx context.Context, host string, opts ...APIOption) (*PublicAPI, error)

+ func NewPublicAPIFromIndex(host string, index *Index, opts ...APIOption) *PublicAPI

+ func (a *PublicAPI) Client() request.Sender

+ func (a *PublicAPI) EncryptRequest(projectID int, componentID ComponentID, data map[string]string) request.APIRequest[*map[string]string]

+ func (a *PublicAPI) Index() *Index

+ func (a *PublicAPI) IndexComponentsRequest() request.APIRequest[*IndexComponents]

+ func (a *PublicAPI) IndexRequest() request.APIRequest[*Index]

+ func (a *PublicAPI) VerifyTokenRequest(token string) request.APIRequest[*Token]

+ func (a *PublicAPI) WithToken(token string) *AuthorizedAPI

type TableKey

+ func (v TableKey) BucketKey() BucketKey

v1.18.0

Nov 6, 2023

v1.17.0

Oct 17, 2023

Changes in this version

+ type BucketKey struct

+ BranchID BranchID

+ BucketID BucketID

+ type FileID int

+ func (v FileID) String() string

+ type FileKey struct

+ BranchID BranchID

+ FileID FileID

+ type ListTableOption func(c *listTablesConfig)

+ type TableKey struct

+ BranchID BranchID

+ TableID TableID

v1.16.7

Nov 6, 2023

Changes in this version

type FileUploadCredentials

+ func (v *FileUploadCredentials) CredentialsExpiration() time.Time

v1.16.6

Oct 18, 2023

v1.16.5

Aug 3, 2023

Changes in this version

+ const DataAppsComponentID

+ const WorkspaceComponentID

type API

+ func (a *API) CreateOrUpdateTableMetadata(tableID TableID, provider string, tableMetadata []TableMetadataRequest, ...) request.APIRequest[*TableMetadataResponse]

+ type ColumnMetadataRequest struct

+ ColumnName string

+ Key string

+ Value string

+ type ColumnsMetadata map[string]ColumnMetadata

+ func (r *ColumnsMetadata) UnmarshalJSON(data []byte) (err error)

type MetadataDetail

+ Provider string

+ type TableMetadata []MetadataDetail

+ type TableMetadataRequest struct

+ Key string

+ Value string

+ type TableMetadataResponse struct

+ ColumnMetadata ColumnsMetadata

+ Metadata TableMetadata

v1.16.4

Jul 26, 2023

Changes in this version

type API

+ func (a *API) WithToken(token string) *API

v1.16.3

Jun 9, 2023

v1.16.2

Jun 6, 2023

v1.16.1

May 24, 2023

v1.16.0

May 22, 2023

v1.15.0

May 15, 2023

Changes in this version

type APIOption

+ func WithMeterProvider(v otelMetric.MeterProvider) APIOption

+ func WithTracerProvider(v otelTrace.TracerProvider) APIOption

v1.14.0

Apr 12, 2023

Changes in this version

type ProjectID

+ func (v ProjectID) String() string

v1.13.0

Mar 29, 2023

v1.12.0

Mar 20, 2023

Changes in this version

type API

+ func (a *API) NewTableUnloadRequest(tableID TableID) *TableUnloadRequestBuilder

+ type TableUnloadJobResult struct

+ CacheHit bool

+ File UnloadedFile

+ type TableUnloadRequestBuilder struct

+ func (b *TableUnloadRequestBuilder) Build() client.APIRequest[*StorageJob]

+ func (b *TableUnloadRequestBuilder) Send(ctx context.Context) (*StorageJob, error)

+ func (b *TableUnloadRequestBuilder) SendAndWait(ctx context.Context, timeout time.Duration) (*TableUnloadJobResult, error)

+ func (b *TableUnloadRequestBuilder) WithChangedSince(v string) *TableUnloadRequestBuilder

+ func (b *TableUnloadRequestBuilder) WithChangedUntil(v string) *TableUnloadRequestBuilder

+ func (b *TableUnloadRequestBuilder) WithColumns(v ...string) *TableUnloadRequestBuilder

+ func (b *TableUnloadRequestBuilder) WithFormat(v UnloadFormat) *TableUnloadRequestBuilder

+ func (b *TableUnloadRequestBuilder) WithLimitRows(v uint) *TableUnloadRequestBuilder

+ func (b *TableUnloadRequestBuilder) WithOrderBy(column string, order ColumnOrder, ty ...DataType) *TableUnloadRequestBuilder

+ func (b *TableUnloadRequestBuilder) WithWhere(column string, op CompareOp, values []string, ty ...DataType) *TableUnloadRequestBuilder

+ type UnloadFormat string

+ const UnloadFormatCSV

+ const UnloadFormatJSON

+ type UnloadedFile struct

+ ID int

v1.11.0

Mar 14, 2023

v1.10.2

Mar 14, 2023

v1.10.1

Mar 5, 2023

v1.10.0

Mar 3, 2023

v1.9.0

Mar 3, 2023

Changes in this version

+ type ProjectID int

+ type SourceProject struct

+ ID ProjectID

+ Name string

+ type SourceTable struct

+ ID TableID

+ Name string

+ Project SourceProject

+ URI string

type Table

+ SourceTable *SourceTable

v1.8.0

Mar 1, 2023

Changes in this version

+ type FileAttributes struct

+ ContentType string

+ ModTime time.Time

+ Size int64

+ func GetFileAttributes(ctx context.Context, file *FileDownloadCredentials, slice string, ...) (*FileAttributes, error)

v1.7.0

Mar 1, 2023

Changes in this version

+ type ColumnOrder string

+ func ParseColumnOrder(s string) (ColumnOrder, error)

+ type CompareOp string

+ func ParseCompareOp(s string) (CompareOp, error)

+ type DataType string

+ func ParseDataType(s string) (DataType, error)

v1.6.0

Feb 27, 2023

Changes in this version

type FileDownloadCredentials

+ func (f *FileDownloadCredentials) DestinationURL() (string, error)

+ type SlicesList []string

v1.5.0

Feb 15, 2023

Changes in this version

type API

+ func (a *API) NewCreateJobRequest(componentID ComponentID) *CreateQueueJobRequestBuilder

+ type CreateQueueJobRequestBuilder struct

+ func (b *CreateQueueJobRequestBuilder) Build() client.APIRequest[*QueueJob]

+ func (b *CreateQueueJobRequestBuilder) Send(ctx context.Context) (*QueueJob, error)

+ func (b *CreateQueueJobRequestBuilder) WithBackendSize(size JobBackendSize) *CreateQueueJobRequestBuilder

+ func (b *CreateQueueJobRequestBuilder) WithBranch(id BranchID) *CreateQueueJobRequestBuilder

+ func (b *CreateQueueJobRequestBuilder) WithConfig(id ConfigID) *CreateQueueJobRequestBuilder

+ func (b *CreateQueueJobRequestBuilder) WithConfigData(data map[string]any) *CreateQueueJobRequestBuilder

+ func (b *CreateQueueJobRequestBuilder) WithConfigRowIDs(ids []string) *CreateQueueJobRequestBuilder

+ func (b *CreateQueueJobRequestBuilder) WithMode(mode JobMode) *CreateQueueJobRequestBuilder

+ func (b *CreateQueueJobRequestBuilder) WithTag(tag string) *CreateQueueJobRequestBuilder

+ func (b *CreateQueueJobRequestBuilder) WithVariableValuesData(values []VariableData) *CreateQueueJobRequestBuilder

+ func (b *CreateQueueJobRequestBuilder) WithVariableValuesID(id string) *CreateQueueJobRequestBuilder

+ type JobBackendSize string

+ const JobBackendLarge

+ const JobBackendMedium

+ const JobBackendSmall

+ const JobBackendXSmall

+ type JobMode string

+ const JobModeDebug

+ const JobModeForceRun

+ const JobModeRun

v1.4.0

Feb 13, 2023

Changes in this version

+ const ManifestFileName

+ func Download(ctx context.Context, file *FileDownloadCredentials) ([]byte, error)

+ func DownloadManifest(ctx context.Context, file *FileDownloadCredentials) ([]byte, error)

+ func DownloadManifestReader(ctx context.Context, file *FileDownloadCredentials) (io.ReadCloser, error)

+ func DownloadReader(ctx context.Context, file *FileDownloadCredentials) (io.ReadCloser, error)

+ func DownloadSlice(ctx context.Context, file *FileDownloadCredentials, slice string) (out []byte, err error)

+ func DownloadSliceReader(ctx context.Context, file *FileDownloadCredentials, slice string, ...) (io.ReadCloser, error)

+ type ABSDownloadParams = abs.DownloadParams

type API

+ func (a *API) GetFileWithCredentialsRequest(id int) client.APIRequest[*FileDownloadCredentials]

+ type DownloadOption func(c *downloadConfig)

+ func WithDownloadTransport(transport http.RoundTripper) DownloadOption

+ type FileDownloadCredentials struct

+ type FileUploadCredentials struct

+ ABSUploadParams *abs.UploadParams

+ GCSUploadParams *gcs.UploadParams

+ S3UploadParams *s3.UploadParams

+ type GCSDownloadParams = gcs.DownloadParams

+ type S3DownloadParams = s3.DownloadParams

+ type UploadOption func(c *uploadConfig)

v1.3.0

Feb 9, 2023

Changes in this version

+ const OldQueueJobStatusCancelled

+ const OldQueueJobStatusError

+ const OldQueueJobStatusProcessing

+ const OldQueueJobStatusSuccess

+ const OldQueueJobStatusTerminated

+ const OldQueueJobStatusTerminating

+ const OldQueueJobStatusWaiting

+ const OldQueueJobStatusWarning

+ const SyrupAPI

type API

+ func (a *API) CreateOldQueueJobRequest(componentID ComponentID, configID ConfigID, opts ...OldQueueJobOption) client.APIRequest[*CreateJobResult]

+ func (a *API) CreateTableRequest(tableID TableID, columns []string, opts ...CreateTableOption) client.APIRequest[*Table]

+ func (a *API) GetOldQueueJobRequest(jobID JobID, opts ...GetOldQueueJobOption) client.APIRequest[*JobDetail]

+ func (a *API) WaitForOldQueueJob(ctx context.Context, id JobID) error

+ type CreateJobResult struct

+ ID JobID

+ Status string

+ URL string

+ type GetOldQueueJobOption func(c *getOldQueueJobConfig)

+ func WithMetrics() GetOldQueueJobOption

+ type JobDetail struct

+ Command string

+ Component ComponentID

+ CreatedTime iso8601.Time

+ DurationSeconds uint64

+ EndTime *iso8601.Time

+ ID JobID

+ LockName string

+ Metrics *JobMetrics

+ Params *orderedmap.OrderedMap

+ Process ProcessDetail

+ Project ProjectDetail

+ Result OldQueueJobResult

+ RunID string

+ StartTime *iso8601.Time

+ Status string

+ Token TokenDetail

+ WaitSeconds uint64

type JobID

+ func (j *JobID) UnmarshalJSON(b []byte) error

+ type JobMetrics struct

+ Backend string

+ Network NetworkMetrics

+ Storage StorageMetrics

+ type NetworkMetrics struct

+ InBytes uint64

+ OutBytes uint64

+ type OldQueueJobOption func(c *oldQueueJobConfig)

+ func WithBranchID(id BranchID) OldQueueJobOption

+ func WithConfigData(configData map[string]any) OldQueueJobOption

+ func WithImageTag(tag string) OldQueueJobOption

+ func WithRowID(id RowID) OldQueueJobOption

+ func WithVariableValuesData(data VariableValuesData) OldQueueJobOption

+ func WithVariableValuesID(id string) OldQueueJobOption

+ type OldQueueJobResult struct

+ ExceptionID string

+ Message string

+ type ProcessDetail struct

+ Host string

+ PID int

+ type ProjectDetail struct

+ ID int

+ Name string

+ type StorageMetrics struct

+ InBytes uint64

+ OutBytes uint64

+ type TokenDetail struct

+ Description string

+ ID string

+ type VariableData struct

+ Name string

+ Value string

+ type VariableValuesData struct

+ Values []VariableData

v1.2.0

Feb 1, 2023

Changes in this version

+ func WithContentType(v string) withContentType

+ func WithDisableEncryption() withDisableEncryption

+ func WithIsPermanent(v bool) withIsPermanent

+ func WithIsSliced(v bool) withIsSliced

+ func WithNotify(v bool) withNotify

+ func WithSizeBytes(v uint64) withSizeBytes

+ func WithTags(v ...string) withTags

+ type CreateFileOption interface

v1.1.0

Jan 27, 2023

Changes in this version

+ const CompareEq

+ const CompareGe

+ const CompareGt

+ const CompareLe

+ const CompareLt

+ const CompareNe

+ const OrderAsc

+ const OrderDesc

+ const TypeBigInt

+ const TypeDecimal

+ const TypeDouble

+ const TypeInteger

+ const TypeReal

+ func WithChangedSince(value string) withChangedSince

+ func WithChangedUntil(value string) withChangedUntil

+ func WithExportColumns(columns ...string) withExportColumns

+ func WithLimitRows(value uint) withLimitRows

+ func WithOrderBy(column string, order order, ty ...dataType) *orderByBuilder

+ func WithWhere(column string, op compareOp, values []any, ty ...dataType) *whereFilterBuilder

type API

+ func (a *API) DeleteBucketAsyncRequest(bucketID BucketID, opts ...DeleteOption) client.APIRequest[*StorageJob]

+ func (a *API) PreviewTableRequest(tableID TableID, opts ...PreviewOption) client.APIRequest[*TablePreview]

type BucketID

+ func ParseBucketIDExpectMagicPrefix(v string) (BucketID, error)

+ type PreviewOption interface

+ type TablePreview struct

+ Columns []string

+ Rows [][]string

v1.0.0

Jan 26, 2023

Changes in this version

+ const BucketStageIn

+ const BucketStageOut

+ const BucketStageSys

+ const ComponentTypeCodePattern

+ const ComponentTypeProcessor

+ const DeprecatedFlag

+ const EncryptionAPI

+ const ExcludeFromNewListFlag

+ const GenericCodeBlocksUIFlag

+ const OrchestratorComponentID

+ const QueueAPI

+ const SchedulerAPI

+ const SchedulerComponentID

+ const SharedCodeComponentID

+ const StorageAPI

+ const TimeFormat

+ const TransformationType

+ const VariablesComponentID

+ const WorkspaceSizeLarge

+ const WorkspaceSizeMedium

+ const WorkspaceSizeSmall

+ const WorkspaceTypePython

+ const WorkspaceTypeR

+ const WorkspaceTypeSnowflake

+ const WorkspacesAPI

+ const WorkspacesComponent

+ func CleanProject(ctx context.Context, api *API) error

+ func IsEncrypted(value string) bool

+ func IsKeyToEncrypt(key string) bool

+ func NewSliceURL(file *File, slice string) (string, error)

+ func NewUploadSliceWriter(ctx context.Context, file *File, slice string, opts ...UploadOptions) (*blob.Writer, error)

+ func NewUploadWriter(ctx context.Context, file *File, opts ...UploadOptions) (*blob.Writer, error)

+ func SortComponents(components Components)

+ func Upload(ctx context.Context, file *File, fr io.Reader) (written int64, err error)

+ func UploadSlice(ctx context.Context, file *File, slice string, fr io.Reader) (written int64, err error)

+ func UploadSlicedFileManifest(ctx context.Context, file *File, slices []string) (written int64, err error)

+ func WithColumnsHeaders(c []string) columnsHeadersOption

+ func WithDelimiter(d string) delimiterOption

+ func WithEnclosure(e string) enclosureOption

+ func WithEscapedBy(e string) escapedByOption

+ func WithIncrementalLoad(i bool) incrementalLoadOption

+ func WithPrimaryKey(pk []string) primaryKeyOption

+ func WithoutHeader(h bool) withoutHeaderOption

+ func WorkspaceSizesMap() map[string]bool

+ func WorkspaceSizesOrdered() []string

+ func WorkspaceSupportsSizes(typ string) bool

+ func WorkspaceTypesMap() map[string]bool

+ func WorkspaceTypesOrdered() []string

+ type API struct

+ func APIClientForAnEmptyProject(t *testing.T, ctx context.Context, opts ...testproject.Option) *API

+ func APIClientForRandomProject(t *testing.T, ctx context.Context, opts ...testproject.Option) (*testproject.Project, *API)

+ func NewAPI(ctx context.Context, host string, opts ...APIOption) (*API, error)

+ func NewAPIFromIndex(host string, index *Index, opts ...APIOption) *API

+ func (a *API) ActivateScheduleRequest(configID ConfigID, configurationVersionID string) client.APIRequest[*Schedule]

+ func (a *API) AppendBranchMetadataRequest(key BranchKey, metadata Metadata) client.APIRequest[client.NoResult]

+ func (a *API) AppendConfigMetadataRequest(key ConfigKey, metadata Metadata) client.APIRequest[client.NoResult]

+ func (a *API) AppendMetadataRequest(key any, metadata map[string]string) client.APIRequest[client.NoResult]

+ func (a *API) CleanAllSchedulesRequest() client.APIRequest[client.NoResult]

+ func (a *API) CleanProjectRequest() client.APIRequest[*Branch]

+ func (a *API) CleanWorkspaceInstances(ctx context.Context) error

+ func (a *API) Client() client.Sender

+ func (a *API) CreateBranchAsyncRequest(branch *Branch) client.APIRequest[*StorageJob]

+ func (a *API) CreateBranchRequest(branch *Branch) client.APIRequest[*Branch]

+ func (a *API) CreateBucketRequest(bucket *Bucket) client.APIRequest[*Bucket]

+ func (a *API) CreateConfigRequest(config *ConfigWithRows) client.APIRequest[*ConfigWithRows]

+ func (a *API) CreateConfigRowRequest(row *ConfigRow) client.APIRequest[*ConfigRow]

+ func (a *API) CreateEventRequest(event *Event) client.APIRequest[*Event]

+ func (a *API) CreateFileResourceRequest(file *File) client.APIRequest[*File]

+ func (a *API) CreateQueueJobConfigDataRequest(componentID ComponentID, configID ConfigID, configData map[string]any) client.APIRequest[*QueueJob]

+ func (a *API) CreateQueueJobRequest(componentID ComponentID, configID ConfigID) client.APIRequest[*QueueJob]

+ func (a *API) CreateRequest(object Object) client.APIRequest[Object]

+ func (a *API) CreateTable(ctx context.Context, tableID TableID, columns []string, ...) (*Table, error)

+ func (a *API) CreateTableDeprecatedSyncRequest(tableID TableID, columns []string, opts ...CreateTableOption) (client.APIRequest[*Table], error)

+ func (a *API) CreateTableFromFileRequest(tableID TableID, dataFileID int, opts ...CreateTableOption) client.APIRequest[*Table]

+ func (a *API) CreateTokenRequest(opts ...CreateTokenOption) client.APIRequest[*Token]

+ func (a *API) CreateWorkspace(ctx context.Context, branchID BranchID, workspaceName string, ...) (*WorkspaceWithConfig, error)

+ func (a *API) CreateWorkspaceConfigRequest(branchID BranchID, name string) client.APIRequest[*ConfigWithRows]

+ func (a *API) CreateWorkspaceJobRequest(configID ConfigID, workspaceType string, opts ...CreateWorkspaceOption) client.APIRequest[client.NoResult]

+ func (a *API) DeleteBranchAsyncRequest(key BranchKey) client.APIRequest[*StorageJob]

+ func (a *API) DeleteBranchMetadataRequest(branch BranchKey, metaID string) client.APIRequest[client.NoResult]

+ func (a *API) DeleteBranchRequest(key BranchKey) client.APIRequest[client.NoResult]

+ func (a *API) DeleteBucketRequest(bucketID BucketID, opts ...DeleteOption) client.APIRequest[client.NoResult]

+ func (a *API) DeleteConfigMetadataRequest(key ConfigKey, metaID string) client.APIRequest[client.NoResult]

+ func (a *API) DeleteConfigRequest(config ConfigKey) client.APIRequest[client.NoResult]

+ func (a *API) DeleteConfigRowRequest(key ConfigRowKey) client.APIRequest[client.NoResult]

+ func (a *API) DeleteConfigsInBranchRequest(branch BranchKey) client.APIRequest[client.NoResult]

+ func (a *API) DeleteFileRequest(id int) client.APIRequest[client.NoResult]

+ func (a *API) DeleteMetadataRequest(key any, metaID string) client.APIRequest[client.NoResult]

+ func (a *API) DeleteRequest(key any) client.APIRequest[client.NoResult]

+ func (a *API) DeleteScheduleRequest(key ScheduleKey) client.APIRequest[client.NoResult]

+ func (a *API) DeleteSchedulesForConfigurationRequest(configID ConfigID) client.APIRequest[client.NoResult]

+ func (a *API) DeleteTableRequest(tableID TableID, opts ...DeleteOption) client.APIRequest[client.NoResult]

+ func (a *API) DeleteTokenRequest(tokenID string) client.APIRequest[*Token]

+ func (a *API) DeleteWorkspace(ctx context.Context, branchID BranchID, configID ConfigID, ...) error

+ func (a *API) DeleteWorkspaceConfigRequest(branchID BranchID, configID ConfigID) client.APIRequest[client.NoResult]

+ func (a *API) DeleteWorkspaceJobRequest(workspaceID WorkspaceID) client.APIRequest[client.NoResult]

+ func (a *API) EncryptRequest(projectID int, componentID ComponentID, data map[string]string) client.APIRequest[*map[string]string]

+ func (a *API) GenerateIDRequest() client.APIRequest[*Ticket]

+ func (a *API) GetBranchRequest(key BranchKey) client.APIRequest[*Branch]

+ func (a *API) GetBucketRequest(bucketID BucketID) client.APIRequest[*Bucket]

+ func (a *API) GetConfigRequest(key ConfigKey) client.APIRequest[*Config]

+ func (a *API) GetConfigRowRequest(key ConfigRowKey) client.APIRequest[*ConfigRow]

+ func (a *API) GetDefaultBranchRequest() client.APIRequest[*Branch]

+ func (a *API) GetFileRequest(id int) client.APIRequest[*File]

+ func (a *API) GetQueueJobRequest(key JobKey) client.APIRequest[*QueueJob]

+ func (a *API) GetStorageJobRequest(key StorageJobKey) client.APIRequest[*StorageJob]

+ func (a *API) GetTableRequest(tableID TableID) client.APIRequest[*Table]

+ func (a *API) GetWorkspace(ctx context.Context, branchID BranchID, configID ConfigID) (*WorkspaceWithConfig, error)

+ func (a *API) GetWorkspaceConfigRequest(branchID BranchID, configID ConfigID) client.APIRequest[*Config]

+ func (a *API) GetWorkspaceInstanceRequest(workspaceID WorkspaceID) client.APIRequest[*Workspace]

+ func (a *API) Index() *Index

+ func (a *API) IndexComponentsRequest() client.APIRequest[*IndexComponents]

+ func (a *API) IndexRequest() client.APIRequest[*Index]

+ func (a *API) ListBranchMetadataRequest(key BranchKey) client.APIRequest[*MetadataDetails]

+ func (a *API) ListBranchesRequest() client.APIRequest[*[]*Branch]

+ func (a *API) ListBucketsRequest(opts ...ListBucketsOption) client.APIRequest[*[]*Bucket]

+ func (a *API) ListConfigMetadataRequest(branchID BranchID) client.APIRequest[*ConfigsMetadata]

+ func (a *API) ListConfigRequest(branchID BranchID, componentID ComponentID) client.APIRequest[*[]*Config]

+ func (a *API) ListConfigsAndRowsFrom(branch BranchKey) client.APIRequest[*[]*ComponentWithConfigs]

+ func (a *API) ListFilesRequest() client.APIRequest[*[]*File]

+ func (a *API) ListSchedulesRequest() client.APIRequest[*[]*Schedule]

+ func (a *API) ListTablesRequest(opts ...Option) client.APIRequest[*[]*Table]

+ func (a *API) ListTokensRequest() client.APIRequest[*[]*Token]

+ func (a *API) ListWorkspaceConfigRequest(branchID BranchID) client.APIRequest[*[]*Config]

+ func (a *API) ListWorkspaceInstancesRequest() client.APIRequest[*[]*Workspace]

+ func (a *API) ListWorkspaces(ctx context.Context, branchID BranchID) ([]*WorkspaceWithConfig, error)

+ func (a *API) LoadDataFromFileRequest(tableID TableID, dataFileID int, opts ...LoadDataOption) client.APIRequest[*StorageJob]

+ func (a *API) RefreshTokenRequest(tokenID string) client.APIRequest[*Token]

+ func (a *API) UpdateBranchRequest(branch *Branch, changedFields []string) client.APIRequest[*Branch]

+ func (a *API) UpdateConfigRequest(config *Config, changedFields []string) client.APIRequest[*Config]

+ func (a *API) UpdateConfigRowRequest(row *ConfigRow, changedFields []string) client.APIRequest[*ConfigRow]

+ func (a *API) UpdateRequest(object Object, changedFields []string) client.APIRequest[Object]

+ func (a *API) VerifyTokenRequest(token string) client.APIRequest[*Token]

+ func (a *API) WaitForQueueJob(ctx context.Context, job *QueueJob) error

+ func (a *API) WaitForStorageJob(ctx context.Context, job *StorageJob) error

+ type APIOption func(c *apiConfig)

+ func WithClient(cl *client.Client) APIOption

+ func WithToken(token string) APIOption

+ type Branch struct

+ Created iso8601.Time

+ Description string

+ IsDefault bool

+ Name string

+ type BranchID int

+ func (id BranchID) String() string

+ type BranchKey struct

+ ID BranchID

+ func (k BranchKey) ObjectID() any

+ type Bucket struct

+ Created iso8601.Time

+ DataSizeBytes uint64

+ Description string

+ DisplayName string

+ ID BucketID

+ IsReadOnly bool

+ LastChangeDate *iso8601.Time

+ RowsCount uint64

+ URI string

+ type BucketID struct

+ BucketName string

+ Stage string

+ func MustParseBucketID(v string) BucketID

+ func ParseBucketID(v string) (BucketID, error)

+ func (v *BucketID) UnmarshalJSON(data []byte) error

+ func (v BucketID) MarshalJSON() ([]byte, error)

+ func (v BucketID) String() string

+ type BucketPermission string

+ const BucketPermissionRead

+ const BucketPermissionWrite

+ type BucketPermissions map[BucketID]BucketPermission

+ func (r *BucketPermissions) UnmarshalJSON(data []byte) (err error)

+ func (r BucketPermissions) MarshalJSON() ([]byte, error)

+ type ColumnMetadata map[string]MetadataDetail

+ func (r *ColumnMetadata) UnmarshalJSON(data []byte) (err error)

+ type Component struct

+ Data ComponentData

+ EmptyConfig *orderedmap.OrderedMap

+ EmptyConfigRow *orderedmap.OrderedMap

+ Flags []string

+ Name string

+ Schema json.RawMessage

+ SchemaRow json.RawMessage

+ Type string

+ func (c *Component) IsCodePattern() bool

+ func (c *Component) IsDeprecated() bool

+ func (c *Component) IsExcludedFromNewList() bool

+ func (c *Component) IsOrchestrator() bool

+ func (c *Component) IsProcessor() bool

+ func (c *Component) IsScheduler() bool

+ func (c *Component) IsSharedCode() bool

+ func (c *Component) IsTransformation() bool

+ func (c *Component) IsTransformationWithBlocks() bool

+ func (c *Component) IsVariables() bool

+ type ComponentData struct

+ DefaultBucket bool

+ DefaultBucketStage string

+ type ComponentID string

+ func (v ComponentID) String() string

+ func (v ComponentID) WithoutVendor() string

+ type ComponentKey struct

+ ID ComponentID

+ type ComponentWithConfigs struct

+ BranchID BranchID

+ Configs []*ConfigWithRows

+ type Components []*Component

+ func (v Components) NewComponentList() Components

+ func (v Components) ToMap() ComponentsMap

+ type ComponentsMap struct

+ func (m ComponentsMap) ForEach(fn func(component *Component))

+ func (m ComponentsMap) Get(id ComponentID) (*Component, bool)

+ type Config struct

+ ChangeDescription string

+ Content *orderedmap.OrderedMap

+ Created iso8601.Time

+ Description string

+ IsDeleted bool

+ IsDisabled bool

+ Name string

+ State *orderedmap.OrderedMap

+ Version int

+ type ConfigID string

+ func (v ConfigID) String() string

+ type ConfigKey struct

+ BranchID BranchID

+ ComponentID ComponentID

+ ID ConfigID

+ func (k ConfigKey) ObjectID() any

+ type ConfigMetadataItem struct

+ BranchID BranchID

+ ComponentID ComponentID

+ ConfigID ConfigID

+ Metadata MetadataDetails

+ type ConfigRow struct

+ ChangeDescription string

+ Content *orderedmap.OrderedMap

+ Description string

+ IsDisabled bool

+ Name string

+ State *orderedmap.OrderedMap

+ Version int

+ type ConfigRowKey struct

+ BranchID BranchID

+ ComponentID ComponentID

+ ConfigID ConfigID

+ ID RowID

+ func (k ConfigRowKey) ObjectID() any

+ type ConfigWithRows struct

+ Rows []*ConfigRow

+ func (c *ConfigWithRows) SortRows()

+ type ConfigsMetadata []*ConfigMetadataItem

+ func (v ConfigsMetadata) ToMap() map[ConfigKey]Metadata

+ type CreateTableOption interface

+ type CreateTokenOption func(*createTokenOptions)

+ func WithBucketPermission(bucketID BucketID, perm BucketPermission) CreateTokenOption

+ func WithBucketPermissions(v BucketPermissions) CreateTokenOption

+ func WithCanManageBuckets(canManageBuckets bool) CreateTokenOption

+ func WithCanPurgeTrash(canPurgeTrash bool) CreateTokenOption

+ func WithCanReadAllFileUploads(canReadAllFileUploads bool) CreateTokenOption

+ func WithComponentAccess(component string) CreateTokenOption

+ func WithDescription(description string) CreateTokenOption

+ func WithExpiresIn(expiresIn time.Duration) CreateTokenOption

+ type CreateWorkspaceOption func(p *params)

+ func WithExpireAfterHours(v uint64) CreateWorkspaceOption

+ func WithImageVersion(v string) CreateWorkspaceOption

+ func WithShared(v bool) CreateWorkspaceOption

+ func WithSize(v string) CreateWorkspaceOption

+ type CreatorToken struct

+ Description string

+ ID int

+ type DeleteOption func(c *deleteConfig)

+ func WithForce() DeleteOption

+ type DurationSeconds time.Duration

+ func (d *DurationSeconds) UnmarshalJSON(data []byte) (err error)

+ func (d DurationSeconds) MarshalJSON() ([]byte, error)

+ func (d DurationSeconds) String() string

+ type EncryptionError struct

+ ErrCode int

+ ExceptionID string

+ Message string

+ func (e *EncryptionError) Error() string

+ func (e *EncryptionError) ErrorExceptionID() string

+ func (e *EncryptionError) ErrorName() string

+ func (e *EncryptionError) ErrorUserMessage() string

+ func (e *EncryptionError) SetRequest(request *http.Request)

+ func (e *EncryptionError) SetResponse(response *http.Response)

+ func (e *EncryptionError) StatusCode() int

+ type Event struct

+ ComponentID ComponentID

+ Duration client.DurationSeconds

+ ID EventID

+ Message string

+ Params JSONString

+ Results JSONString

+ Type string

+ type EventID string

+ func (v EventID) String() string

+ type Features []string

+ func (v Features) ToMap() FeaturesMap

+ type FeaturesMap struct

+ func (m FeaturesMap) Has(feature string) bool

+ type File struct

+ ABSUploadParams *abs.UploadParams

+ ContentType string

+ Created iso8601.Time

+ FederationToken bool

+ GCSUploadParams *gcs.UploadParams

+ ID int

+ IsEncrypted bool

+ IsPermanent bool

+ IsSliced bool

+ MaxAgeDays uint

+ Name string

+ Notify bool

+ Provider string

+ Region string

+ S3UploadParams *s3.UploadParams

+ SizeBytes uint64

+ Tags []string

+ URL string

+ type Index struct

+ Features Features

+ Services Services

+ func APIIndex(ctx context.Context, host string, opts ...APIOption) (*Index, error)

+ func (i Index) AllServices() ServicesMap

+ func (i Index) ServiceURLByID(serviceID ServiceID) (ServiceURL, bool)

+ type IndexComponents struct

+ Components Components

+ func APIIndexWithComponents(ctx context.Context, host string, opts ...APIOption) (*IndexComponents, error)

+ type JSONString map[string]any

+ func (v *JSONString) MarshalJSON() ([]byte, error)

+ func (v *JSONString) UnmarshalJSON(data []byte) (err error)

+ func (v JSONString) String() string

+ type JobID string

+ func (j JobID) String() string

+ type JobKey struct

+ ID JobID

+ type JobResult struct

+ Error map[string]any

+ Message string

+ func (r *JobResult) UnmarshalJSON(data []byte) (err error)

+ type ListBucketsOption func(c *listBucketsConfig)

+ type LoadDataOption interface

+ type Metadata map[string]string

+ type MetadataDetail struct

+ ID string

+ Key string

+ Timestamp string

+ Value string

+ type MetadataDetails []MetadataDetail

+ func (v MetadataDetails) ToMap() Metadata

+ type Object interface

+ ObjectID func() any

+ type Option func(c *listTablesConfig)

+ func WithBuckets() Option

+ func WithColumnMetadata() Option

+ func WithColumns() Option

+ func WithMetadata() Option

+ type QueueError struct

+ ErrCode int

+ ExceptionID string

+ Message string

+ func (e *QueueError) Error() string

+ func (e *QueueError) ErrorExceptionID() string

+ func (e *QueueError) ErrorName() string

+ func (e *QueueError) ErrorUserMessage() string

+ func (e *QueueError) SetRequest(request *http.Request)

+ func (e *QueueError) SetResponse(response *http.Response)

+ func (e *QueueError) StatusCode() int

+ type QueueJob struct

+ CreateTime iso8601.Time

+ EndTime *iso8601.Time

+ IsFinished bool

+ Result JobResult

+ StartTime *iso8601.Time

+ Status string

+ URL string

+ type RowID string

+ func (v RowID) String() string

+ type Schedule struct

+ ConfigID ConfigID

+ type ScheduleID string

+ func (v ScheduleID) String() string

+ type ScheduleKey struct

+ ID ScheduleID

+ type SchedulerError struct

+ ErrCode int

+ ExceptionID string

+ Message string

+ func (e *SchedulerError) Error() string

+ func (e *SchedulerError) ErrorExceptionID() string

+ func (e *SchedulerError) ErrorName() string

+ func (e *SchedulerError) ErrorUserMessage() string

+ func (e *SchedulerError) SetRequest(request *http.Request)

+ func (e *SchedulerError) SetResponse(response *http.Response)

+ func (e *SchedulerError) StatusCode() int

+ type Service struct

+ ID ServiceID

+ URL ServiceURL

+ type ServiceID string

+ func (u ServiceID) String() string

+ type ServiceType string

+ type ServiceURL string

+ func (u ServiceURL) String() string

+ type Services []*Service

+ func (v Services) ToMap() ServicesMap

+ type ServicesMap struct

+ func (m ServicesMap) Len() int

+ func (m ServicesMap) URLByID(serviceID ServiceID) (ServiceURL, bool)

+ type Slice struct

+ URL string

+ type SlicedFileManifest struct

+ Entries []Slice

+ func NewSlicedFileManifest(file *File, sliceNames []string) (*SlicedFileManifest, error)

+ type StorageError struct

+ ErrCode string

+ ExceptionID string

+ Message string

+ func (e *StorageError) Error() string

+ func (e *StorageError) ErrorExceptionID() string

+ func (e *StorageError) ErrorName() string

+ func (e *StorageError) ErrorUserMessage() string

+ func (e *StorageError) SetRequest(request *http.Request)

+ func (e *StorageError) SetResponse(response *http.Response)

+ func (e *StorageError) StatusCode() int

+ type StorageJob struct

+ CreateTime iso8601.Time

+ EndTime *iso8601.Time

+ Error StorageJobError

+ OperationName string

+ OperationParams map[string]any

+ Results StorageJobResult

+ StartTime *iso8601.Time

+ Status string

+ URL string

+ type StorageJobError struct

+ Code string

+ ExceptionID string

+ Message string

+ type StorageJobID int

+ func (id StorageJobID) String() string

+ type StorageJobKey struct

+ ID StorageJobID

+ type StorageJobResult map[string]any

+ func (r *StorageJobResult) UnmarshalJSON(data []byte) (err error)

+ type Table struct

+ Bucket *Bucket

+ ColumnMetadata ColumnMetadata

+ Columns []string

+ Created iso8601.Time

+ DataSizeBytes uint64

+ DisplayName string

+ ID TableID

+ LastChangeDate *iso8601.Time

+ LastImportDate iso8601.Time

+ Metadata []MetadataDetail

+ Name string

+ PrimaryKey []string

+ RowsCount uint64

+ URI string

+ type TableID struct

+ TableName string

+ func MustParseTableID(v string) TableID

+ func ParseTableID(v string) (TableID, error)

+ func (v *TableID) UnmarshalJSON(data []byte) error

+ func (v TableID) MarshalJSON() ([]byte, error)

+ func (v TableID) String() string

+ type Ticket struct

+ ID string

+ type TicketProvider struct

+ func NewTicketProvider(ctx context.Context, api *API) *TicketProvider

+ func (t *TicketProvider) Request(onSuccess func(ticket *Ticket))

+ func (t *TicketProvider) Resolve() error

+ type Token struct

+ Admin *TokenAdmin

+ BucketPermissions BucketPermissions

+ CanManageBuckets bool

+ CanManageTokens bool

+ CanPurgeTrash bool

+ CanReadAllFileUploads bool

+ ComponentAccess []string

+ Created iso8601.Time

+ Creator *CreatorToken

+ Description string

+ Expires *iso8601.Time

+ ID string

+ IsDisabled bool

+ IsExpired bool

+ IsMaster bool

+ Owner TokenOwner

+ Refreshed iso8601.Time

+ Token string

+ func (t *Token) ProjectID() int

+ func (t *Token) ProjectName() string

+ type TokenAdmin struct

+ Features Features

+ ID int

+ IsOrganizationMember bool

+ Name string

+ Role string

+ type TokenOwner struct

+ Features Features

+ ID int

+ Name string

+ type UploadOptions func(c *uploadConfig)

+ func WithUploadTransport(transport http.RoundTripper) UploadOptions

+ type Workspace struct

+ Active bool

+ Created WorkspacesTime

+ Details *WorkspaceDetails

+ Host string

+ ID WorkspaceID

+ Password string

+ Shared bool

+ Size string

+ Start WorkspacesTime

+ Type string

+ URL string

+ Updated WorkspacesTime

+ User string

+ type WorkspaceDetails struct

+ Connection struct{ ... }

+ type WorkspaceID string

+ func GetWorkspaceID(c *Config) (WorkspaceID, error)

+ func (v WorkspaceID) String() string

+ type WorkspaceWithConfig struct

+ Config *Config

+ Workspace *Workspace

+ func (v WorkspaceWithConfig) String() string

+ type WorkspacesError struct

+ ErrorInfo string

+ Message string

+ func (e *WorkspacesError) Error() string

+ func (e *WorkspacesError) ErrorName() string

+ func (e *WorkspacesError) ErrorUserMessage() string

+ func (e *WorkspacesError) SetRequest(request *http.Request)

+ func (e *WorkspacesError) SetResponse(response *http.Response)

+ func (e *WorkspacesError) StatusCode() int

+ type WorkspacesTime time.Time

+ func (t *WorkspacesTime) UnmarshalJSON(data []byte) (err error)

+ func (t WorkspacesTime) MarshalJSON() ([]byte, error)

+ func (t WorkspacesTime) String() string

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