storageapi

Dec 21, 2022

Changes in this version

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

type CreateTokenOption

+ func WithBucketPermissions(v BucketPermissions) CreateTokenOption

Dec 19, 2022

Changes in this version

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

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

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

Dec 19, 2022

Changes in this version

type BucketPermissions

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

Dec 19, 2022

Changes in this version

+ const BucketStageSys

type BucketID

+ 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)

type TableID

+ 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)

Dec 16, 2022

Changes in this version

+ const GenericCodeBlocksUIFlag

type Component

+ func (c *Component) IsTransformationWithBlocks() bool

Dec 7, 2022

Changes in this version

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

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

+ type BucketPermissions map[BucketID]BucketPermission

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

+ type CreateTokenOption func(*createTokenOptions)

Nov 24, 2022

Changes in this version

+ func CreateTokenRequest(opts ...createTokenOption) client.APIRequest[*Token]

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

+ func WithBucketPermission(bucketID BucketID, perm BucketPermission) 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 BucketPermission string

+ const BucketPermissionRead

+ const BucketPermissionWrite

+ type CreatorToken struct

+ Description string

+ ID int

type Token

+ BucketPermissions map[BucketID]BucketPermission

+ CanManageBuckets bool

+ CanManageTokens bool

+ CanPurgeTrash bool

+ CanReadAllFileUploads bool

+ ComponentAccess []string

+ Created iso8601.Time

+ Creator *CreatorToken

+ Expires *iso8601.Time

+ IsDisabled bool

+ IsExpired bool

+ Refreshed iso8601.Time

+ type TokenAdmin struct

+ Features Features

+ Id int

+ IsOrganizationMember bool

+ Name string

+ Role string

Nov 16, 2022

Changes in this version

+ func GetBucketRequest(id BucketID) client.APIRequest[*Bucket]

Nov 15, 2022

Changes in this version

+ func CreateTable(ctx context.Context, sender client.Sender, bucketID string, name string, ...) (err error)

+ func CreateTableFromFileRequest(bucketID string, name string, dataFileID int, opts ...CreateTableOption) client.APIRequest[*Job]

+ func GetFileResourceRequest(id int) client.APIRequest[*File]

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

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

+ 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 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 WaitForJob(ctx context.Context, sender client.Sender, job *Job) 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

+ type ColumnMetadata map[string]MetadataDetail

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

+ type CreateTableOption interface

type File

+ GCSUploadParams gcs.UploadParams

type Job

+ Error JobError

+ type JobError struct

+ Code string

+ ExceptionId string

+ Message string

+ type JobResult map[string]any

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

+ type LoadDataOption interface

+ type Slice struct

+ Url string

+ type SlicedFileManifest struct

+ Entries []Slice

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

+ type UploadOptions func(c *uploadConfig)

+ func WithUploadTransport(transport http.RoundTripper) UploadOptions

Nov 2, 2022

Changes in this version

+ func ClientForAnEmptyProject(t *testing.T, opts ...testproject.Option) client.Sender

+ func ClientForRandomProject(t *testing.T, opts ...testproject.Option) (*testproject.Project, client.Client)

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

+ type File struct

+ ABSUploadParams abs.UploadParams

+ ContentType string

+ Created iso8601.Time

+ FederationToken bool

+ ID int

+ IsEncrypted bool

+ IsPermanent bool

+ IsPublic bool

+ IsSliced bool

+ MaxAgeDays int

+ Name string

+ Notify bool

+ Provider string

+ Region string

+ S3UploadParams s3.UploadParams

+ SizeBytes int

+ Tags []string

+ Url string

Oct 27, 2022

Changes in this version

type Token

+ Description string

Oct 26, 2022

Changes in this version

+ type AdminToken struct

+ Features Features

+ Id int

+ IsOrganizationMember bool

+ Name string

+ Role string

type Token

+ Admin *AdminToken

Oct 10, 2022

Changes in this version

+ func CreateTableRequest(table *Table) client.APIRequest[*Table]

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

+ type DeleteOption func(c *deleteConfig)

Sep 30, 2022

Changes in this version

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

+ func DeleteBucketRequest(bucketID BucketID, opts ...DeleteBucketOption) client.APIRequest[client.NoResult]

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

+ type DeleteBucketOption func(c *deleteBucketsConfig)

+ func WithForce() DeleteBucketOption

+ type ListBucketsOption func(c *listBucketsConfig)

Sep 26, 2022

Changes in this version

type Bucket

+ ID BucketID

type Table

+ ID TableID

Sep 21, 2022

Changes in this version

+ const BucketStageIn

+ const BucketStageOut

+ func ListConfigRequest(branchId BranchID, componentId ComponentID) client.APIRequest[*[]*Config]

+ func ListTablesRequest(branch BranchKey, opts ...Option) client.APIRequest[*[]*Table]

+ type Bucket struct

+ Created Time

+ DataSizeBytes uint64

+ Description string

+ DisplayName string

+ IsReadOnly bool

+ LastChangeDate Time

+ Name string

+ RowsCount uint64

+ Stage string

+ Uri string

+ type BucketID string

+ func (v BucketID) String() string

+ type BucketKey struct

+ BranchID BranchID

+ ID BucketID

+ func (k BucketKey) ObjectId() any

+ type Option func(c *listTablesConfig)

+ func WithBuckets() Option

+ func WithColumnMetadata() Option

+ func WithColumns() Option

+ func WithMetadata() Option

+ type Table struct

+ Bucket *Bucket

+ ColumnMetadata map[string]MetadataDetail

+ Columns []string

+ Created Time

+ DataSizeBytes uint64

+ DisplayName string

+ LastChangeDate Time

+ LastImportDate Time

+ Metadata []MetadataDetail

+ Name string

+ PrimaryKey []string

+ RowsCount uint64

+ Uri string

+ type TableID string

+ func (v TableID) String() string

+ type TableKey struct

+ BranchID BranchID

+ ID TableID

+ func (k TableKey) ObjectId() any

Jul 7, 2022

Changes in this version

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

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

Jun 22, 2022

Changes in this version

type TokenOwner

+ Features Features

Jun 20, 2022

Changes in this version

+ const ComponentTypeCodePattern

+ const ComponentTypeProcessor

+ const DeprecatedFlag

+ const ExcludeFromNewListFlag

+ const OrchestratorComponentID

+ const SchedulerComponentID

+ const SharedCodeComponentID

+ const TimeFormat

+ const TransformationType

+ const VariablesComponentID

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

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

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

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

+ func ClientWithHost(c client.Client, apiHost string) client.Client

+ func ClientWithHostAndToken(c client.Client, apiHost, apiToken string) client.Client

+ func ClientWithToken(c client.Client, apiToken string) client.Client

+ func CreatEventRequest(event *Event) client.APIRequest[*Event]

+ func CreateBranchAsyncRequest(branch *Branch) client.APIRequest[*Job]

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

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

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

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

+ func DeleteBranchAsyncRequest(key BranchKey) client.APIRequest[*Job]

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

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

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

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

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

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

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

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

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

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

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

+ func GetJobRequest(key JobKey) client.APIRequest[*Job]

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

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

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

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

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

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

+ func SortComponents(components Components)

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

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

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

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

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

+ type Branch struct

+ Created 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 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) 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 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

+ Created Time

+ 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 DurationSeconds time.Duration

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

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

+ func (d DurationSeconds) String() string

+ type Error struct

+ ErrCode string

+ ExceptionID string

+ Message string

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

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

+ func (e Error) Error() string

+ func (e Error) ErrorExceptionID() string

+ func (e Error) ErrorName() string

+ func (e Error) ErrorUserMessage() string

+ func (e Error) StatusCode() int

+ type Event struct

+ ComponentID ComponentID

+ Duration 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 Index struct

+ Features Features

+ Services Services

+ func (i Index) AllServices() ServicesMap

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

+ type IndexComponents struct

+ Components Components

+ 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 Job struct

+ CreateTime Time

+ EndTime *Time

+ OperationName string

+ OperationParams map[string]any

+ Results map[string]any

+ StartTime *Time

+ Status string

+ URL string

+ type JobID int

+ func (id JobID) String() string

+ type JobKey struct

+ ID JobID

+ 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 RowID string

+ func (v RowID) String() string

+ type Service struct

+ ID ServiceID

+ URL ServiceURL

+ type ServiceID string

+ func (u ServiceID) String() string

+ type ServiceURL string

+ func (u ServiceURL) String() string

+ type Services []*Service

+ func (v Services) ToMap() ServicesMap

+ type ServicesMap struct

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

+ type Ticket struct

+ ID string

+ type TicketProvider struct

+ func NewTicketProvider(ctx context.Context, sender client.Sender) *TicketProvider

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

+ func (t *TicketProvider) Resolve() error

+ type Time time.Time

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

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

+ func (t Time) String() string

+ type Token struct

+ ID string

+ IsMaster bool

+ Owner TokenOwner

+ Token string

+ func (t *Token) ProjectID() int

+ func (t *Token) ProjectName() string

+ type TokenOwner struct

+ ID int

+ Name string