model.go

package catalog

import (
	"database/sql/driver"
	"encoding/json"
	"time"
)

type Metadata map[string]string

type Repository struct {
	Name             string    `db:"name"`
	StorageNamespace string    `db:"storage_namespace"`
	DefaultBranch    string    `db:"default_branch"`
	CreationDate     time.Time `db:"creation_date"`
}

type Entry struct {
	CommonLevel     bool
	Path            string    `db:"path"`
	PhysicalAddress string    `db:"physical_address"`
	CreationDate    time.Time `db:"creation_date"`
	Size            int64     `db:"size"`
	Checksum        string    `db:"checksum"`
	Metadata        Metadata  `db:"metadata"`
	Expired         bool      `db:"is_expired"`
}

type CommitLog struct {
	Reference    string
	Committer    string    `db:"committer"`
	Message      string    `db:"message"`
	CreationDate time.Time `db:"creation_date"`
	Metadata     Metadata  `db:"metadata"`
	Parents      []string
}

type MergeResult struct {
	Summary   map[DifferenceType]int
	Reference string
}

type commitLogRaw struct {
	BranchName            string    `db:"branch_name"`
	CommitID              CommitID  `db:"commit_id"`
	PreviousCommitID      CommitID  `db:"previous_commit_id"`
	Committer             string    `db:"committer"`
	Message               string    `db:"message"`
	CreationDate          time.Time `db:"creation_date"`
	Metadata              Metadata  `db:"metadata"`
	MergeSourceBranchName string    `db:"merge_source_branch_name"`
	MergeSourceCommit     CommitID  `db:"merge_source_commit"`
}

type lineageCommit struct {
	BranchID int64    `db:"branch_id"`
	CommitID CommitID `db:"commit_id"`
}

type Branch struct {
	Repository string `db:"repository"`
	Name       string `db:"name"`
}

type MultipartUpload struct {
	Repository      string    `db:"repository"`
	UploadID        string    `db:"upload_id"`
	Path            string    `db:"path"`
	CreationDate    time.Time `db:"creation_date"`
	PhysicalAddress string    `db:"physical_address"`
}

func (j Metadata) Value() (driver.Value, error) {
	if j == nil {
		return json.Marshal(struct{}{})
	}
	return json.Marshal(j)
}

func (j *Metadata) Scan(src interface{}) error {
	if src == nil {
		return nil
	}
	data, ok := src.([]byte)
	if !ok {
		return ErrInvalidMetadataSrcFormat
	}
	return json.Unmarshal(data, j)
}

type DBReaderEntry struct {
	BranchID  int64    `db:"branch_id"`
	Path      string   `db:"path"`
	MinCommit CommitID `db:"min_commit"`
	MaxCommit CommitID `db:"max_commit"`
	RowCtid   string   `db:"ctid"`
}