repositories

package
v1.0.59 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 24, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

TODO all mutating methods should call Validate() before saving

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CandidateRecordVisitor added in v1.0.59 

type CandidateRecordVisitor = func(*models.CandidateRecord) error

type Config 

type Config struct {
	Conn                   *pgxpool.Pool
	PublicationListeners   []PublicationListener
	DatasetListeners       []DatasetListener
	PublicationMutators    map[string]PublicationMutator
	DatasetMutators        map[string]DatasetMutator
	PublicationLoaders     []PublicationVisitor
	DatasetLoaders         []DatasetVisitor
	CandidateRecordLoaders []CandidateRecordVisitor
}

type DatasetListener 

type DatasetListener = func(*models.Dataset)

type DatasetMutator 

type DatasetMutator = func(*models.Dataset, []string) error

type DatasetVisitor 

type DatasetVisitor = func(*models.Dataset) error

type Mutation 

type Mutation struct {
	Name string
	Args []string
	// Line is not always set
	Line int
}

type PublicationListener 

type PublicationListener = func(*models.Publication)

type PublicationMutator 

type PublicationMutator = func(*models.Publication, []string) error

type PublicationVisitor 

type PublicationVisitor = func(*models.Publication) error

type Repo 

type Repo struct {
	// contains filtered or unexported fields
}

func New 

func New(c Config) (*Repo, error)

func (*Repo) AddCandidateRecord added in v1.0.56 

func (r *Repo) AddCandidateRecord(ctx context.Context, rec *models.CandidateRecord) error

func (*Repo) AddProxyPerson added in v1.0.59 

func (r *Repo) AddProxyPerson(ctx context.Context, proxyID, personID string) error

func (*Repo) AddPublicationDataset 

func (s *Repo) AddPublicationDataset(p *models.Publication, d *models.Dataset, u *models.Person) error

func (*Repo) CanChangeType added in v1.0.59 

func (s *Repo) CanChangeType(u *models.Person, p *models.Publication) bool

func (*Repo) CanCurate added in v1.0.59 

func (s *Repo) CanCurate(u *models.Person) bool

func (*Repo) CanDeleteDataset added in v1.0.59 

func (s *Repo) CanDeleteDataset(u *models.Person, d *models.Dataset) bool

func (*Repo) CanDeletePublication added in v1.0.59 

func (s *Repo) CanDeletePublication(u *models.Person, p *models.Publication) bool

func (*Repo) CanEditDataset added in v1.0.59 

func (s *Repo) CanEditDataset(u *models.Person, d *models.Dataset) bool

func (*Repo) CanEditPublication added in v1.0.59 

func (s *Repo) CanEditPublication(u *models.Person, p *models.Publication) bool

func (*Repo) CanImpersonateUser added in v1.0.59 

func (s *Repo) CanImpersonateUser(u *models.Person) bool

func (*Repo) CanPublishDataset added in v1.0.59 

func (s *Repo) CanPublishDataset(u *models.Person, d *models.Dataset) bool

func (*Repo) CanPublishPublication added in v1.0.59 

func (s *Repo) CanPublishPublication(u *models.Person, p *models.Publication) bool

func (*Repo) CanViewDashboard added in v1.0.59 

func (s *Repo) CanViewDashboard(u *models.Person) bool

func (*Repo) CanViewDataset added in v1.0.59 

func (s *Repo) CanViewDataset(u *models.Person, d *models.Dataset) bool

func (*Repo) CanViewPublication added in v1.0.59 

func (s *Repo) CanViewPublication(u *models.Person, p *models.Publication) bool

func (*Repo) CanWithdrawDataset added in v1.0.59 

func (s *Repo) CanWithdrawDataset(u *models.Person, d *models.Dataset) bool

func (*Repo) CanWithdrawPublication added in v1.0.59 

func (s *Repo) CanWithdrawPublication(u *models.Person, p *models.Publication) bool

func (*Repo) CountPersonCandidateRecords added in v1.0.59 

func (r *Repo) CountPersonCandidateRecords(ctx context.Context, personID string) (int, error)

func (*Repo) DatasetHistory 

func (s *Repo) DatasetHistory(id string, fn func(*models.Dataset) bool) error

func (*Repo) DatasetsAfter 

func (s *Repo) DatasetsAfter(t time.Time, limit, offset int) (int, []*models.Dataset, error)

func (*Repo) DatasetsBetween 

func (s *Repo) DatasetsBetween(t1, t2 time.Time, fn func(*models.Dataset) bool) error

func (*Repo) EachDataset 

func (s *Repo) EachDataset(fn func(*models.Dataset) bool) error

func (*Repo) EachDatasetSnapshot 

func (s *Repo) EachDatasetSnapshot(fn func(*models.Dataset) bool) error

func (*Repo) EachDatasetWithoutHandle 

func (s *Repo) EachDatasetWithoutHandle(fn func(*models.Dataset) bool) error

func (*Repo) EachPublication 

func (s *Repo) EachPublication(fn func(*models.Publication) bool) error

func (*Repo) EachPublicationSnapshot 

func (s *Repo) EachPublicationSnapshot(fn func(*models.Publication) bool) error

func (*Repo) EachPublicationWithStatus added in v1.0.41 

func (s *Repo) EachPublicationWithStatus(status string, fn func(*models.Publication) bool) error

func (*Repo) EachPublicationWithoutHandle 

func (s *Repo) EachPublicationWithoutHandle(fn func(*models.Publication) bool) error

TODO add handle with a listener, then this method isn't needed anymore

func (*Repo) FindProxies added in v1.0.59 

func (r *Repo) FindProxies(ctx context.Context, personIDs []string, limit, offset int) (int, [][]string, error)

func (*Repo) GetCandidateRecord added in v1.0.56 

func (r *Repo) GetCandidateRecord(ctx context.Context, id string) (*models.CandidateRecord, error)

func (*Repo) GetCandidateRecordBySource added in v1.0.56 

func (r *Repo) GetCandidateRecordBySource(ctx context.Context, sourceName string, sourceID string) (*models.CandidateRecord, error)

func (*Repo) GetCandidateRecords added in v1.0.56 

func (r *Repo) GetCandidateRecords(ctx context.Context, start int, limit int) (int, []*models.CandidateRecord, error)

func (*Repo) GetCandidateRecordsByPersonID added in v1.0.59 

func (r *Repo) GetCandidateRecordsByPersonID(ctx context.Context, personID string, start int, limit int, newOnly bool) (int, []*models.CandidateRecord, error)

func (*Repo) GetDataset 

func (s *Repo) GetDataset(id string) (*models.Dataset, error)

func (*Repo) GetDatasetPublications 

func (s *Repo) GetDatasetPublications(d *models.Dataset) ([]*models.Publication, error)

func (*Repo) GetDatasetSnapshotBefore added in v1.0.42 

func (s *Repo) GetDatasetSnapshotBefore(id string, dateFrom time.Time) (*models.Dataset, error)

func (*Repo) GetDatasets 

func (s *Repo) GetDatasets(ids []string) ([]*models.Dataset, error)

func (*Repo) GetPublication 

func (s *Repo) GetPublication(id string) (*models.Publication, error)

func (*Repo) GetPublicationDatasets 

func (s *Repo) GetPublicationDatasets(p *models.Publication) ([]*models.Dataset, error)

func (*Repo) GetPublicationSnapshotBefore added in v1.0.42 

func (s *Repo) GetPublicationSnapshotBefore(id string, dateFrom time.Time) (*models.Publication, error)

func (*Repo) GetPublications 

func (s *Repo) GetPublications(ids []string) ([]*models.Publication, error)

func (*Repo) GetVisibleDatasetPublications 

func (s *Repo) GetVisibleDatasetPublications(u *models.Person, d *models.Dataset) ([]*models.Publication, error)

func (*Repo) GetVisiblePublicationDatasets 

func (s *Repo) GetVisiblePublicationDatasets(u *models.Person, p *models.Publication) ([]*models.Dataset, error)

func (*Repo) HasCandidateRecords added in v1.0.59 

func (r *Repo) HasCandidateRecords(ctx context.Context) (bool, error)

func (*Repo) HasProxy added in v1.0.59 

func (s *Repo) HasProxy(personIDs []string) bool

func (*Repo) ImportCandidateRecordAsPublication added in v1.0.56 

func (r *Repo) ImportCandidateRecordAsPublication(ctx context.Context, id string, user *models.Person) (string, error)

func (*Repo) ImportDataset 

func (s *Repo) ImportDataset(d *models.Dataset) error

func (*Repo) ImportPublication 

func (s *Repo) ImportPublication(p *models.Publication) error

func (*Repo) IsProxy added in v1.0.59 

func (s *Repo) IsProxy(proxyIDs []string) bool

func (*Repo) IsProxyFor added in v1.0.59 

func (s *Repo) IsProxyFor(proxyIDs []string, personIDs []string) bool

func (*Repo) MutateDataset 

func (s *Repo) MutateDataset(id string, u *models.Person, muts ...Mutation) error

func (*Repo) MutatePublication 

func (s *Repo) MutatePublication(id string, u *models.Person, muts ...Mutation) error

func (*Repo) PersonHasCandidateRecords added in v1.0.59 

func (r *Repo) PersonHasCandidateRecords(ctx context.Context, personID string) (bool, error)

func (*Repo) ProxyIDs added in v1.0.59 

func (r *Repo) ProxyIDs(ctx context.Context, personIDs []string) ([]string, error)

func (*Repo) ProxyPersonIDs added in v1.0.59 

func (r *Repo) ProxyPersonIDs(ctx context.Context, proxyIDs []string) ([]string, error)

func (*Repo) PublicationHistory 

func (s *Repo) PublicationHistory(id string, fn func(*models.Publication) bool) error

func (*Repo) PublicationsAfter 

func (s *Repo) PublicationsAfter(t time.Time, limit, offset int) (int, []*models.Publication, error)

func (*Repo) PublicationsBetween 

func (s *Repo) PublicationsBetween(t1, t2 time.Time, fn func(*models.Publication) bool) error

func (*Repo) PurgeAllDatasets 

func (s *Repo) PurgeAllDatasets() error

func (*Repo) PurgeAllPublications 

func (s *Repo) PurgeAllPublications() error

func (*Repo) PurgeDataset 

func (s *Repo) PurgeDataset(id string) error

func (*Repo) PurgePublication 

func (s *Repo) PurgePublication(id string) error

func (*Repo) RejectCandidateRecord added in v1.0.56 

func (r *Repo) RejectCandidateRecord(ctx context.Context, id string, user *models.Person) error

func (*Repo) RemoveProxyPerson added in v1.0.59 

func (r *Repo) RemoveProxyPerson(ctx context.Context, proxyIDs, personIDs []string) error

func (*Repo) RemovePublicationDataset 

func (s *Repo) RemovePublicationDataset(p *models.Publication, d *models.Dataset, u *models.Person) error

func (*Repo) RestoreCandidateRecord added in v1.0.59 

func (r *Repo) RestoreCandidateRecord(ctx context.Context, id string, user *models.Person) error

func (*Repo) SaveDataset 

func (s *Repo) SaveDataset(d *models.Dataset, u *models.Person) error

func (*Repo) SavePublication 

func (s *Repo) SavePublication(p *models.Publication, u *models.Person) error

func (*Repo) UpdateDataset 

func (s *Repo) UpdateDataset(snapshotID string, d *models.Dataset, u *models.Person) error

func (*Repo) UpdateDatasetEmbargoes 

func (s *Repo) UpdateDatasetEmbargoes() (int, error)

func (*Repo) UpdatePublication 

func (s *Repo) UpdatePublication(snapshotID string, p *models.Publication, u *models.Person) error

func (*Repo) UpdatePublicationEmbargoes 

func (s *Repo) UpdatePublicationEmbargoes() (int, error)

func (*Repo) UpdatePublicationInPlace 

func (s *Repo) UpdatePublicationInPlace(p *models.Publication) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.