Versions in this module Expand all Collapse all v1 v1.2.2 Feb 24, 2023 Changes in this version + type Contributors []string + func (c *Contributors) Scan(src any) error + func (c Contributors) Value() (driver.Value, error) type Dataset + License sql.NullString + type Tags []string + func (t *Tags) Scan(src any) error + func (t Tags) Value() (driver.Value, error) v1.2.1 Feb 23, 2023 v1.2.0 Feb 23, 2023 Changes in this version type Dataset + AutomaticallyProcessPackages bool + BannerId uuid.UUID + ChangelogId uuid.NullUUID + Contributors []string + CreatedAt time.Time + DataUseAgreementId sql.NullInt32 + Description sql.NullString + ETag time.Time + Id int64 + Licence sql.NullString + NodeId sql.NullString + PermissionBit sql.NullInt32 + PublicationStatusId sql.NullInt32 + ReadmeId uuid.UUID + Size sql.NullInt64 + Status string + StatusId int32 + Tags []string + Type string + UpdatedAt time.Time type ManifestFileTable + func (f *ManifestFileTable) GetFilesForPath(client core.DynamoDBAPI, tableName string, manifestId string, path string, ...) (*dynamodb.QueryOutput, error) + func (f *ManifestFileTable) GetFilesPaginated(client core.DynamoDBAPI, tableName string, manifestId string, ...) ([]ManifestFileTable, map[string]types.AttributeValue, error) + func (f *ManifestFileTable) GetManifestFile(client core.DynamoDBAPI, tableName string, manifestId string, uploadId string) (*ManifestFileTable, error) + func (f *ManifestFileTable) SyncFiles(client core.DynamoDBAPI, tableName string, manifestId string, ...) (*manifest.AddFilesStats, error) + func (f *ManifestFileTable) UpdateFileTableStatus(client core.DynamoDBAPI, tableName string, manifestId string, uploadId string, ...) error type ManifestTable + func (m *ManifestTable) CreateManifest(client core.DynamoDBAPI, manifestTableName string, item ManifestTable) error + func (m *ManifestTable) GetFromManifest(client core.DynamoDBAPI, manifestTableName string, manifestId string) (*ManifestTable, error) + func (m *ManifestTable) GetManifestsForDataset(client core.DynamoDBAPI, manifestTableName string, datasetNodeId string) ([]ManifestTable, error) + func (m *ManifestTable) UpdateManifestStatus(client core.DynamoDBAPI, tableName string, manifestId string, ...) error v1.1.0 Feb 22, 2023 Changes in this version + const Administer + const Collaborate + const Delete + const NoPermission + const Owner + const Read + const Write + func CreateManifest(client core.DynamoDBAPI, manifestTableName string, item ManifestTable) error + func GetFilesForPath(client core.DynamoDBAPI, tableName string, manifestId string, path string, ...) (*dynamodb.QueryOutput, error) + func UpdateFileTableStatus(client core.DynamoDBAPI, tableName string, manifestId string, uploadId string, ...) error + func UpdateManifestStatus(client core.DynamoDBAPI, tableName string, manifestId string, ...) error + type Dataset struct + Name string + Role string + State string + func (d *Dataset) GetAll(db core.PostgresAPI, organizationId int) ([]Dataset, error) + type DatasetStorage struct + DatasetId int64 + Size int64 + func (d *DatasetStorage) Increment(db core.PostgresAPI, datasetId int64, size int64) error + type DatasetTeam struct + CreatedAt time.Time + DatasetId int64 + Role dataset.Role + TeamId int64 + UpdatedAt time.Time + type DatasetUser struct + CreatedAt time.Time + DatasetId int64 + Role dataset.Role + UpdatedAt time.Time + UserId int64 + type DbPermission int64 + func (s DbPermission) String() string + type ErrFileNotFound struct + func (m *ErrFileNotFound) Error() string + type ErrMultipleRowsAffected struct + func (m *ErrMultipleRowsAffected) Error() string + type FeatureFlags struct + CreatedAt time.Time + Enabled bool + Feature string + OrganizationId int64 + UpdatedAt time.Time + func (d *FeatureFlags) GetAll(db core.PostgresAPI, organizationId int64) ([]FeatureFlags, error) + type File struct + CheckSum string + CreatedAt time.Time + FileType fileType.Type + Id string + Name string + ObjectType objectType.ObjectType + PackageId int + ProcessingState processingState.ProcessingState + S3Bucket string + S3Key string + Size int64 + UUID uuid.UUID + UpdatedAt time.Time + UploadedState uploadState.UploadedState + func (p *File) Add(db core.PostgresAPI, files []FileParams) ([]File, error) + func (p *File) UpdateBucket(db core.PostgresAPI, uploadId string, bucket string, s3Key string, ...) error + type FileParams struct + CheckSum string + FileType fileType.Type + Name string + ObjectType objectType.ObjectType + PackageId int + S3Bucket string + S3Key string + Sha256 string + Size int64 + UUID uuid.UUID + type ManifestFilePrimaryKey struct + ManifestId string + UploadId string + type ManifestFileTable struct + FileName string + FilePath string + FileType string + InProgress string + ManifestId string + MergePackageId string + Status string + UploadId string + func GetFilesPaginated(client core.DynamoDBAPI, tableName string, manifestId string, ...) ([]ManifestFileTable, map[string]types.AttributeValue, error) + func GetManifestFile(client core.DynamoDBAPI, tableName string, manifestId string, uploadId string) (*ManifestFileTable, error) + type ManifestTable struct + DatasetId int64 + DatasetNodeId string + DateCreated int64 + ManifestId string + OrganizationId int64 + Status string + UserId int64 + func GetFromManifest(client core.DynamoDBAPI, manifestTableName string, manifestId string) (*ManifestTable, error) + func GetManifestsForDataset(client core.DynamoDBAPI, manifestTableName string, datasetNodeId string) ([]ManifestTable, error) + type Organization struct + CreatedAt time.Time + EmbargoBucket sql.NullString + Id int64 + Name string + NodeId string + PublishBucket sql.NullString + Slug string + StorageBucket sql.NullString + UpdatedAt time.Time + func (o *Organization) Get(db core.PostgresAPI, id int64) (*Organization, error) + type OrganizationStorage struct + OrganizationId int64 + Size int64 + func (d *OrganizationStorage) Increment(db core.PostgresAPI, organizationId int64, size int64) error + type OrganizationUser struct + CreatedAt time.Time + DbPermission DbPermission + OrganizationId int64 + UpdatedAt time.Time + UserId int64 + func (o *OrganizationUser) GetByUserId(db core.PostgresAPI, id int64) (*OrganizationUser, error) + type Package struct + Attributes []packageInfo.PackageAttribute + CreatedAt time.Time + DatasetId int + Id int64 + ImportId sql.NullString + Name string + NodeId string + OwnerId int + PackageState packageState.State + PackageType packageType.Type + ParentId sql.NullInt64 + Size sql.NullInt64 + UpdatedAt time.Time + func (p *Package) Add(db core.PostgresAPI, records []PackageParams) ([]Package, error) + func (p *Package) Children(db core.PostgresAPI, organizationId int, parent *Package, datasetId int, ...) ([]Package, error) + type PackageMap = map[string]Package + type PackageParams struct + Attributes []packageInfo.PackageAttribute + DatasetId int + ImportId sql.NullString + Name string + NodeId string + OwnerId int + PackageState packageState.State + PackageType packageType.Type + ParentId int64 + Size int64 + type PackageStorage struct + PackageId int64 + Size int64 + func (p *PackageStorage) Increment(db core.PostgresAPI, packageId int64, size int64) error + func (p *PackageStorage) IncrementAncestors(db core.PostgresAPI, parentId int64, size int64) error + type Token struct + CognitoId string + CreatedAt time.Time + Id int64 + LastUsed int64 + Name string + OrganizationId string + Token string + UpdatedAt time.Time + UserId bool + func (t *Token) GetByCognitoId(db core.PostgresAPI, id string) (*Token, error) + func (t *Token) GetUserByCognitoId(db core.PostgresAPI, id string) (*User, error) + type User struct + Email string + FirstName string + Id int64 + IsSuperAdmin bool + LastName string + NodeId string + PreferredOrg int64 + func (u *User) GetByCognitoId(db core.PostgresAPI, id string) (*User, error)
Go to main page