Versions in this module Expand all Collapse all v1 v1.4.5 Feb 15, 2023 v1.4.4 Feb 11, 2023 v1.4.3 Jan 12, 2023 v1.4.2 Nov 13, 2022 Changes in this version + type ErrFileNotFound struct + func (m *ErrFileNotFound) Error() string + type ErrMultipleRowsAffected struct + func (m *ErrMultipleRowsAffected) Error() string type FileParams + Sha256 string v1.4.1 Nov 10, 2022 v1.4.0 Oct 24, 2022 v1.3.1 Oct 4, 2022 v1.3.0 Oct 4, 2022 v1.2.2 Sep 25, 2022 v1.2.1 Sep 25, 2022 v1.2.0 Sep 25, 2022 Changes in this version type User + NodeId string v1.1.1 Aug 18, 2022 v1.1.0 Aug 18, 2022 Changes in this version + func UpdateManifestStatus(client core.DynamoDBAPI, tableName string, manifestId string, ...) error v1.0.4 Aug 14, 2022 Changes in this version + const Administer + const Collaborate + const Delete + const NoPermission + const Owner + const Read + const Write + 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 + 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 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, organizationId int64) error + type FileParams struct + CheckSum string + FileType fileType.Type + Name string + ObjectType objectType.ObjectType + PackageId int + S3Bucket string + S3Key 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 + PreferredOrg int64 + func (u *User) GetByCognitoId(db core.PostgresAPI, id string) (*User, error)
Go to main page