dbs

Sep 16, 2025

Changes in this version

type BucketRecord

+ func (b *BucketRecord) IsEmpty() bool

type ConfigRecord

+ func (c *ConfigRecord) IsEmpty() bool

type EnvironmentRecord

+ func (e *EnvironmentRecord) IsEmpty() bool

type FileRecord

+ func (r *FileRecord) IsEmpty() bool

type OsInfoRecord

+ func (o *OsInfoRecord) IsEmpty() bool

type ProvenanceRecord

+ func (p *ProvenanceRecord) IsEmpty() bool

type ScriptRecord

+ func (s *ScriptRecord) IsEmpty() bool

Sep 8, 2025

Changes in this version

+ const ConfigsErrorCode

type API

+ func (a *API) DeleteConfig() error

+ func (a *API) GetConfig() error

+ func (a *API) InsertConfig() error

+ func (a *API) InsertProvenance() error

+ func (a *API) UpdateConfig() error

+ type Config struct

+ CONFIG_ID int64

+ CONTENT any

+ CREATE_AT int64

+ CREATE_BY string

+ MODIFY_AT int64

+ MODIFY_BY string

+ func (r *Config) Delete(tx *sql.Tx) error

+ func (r *Config) Insert(tx *sql.Tx) (int64, error)

+ func (r *Config) SetDefaults()

+ func (r *Config) Update(tx *sql.Tx) error

+ func (r *Config) Validate() error

+ type ConfigRecord struct

+ Content any

+ func (o *ConfigRecord) Insert(tx *sql.Tx) (int64, error)

+ func (r *ConfigRecord) Validate() error

type DatasetRecord

+ Config any

type Datasets

+ CONFIG_ID int64

+ type ProvenanceRecord struct

+ Buckets []BucketRecord

+ Config ConfigRecord

+ Did string

+ Environments []EnvironmentRecord

+ InputFiles []FileRecord

+ OsInfo OsInfoRecord

+ OutputFiles []FileRecord

+ ParentDid string

+ Processing string

+ Scripts []ScriptRecord

+ Site string

Jan 26, 2025

Changes in this version

+ const DeleteErrorCode

+ const UnsupportedOperationErrorCode

+ func DBOperation(op string, rec DBRecord, data []byte, msg string) error

type Buckets

+ func (r *Buckets) Delete(tx *sql.Tx) error

type DBRecord

+ Delete func(tx *sql.Tx) error

type Datasets

+ func (r *Datasets) Delete(tx *sql.Tx) error

type Environments

+ func (r *Environments) Delete(tx *sql.Tx) error

type Files

+ func (r *Files) Delete(tx *sql.Tx) error

type OsInfo

+ func (r *OsInfo) Delete(tx *sql.Tx) error

type Packages

+ func (r *Packages) Delete(tx *sql.Tx) error

type Parents

+ func (r *Parents) Delete(tx *sql.Tx) error

type Processing

+ func (r *Processing) Delete(tx *sql.Tx) error

type Scripts

+ func (r *Scripts) Delete(tx *sql.Tx) error

type Sites

+ func (r *Sites) Delete(tx *sql.Tx) error

Jan 24, 2025

Changes in this version

+ const DatasetErrorCode

+ const EnvironmentsErrorCode

+ const FilesErrorCode

+ const ManyToManyErrorCode

+ const OsInfoErrorCode

+ const PackagesErrorCode

+ const ParentsErrorCode

+ const ProcessingErrorCode

+ const ScriptsErrorCode

+ const SitesErrorCode

+ func InsertManyToMany(tx *sql.Tx, tmplName string, args ...interface{}) error

+ func UniqueList(input []string) []string

type API

+ func (a *API) DeleteEnvironment() error

+ func (a *API) DeleteOsInfo() error

+ func (a *API) DeletePackage() error

+ func (a *API) DeleteScript() error

+ func (a *API) GetEnvironment() error

+ func (a *API) GetOsInfo() error

+ func (a *API) GetPackage() error

+ func (a *API) GetParentDID(did string) (string, error)

+ func (a *API) GetProvenance() error

+ func (a *API) GetScript() error

+ func (a *API) InsertEnvironment() error

+ func (a *API) InsertOsInfo() error

+ func (a *API) InsertPackage() error

+ func (a *API) InsertScript() error

+ func (a *API) UpdateEnvironment() error

+ func (a *API) UpdateOsInfo() error

+ func (a *API) UpdatePackage() error

+ func (a *API) UpdateScript() error

+ type BucketRecord struct

+ MetaData string

+ Name string

+ UUID string

+ func UniqueBucketRecords(bucketRecords []BucketRecord) []BucketRecord

+ func (e *BucketRecord) Insert(tx *sql.Tx) (int64, error)

+ func (r *BucketRecord) Validate() error

type Buckets

+ META_DATA string

+ UUID string

type DatasetRecord

+ Environments []EnvironmentRecord

+ InputFiles []FileRecord

+ OsInfo OsInfoRecord

+ OutputFiles []FileRecord

+ Scripts []ScriptRecord

+ func (r *DatasetRecord) Validate() error

type Datasets

+ OSINFO_ID int64

+ type EnvironmentRecord struct

+ Details string

+ Name string

+ OSName string

+ Packages []PackageRecord

+ Parent string

+ Version string

+ func (e *EnvironmentRecord) Insert(tx *sql.Tx) (int64, error)

+ func (r *EnvironmentRecord) Validate() error

+ type Environments struct

+ CREATE_AT int64

+ CREATE_BY string

+ DETAILS string

+ ENVIRONMENT_ID int64

+ MODIFY_AT int64

+ MODIFY_BY string

+ NAME string

+ OS_ID int64

+ PARENT_ENVIRONMENT_ID int64

+ VERSION string

+ func (r *Environments) Decode(reader io.Reader) error

+ func (r *Environments) Insert(tx *sql.Tx) (int64, error)

+ func (r *Environments) SetDefaults()

+ func (r *Environments) Update(tx *sql.Tx) error

+ func (r *Environments) Validate() error

type FileRecord

+ Checksum string

+ IsValid int64

+ Name string

+ Size int64

+ func (r *FileRecord) Insert(tx *sql.Tx) (int64, error)

+ func (r *FileRecord) Validate() error

type Files

+ CHECKSUM string

+ SIZE int64

+ type OsInfo struct

+ CREATE_AT int64

+ CREATE_BY string

+ KERNEL string

+ MODIFY_AT int64

+ MODIFY_BY string

+ NAME string

+ OS_ID int64

+ VERSION string

+ func (r *OsInfo) Decode(reader io.Reader) error

+ func (r *OsInfo) Insert(tx *sql.Tx) (int64, error)

+ func (r *OsInfo) SetDefaults()

+ func (r *OsInfo) Update(tx *sql.Tx) error

+ func (r *OsInfo) Validate() error

+ type OsInfoRecord struct

+ Kernel string

+ Name string

+ Version string

+ func (o *OsInfoRecord) Insert(tx *sql.Tx) (int64, error)

+ func (r *OsInfoRecord) Validate() error

+ type PackageRecord struct

+ Name string

+ Version string

+ func (e *PackageRecord) Insert(tx *sql.Tx) (int64, error)

+ func (r *PackageRecord) Validate() error

+ type Packages struct

+ CREATE_AT int64

+ CREATE_BY string

+ MODIFY_AT int64

+ MODIFY_BY string

+ NAME string

+ PACKAGE_ID int64

+ VERSION string

+ func (r *Packages) Decode(reader io.Reader) error

+ func (r *Packages) Insert(tx *sql.Tx) (int64, error)

+ func (r *Packages) SetDefaults()

+ func (r *Packages) Update(tx *sql.Tx) error

+ func (r *Packages) Validate() error

+ type ScriptRecord struct

+ Name string

+ Options string

+ OrderIdx int64

+ Parent string

+ func (e *ScriptRecord) Insert(tx *sql.Tx) (int64, error)

+ func (r *ScriptRecord) Validate() error

+ type Scripts struct

+ CREATE_AT int64

+ CREATE_BY string

+ MODIFY_AT int64

+ MODIFY_BY string

+ NAME string

+ OPTIONS string

+ ORDER_IDX int64

+ PARENT_SCRIPT_ID int64

+ SCRIPT_ID int64

+ func (r *Scripts) Decode(reader io.Reader) error

+ func (r *Scripts) Insert(tx *sql.Tx) (int64, error)

+ func (r *Scripts) SetDefaults()

+ func (r *Scripts) Update(tx *sql.Tx) error

+ func (r *Scripts) Validate() error

Jul 23, 2024

Changes in this version

type API

+ func (a *API) GetChild() error

+ type FileRecord struct

+ Did string

+ File string

+ type ParentRecord struct

+ Did string

+ Parent string

type Parents

+ DATASET_ID int64

Apr 17, 2024

Changes in this version

type Buckets

+ func (r *Buckets) Update(tx *sql.Tx) error

type DBRecord

+ Update func(tx *sql.Tx) error

type DatasetRecord

+ Did string

type Datasets

+ DID string

+ func (r *Datasets) Update(tx *sql.Tx) error

type Files

+ func (r *Files) Update(tx *sql.Tx) error

type Parents

+ func (r *Parents) Update(tx *sql.Tx) error

type Processing

+ func (r *Processing) Update(tx *sql.Tx) error

type Sites

+ func (r *Sites) Update(tx *sql.Tx) error

Feb 10, 2024

Changes in this version

+ const AcquisitionEraDoesNotExist

+ const BlockAlreadyExists

+ const CommitErrorCode

+ const ContentTypeErrorCode

+ const DataTierDoesNotExist

+ const DatabaseErrorCode

+ const DatasetAccessTypeDoesNotExist

+ const DatasetDoesNotExist

+ const DatasetParentDoesNotExist

+ const DecodeErrorCode

+ const EncodeErrorCode

+ const FileDataTypesDoesNotExist

+ const FileParentDoesNotExist

+ const GenericErrorCode

+ const GetIDErrorCode

+ const HttpRequestErrorCode

+ const InsertErrorCode

+ const InvalidRequestErrorCode

+ const LastAvailableErrorCode

+ const LastInsertErrorCode

+ const LoadErrorCode

+ const MarshalErrorCode

+ const MigrationErrorCode

+ const NotImplementedApiCode

+ const ParametersErrorCode

+ const ParseErrorCode

+ const PatternErrorCode

+ const PhysicsGroupDoesNotExist

+ const PrimaryDatasetDoesNotExist

+ const PrimaryDatasetTypeDoesNotExist

+ const ProcessedDatasetDoesNotExist

+ const ProcessingEraDoesNotExist

+ const QueryErrorCode

+ const ReaderErrorCode

+ const RemoveErrorCode

+ const RowsScanErrorCode

+ const SessionErrorCode

+ const TransactionErrorCode

+ const UnmarshalErrorCode

+ const UpdateErrorCode

+ const ValidateErrorCode

+ const WriterErrorCode

+ var ConcurrencyErr = errors.New("concurrency error")

+ var ConcurrentBulkBlocks bool

+ var ContentTypeErr = errors.New("content-type error")

+ var DB *sql.DB

+ var DBOWNER string

+ var DBSQL map[string]any

+ var DBTYPE string

+ var DRYRUN bool

+ var DatabaseErr = errors.New("database error")

+ var FileLumiChunkSize int

+ var FileLumiInsertMethod string

+ var FileLumiMaxSize int

+ var GenericErr = errors.New("dbs error")

+ var InvalidParamErr = errors.New("invalid parameter(s)")

+ var InvalidRequestErr = errors.New("invalid request error")

+ var LexiconPatterns map[string]LexiconPattern

+ var NotImplementedApiErr = errors.New("not implemented api error")

+ var RecordErr = errors.New("record error")

+ var RecordValidator *validator.Validate

+ var StaticDir string

+ var Timeout int

+ var ValidationErr = errors.New("validation error")

+ var Verbose int

+ func AddParam(name, sqlName string, params map[string]any, conds []string, ...) ([]string, []interface{})

+ func CastInt(val interface{}) (int, error)

+ func CastInt64(val interface{}) (int64, error)

+ func CastString(val interface{}) (string, error)

+ func CheckPattern(key, value string) error

+ func CleanStatement(stm string) string

+ func ConvertFloat(val string) string

+ func Date() int64

+ func DecodeValidatorError(r, err interface{}) error

+ func Error(err error, code int, msg, function string) error

+ func GetChunks(vals []string, limit int) []string

+ func GetID(tx *sql.Tx, table, id, attr string, val ...interface{}) (int64, error)

+ func GetRecID(tx *sql.Tx, rec DBRecord, table, id, attr string, val ...interface{}) (int64, error)

+ func GetTestData() error

+ func HttpClient(tout int) *http.Client

+ func IfExist(tx *sql.Tx, table, rid, attr string, val ...interface{}) bool

+ func IfExistMulti(tx *sql.Tx, table, rid string, args []string, vals ...interface{}) bool

+ func IncrementSequence(tx *sql.Tx, seq string) (int64, error)

+ func IncrementSequences(tx *sql.Tx, seq string, n int) ([]int64, error)

+ func LastInsertID(tx *sql.Tx, table, idName string) (int64, error)

+ func ListFiles(dir string) []string

+ func LoadPatterns(fname string) (map[string]LexiconPattern, error)

+ func LoadSQL(owner string) map[string]any

+ func LoadTemplateSQL(tmpl string, tmplData map[string]any) (string, error)

+ func OperatorValue(arg string) (string, string)

+ func ParseDBFile(dbfile string) (string, string, string)

+ func ParseRuns(runs []string) ([]string, error)

+ func ParseTmpl(tdir, tmpl string, data interface{}) (string, error)

+ func PrintSQL(stm string, args []interface{}, msg string)

+ func QueryRow(table, id, attr string, val interface{}) (int64, error)

+ func ReplaceBinds(stm string) string

+ func RunsConditions(runs []string, table string) (string, []string, []interface{}, error)

+ func TokenCondition() string

+ func TokenGenerator(runs []string, limit int, name string) (string, []string)

+ func TokenGeneratorORACLE(runs []string, limit int, name string) (string, []string)

+ func TokenGeneratorSQLite(runs []string, name string) (string, []string)

+ func Validate(r *http.Request) error

+ func ValidatePostPayload(rec map[string]any) error

+ func WhereClause(stm string, conds []string) string

+ type API struct

+ Api string

+ ContentType string

+ Context context.Context

+ CreateBy string

+ Params map[string]any

+ Reader io.Reader

+ Separator string

+ Writer http.ResponseWriter

+ func (a *API) DeleteBucket() error

+ func (a *API) DeleteDataset() error

+ func (a *API) DeleteFile() error

+ func (a *API) DeleteMetadata() error

+ func (a *API) DeleteParent() error

+ func (a *API) DeleteProcessing() error

+ func (a *API) DeleteSite() error

+ func (a *API) GetBucket() error

+ func (a *API) GetDataset() error

+ func (a *API) GetFile() error

+ func (a *API) GetMeta() error

+ func (a *API) GetParent() error

+ func (a *API) GetProcessing() error

+ func (a *API) GetSite() error

+ func (a *API) InsertBucket() error

+ func (a *API) InsertDataset() error

+ func (a *API) InsertFile() error

+ func (a *API) InsertMetadata() error

+ func (a *API) InsertParent() error

+ func (a *API) InsertProcessing() error

+ func (a *API) InsertSite() error

+ func (a *API) String() string

+ func (a *API) UpdateBucket() error

+ func (a *API) UpdateDataset() error

+ func (a *API) UpdateFile() error

+ func (a *API) UpdateMetadata() error

+ func (a *API) UpdateParent() error

+ func (a *API) UpdateProcessing() error

+ func (a *API) UpdateSite() error

+ type Buckets struct

+ BUCKET string

+ BUCKET_ID int64

+ CREATE_AT int64

+ CREATE_BY string

+ DATASET_ID int64

+ META_ID int64

+ MODIFY_AT int64

+ MODIFY_BY string

+ func (r *Buckets) Decode(reader io.Reader) error

+ func (r *Buckets) Insert(tx *sql.Tx) error

+ func (r *Buckets) SetDefaults()

+ func (r *Buckets) Validate() error

+ type DBRecord interface

+ Decode func(r io.Reader) error

+ Insert func(tx *sql.Tx) error

+ SetDefaults func()

+ Validate func() error

+ type DBSError struct

+ Code int

+ Function string

+ Message string

+ Reason string

+ Stacktrace string

+ func (e *DBSError) Error() string

+ func (e *DBSError) ErrorStacktrace() string

+ func (e *DBSError) Explain() string

+ type DatasetRecord struct

+ Buckets []string

+ Dataset string

+ Files []string

+ MetaId string

+ Parent string

+ Processing string

+ Site string

+ type Datasets struct

+ CREATE_AT int64

+ CREATE_BY string

+ DATASET string

+ DATASET_ID int64

+ META_ID int64

+ MODIFY_AT int64

+ MODIFY_BY string

+ PARENT_ID int64

+ PROCESSING_ID int64

+ SITE_ID int64

+ func (r *Datasets) Decode(reader io.Reader) error

+ func (r *Datasets) Insert(tx *sql.Tx) error

+ func (r *Datasets) SetDefaults()

+ func (r *Datasets) Validate() error

+ type Files struct

+ CREATE_AT int64

+ CREATE_BY string

+ DATASET_ID int64

+ FILE string

+ FILE_ID int64

+ IS_FILE_VALID int64

+ META_ID int64

+ MODIFY_AT int64

+ MODIFY_BY string

+ func (r *Files) Decode(reader io.Reader) error

+ func (r *Files) Insert(tx *sql.Tx) error

+ func (r *Files) SetDefaults()

+ func (r *Files) Validate() error

+ type Lexicon struct

+ Length int

+ Name string

+ Patterns []string

+ func (r *Lexicon) String() string

+ type LexiconPattern struct

+ Lexicon Lexicon

+ Patterns []*regexp.Regexp

+ type Metadata struct

+ CREATE_AT int64

+ CREATE_BY string

+ DID string

+ META_ID int64

+ MODIFY_AT int64

+ MODIFY_BY string

+ func (r *Metadata) Decode(reader io.Reader) error

+ func (r *Metadata) Insert(tx *sql.Tx) error

+ func (r *Metadata) SetDefaults()

+ func (r *Metadata) Validate() error

+ type ObjectPattern interface

+ Check func(k string, v interface{}) error

+ type Parents struct

+ CREATE_AT int64

+ CREATE_BY string

+ MODIFY_AT int64

+ MODIFY_BY string

+ PARENT string

+ PARENT_ID int64

+ func (r *Parents) Decode(reader io.Reader) error

+ func (r *Parents) Insert(tx *sql.Tx) error

+ func (r *Parents) SetDefaults()

+ func (r *Parents) Validate() error

+ type Processing struct

+ CREATE_AT int64

+ CREATE_BY string

+ MODIFY_AT int64

+ MODIFY_BY string

+ PROCESSING string

+ PROCESSING_ID int64

+ func (r *Processing) Decode(reader io.Reader) error

+ func (r *Processing) Insert(tx *sql.Tx) error

+ func (r *Processing) SetDefaults()

+ func (r *Processing) Validate() error

+ type Sites struct

+ CREATE_AT int64

+ CREATE_BY string

+ MODIFY_AT int64

+ MODIFY_BY string

+ SITE string

+ SITE_ID int64

+ func (r *Sites) Decode(reader io.Reader) error

+ func (r *Sites) Insert(tx *sql.Tx) error

+ func (r *Sites) SetDefaults()

+ func (r *Sites) Validate() error

+ type StrPattern struct

+ Len int

+ Patterns []*regexp.Regexp

+ func (o StrPattern) Check(key string, val interface{}) error