repo

May 7, 2021

Changes in this version

type MemRepo

+ func NewMemRepoWithProfile(ctx context.Context, owner *profile.Profile, fs *muxfs.Mux, bus event.Bus) (*MemRepo, error)

Jul 30, 2020

Changes in this version

+ func ListVersionInfoShim(r Repo, offset, limit int) ([]dsref.VersionInfo, error)

type MemRepo

+ func (r *MemRepo) Bus() event.Bus

type Repo

+ Bus func() event.Bus

Jul 1, 2020

Changes in this version

+ func DeleteVersionInfoShim(r Repo, ref dsref.Ref) (*dsref.VersionInfo, error)

+ func GetVersionInfoShim(r Repo, ref dsref.Ref) (*dsref.VersionInfo, error)

+ func ListDatasetsShim(r Repo, offset, limit int) ([]dsref.VersionInfo, error)

+ func PutVersionInfoShim(r Repo, vi *dsref.VersionInfo) error

type MemRepo

+ func (r *MemRepo) Done() <-chan struct{}

+ func (r *MemRepo) DoneErr() error

+ func (r *MemRepo) ResolveRef(ctx context.Context, ref *dsref.Ref) (string, error)

type Repo

+ Done func() <-chan struct{}

+ DoneErr func() error

Apr 7, 2020

Changes in this version

+ var ErrNoRepo = fmt.Errorf("repo: no repo found")

Feb 27, 2020

Changes in this version

+ func FlatbufferBytes(rs RefList) []byte

+ func MarshalFlatbuffer(r reporef.DatasetRef, builder *flatbuffers.Builder) flatbuffers.UOffsetT

+ func UnmarshalFlatbuffer(rfb *repofb.DatasetRef) (r reporef.DatasetRef, err error)

type MemRepo

+ func (r *MemRepo) Dscache() *dscache.Dscache

+ type RefList []reporef.DatasetRef

+ func (rs RefList) Len() int

+ func (rs RefList) Less(i, j int) bool

+ func (rs RefList) Swap(i, j int)

type Repo

+ Dscache func() *dscache.Dscache

Dec 12, 2019

Changes in this version

type DatasetRef

+ func (r DatasetRef) DebugString() string

Nov 6, 2019

Changes in this version

+ func ConvertToDsref(ref DatasetRef) dsref.Ref

+ type DatasetInfo struct

+ FSIPath string

+ Foreign bool

+ Published bool

+ Ref dsref.Ref

+ func ConvertToDsinfo(ref DatasetRef) DatasetInfo

type DatasetRef

+ func ParseDsref(r dsref.Ref) (DatasetRef, error)

+ func (r DatasetRef) Absolute() (s string)

type MemRepo

+ func (r *MemRepo) Logbook() *logbook.Book

+ func (r *MemRepo) RemoveLogbook()

+ func (r *MemRepo) SetLogbook(book *logbook.Book)

type Repo

+ Logbook func() *logbook.Book

Sep 26, 2019

Changes in this version

+ var ErrNoHistory = fmt.Errorf("repo: no history")

type DatasetRef

+ FSIPath string

+ Foreign bool

+ func (r *DatasetRef) UnmarshalFlatbuffer(rfb *repofb.DatasetRef) (err error)

+ func (r DatasetRef) FlatbufferBytes() []byte

+ func (r DatasetRef) MarshalFlatbuffer(builder *flatbuffers.Builder) flatbuffers.UOffsetT

+ type Refs []DatasetRef

+ func UnmarshalRefsFlatbuffer(data []byte) (ls Refs, err error)

+ func (rs Refs) FlatbufferBytes() []byte

+ func (rs Refs) Len() int

+ func (rs Refs) Less(i, j int) bool

+ func (rs Refs) Remove(i int) Refs

+ func (rs Refs) Swap(i, j int)

Jun 5, 2019

Changes in this version

+ const ETCronJobRan

+ var DefaultQriLocation = "$HOME/.qri"

type Event

+ PeerIDString string

type MemRepo

+ func (r *MemRepo) SetFilesystem(fs qfs.Filesystem)

+ type QFSSetter interface

+ SetFilesystem func(qfs.Filesystem)

Mar 7, 2019

Changes in this version

+ func IsRefString(path string) bool

Feb 5, 2019

Changes in this version

type MemRepo

+ func (r *MemRepo) Filesystem() qfs.Filesystem

type Repo

+ Filesystem func() qfs.Filesystem

Dec 12, 2018

Changes in this version

type DatasetRef

+ func (r DatasetRef) Complete() bool

Nov 9, 2018

Changes in this version

type DatasetRef

+ Published bool

Sep 14, 2018

Changes in this version

+ var ErrEmptyRef = fmt.Errorf("repo: empty dataset reference")

type DatasetRef

+ func CreateDataset(r Repo, name string, ds *dataset.Dataset, body cafs.File, pin bool) (ref DatasetRef, err error)

+ func MustParseDatasetRef(refstr string) DatasetRef

+ type NeedPeernameRenames struct

+ Renames map[string]string

+ func NewNeedPeernameRenames() NeedPeernameRenames

Jul 19, 2018

Changes in this version

+ var ErrNoRegistry = fmt.Errorf("no configured registry")

Jun 18, 2018

Changes in this version

+ var ErrRefSelectionNotSupported = fmt.Errorf("selection not supported")

+ func DatasetPodBodyFile(dsp *dataset.DatasetPod) (cafs.File, error)

type MemRepo

+ func (r *MemRepo) SelectedRefs() ([]DatasetRef, error)

+ func (r *MemRepo) SetSelectedRefs(sel []DatasetRef) error

+ type RefSelector interface

+ SelectedRefs func() ([]DatasetRef, error)

+ SetSelectedRefs func([]DatasetRef) error

Jun 6, 2018

Changes in this version

+ const ETTransformExecuted

+ func DatasetPodDataFile(dsp *dataset.DatasetPod) (cafs.File, error)

May 15, 2018

Changes in this version

type Event

+ Params interface{}

+ PeerID peer.ID

type MemEventLog

+ func (log *MemEventLog) LogEventDetails(t EventType, when int64, peerID peer.ID, ref DatasetRef, params interface{}) error

type MemRepo

+ func (r *MemRepo) Registry() *regclient.Client

type Repo

+ Registry func() *regclient.Client

Apr 25, 2018

Changes in this version

type DatasetRef

+ func (r DatasetRef) DecodeDataset() (*dataset.Dataset, error)

Apr 9, 2018

Changes in this version

+ const ETDsAdded

+ const ETDsCreated

+ const ETDsDeleted

+ const ETDsPinned

+ const ETDsRenamed

+ const ETDsUnpinned

+ var ErrNotPinner = fmt.Errorf("repo: backing store doesn't support pinning")

+ func CanonicalizeProfile(r Repo, ref *DatasetRef) error

+ func MustProfile(r Repo) *profile.Profile

type DatasetRef

+ ProfileID profile.ID

+ type Event struct

+ Ref DatasetRef

+ Time time.Time

+ Type EventType

+ type EventLog interface

+ Events func(limit, offset int) ([]*Event, error)

+ EventsSince func(time.Time) ([]*Event, error)

+ LogEvent func(t EventType, ref DatasetRef) error

+ type EventType string

+ type MemEventLog []*Event

+ func (log *MemEventLog) LogEvent(t EventType, ref DatasetRef) error

+ func (log MemEventLog) Events(limit, offset int) ([]*Event, error)

+ func (log MemEventLog) EventsSince(t time.Time) ([]*Event, error)

type MemRepo

+ func (r *MemRepo) PrivateKey() crypto.PrivKey

+ func (r *MemRepo) Profiles() profile.Store

+ func (r *MemRepo) RefCache() Refstore

+ func (r *MemRepo) SetProfile(p *profile.Profile) error

+ type ProfileRef struct

+ Peername string

+ Profile *profile.Profile

+ ProfileID profile.ID

+ func (r ProfileRef) String() (s string)

type Repo

+ PrivateKey func() crypto.PrivKey

+ Profiles func() profile.Store

+ SetProfile func(*profile.Profile) error

Mar 12, 2018

Changes in this version

+ var ErrPeerIDRequired = fmt.Errorf("repo: peerID is required")

+ func CanonicalizePeer(r Repo, ref *DatasetRef) error

type DatasetRef

+ PeerID string

+ func (r DatasetRef) AliasString() (s string)

Feb 13, 2018

Changes in this version

+ var ErrPathRequired = fmt.Errorf("repo: path is required")

+ var ErrPeernameRequired = fmt.Errorf("repo: peername is required")

+ func CanonicalizeDatasetRef(r Repo, ref *DatasetRef) error

+ func CanonicalizePeername(r Repo, peername *string) error

type DatasetRef

+ func (r DatasetRef) Equal(b DatasetRef) bool

+ func (r DatasetRef) IsEmpty() bool

+ func (r DatasetRef) Match(b DatasetRef) bool

+ type MemRefstore []DatasetRef

+ func (r *MemRefstore) DeleteRef(del DatasetRef) error

+ func (r *MemRefstore) PutRef(put DatasetRef) error

+ func (r MemRefstore) GetRef(get DatasetRef) (ref DatasetRef, err error)

+ func (r MemRefstore) RefCount() (int, error)

+ func (r MemRefstore) References(limit, offset int) ([]DatasetRef, error)

+ type Refstore interface

+ DeleteRef func(ref DatasetRef) error

+ GetRef func(ref DatasetRef) (DatasetRef, error)

+ PutRef func(ref DatasetRef) error

+ RefCount func() (int, error)

+ References func(limit, offset int) ([]DatasetRef, error)

Feb 2, 2018

Changes in this version

+ const ChangeRequestStatusAccepted

+ const ChangeRequestStatusDeclined

+ const ChangeRequestStatusOpen

+ var ErrNameRequired = fmt.Errorf("repo: name is required")

+ var ErrNameTaken = fmt.Errorf("repo: name already in use")

+ var ErrNotFound = fmt.Errorf("repo: not found")

+ var ErrRepoEmpty = fmt.Errorf("repo: this repo contains no datasets")

+ func AcceptChangeRequest(r Repo, path datastore.Key) (err error)

+ func CompareDatasetRef(a, b *DatasetRef) error

+ func DataNodes(nodes map[string]*dsgraph.Node) (ds map[string]bool)

+ func DatasetForQuery(r Repo, qpath datastore.Key) (datastore.Key, error)

+ func DatasetQueries(nodes map[string]*dsgraph.Node) (qs map[string]datastore.Key)

+ func DatasetsQuery(dss Datasets, q query.Query) (map[string]*dataset.Dataset, error)

+ func DeclineChangeRequest(r Repo, path datastore.Key) error

+ func Graph(r Repo) (map[string]*dsgraph.Node, error)

+ func HasPath(r Repo, path datastore.Key) (bool, error)

+ func IsLocalRef(r Repo, ref *DatasetRef) (bool, error)

+ func QueriesMap(nodes map[string]*dsgraph.Node) (qs map[string]datastore.Key)

+ func QueryPeers(ps Peers, q query.Query) ([]*profile.Profile, error)

+ func WalkRepoDatasets(r Repo, visit func(depth int, ref *DatasetRef, err error) (bool, error)) error

+ type ChangeRequest struct

+ Change *dataset.Dataset

+ Created time.Time

+ Path datastore.Key

+ Status string

+ Target datastore.Key

+ type ChangeRequestStore interface

+ ChangeRequestsForTarget func(target datastore.Key, limit, offset int) ([]*ChangeRequest, error)

+ GetChangeRequest func(path datastore.Key) (*ChangeRequest, error)

+ ListChangeRequests func(limit, offset int) ([]*ChangeRequest, error)

+ PutChangeRequest func(path datastore.Key, cr *ChangeRequest) error

+ type DatasetRef struct

+ Dataset *dataset.Dataset

+ Name string

+ Path string

+ Peername string

+ func ParseDatasetRef(ref string) (*DatasetRef, error)

+ func (r DatasetRef) IsPeerRef() bool

+ func (r DatasetRef) String() (s string)

+ type Datasets interface

+ DeleteDataset func(path datastore.Key) error

+ GetDataset func(path datastore.Key) (*dataset.Dataset, error)

+ PutDataset func(path datastore.Key, ds *dataset.Dataset) error

+ PutDatasets func([]*DatasetRef) error

+ Query func(query.Query) (query.Results, error)

+ type MemChangeRequests map[string]*ChangeRequest

+ func (mcr MemChangeRequests) ChangeRequestsForTarget(target datastore.Key, limit, offset int) ([]*ChangeRequest, error)

+ func (mcr MemChangeRequests) DeleteChangeRequest(path datastore.Key) error

+ func (mcr MemChangeRequests) GetChangeRequest(path datastore.Key) (*ChangeRequest, error)

+ func (mcr MemChangeRequests) ListChangeRequests(limit, offset int) ([]*ChangeRequest, error)

+ func (mcr MemChangeRequests) PutChangeRequest(path datastore.Key, cr *ChangeRequest) error

+ type MemDatasets struct

+ func NewMemDatasets(store cafs.Filestore) MemDatasets

+ func (d MemDatasets) DeleteDataset(path datastore.Key) error

+ func (d MemDatasets) GetDataset(path datastore.Key) (*dataset.Dataset, error)

+ func (d MemDatasets) PutDataset(path datastore.Key, ds *dataset.Dataset) error

+ func (d MemDatasets) PutDatasets(datasets []*DatasetRef) error

+ func (d MemDatasets) Query(q query.Query) (query.Results, error)

+ type MemNamestore []*DatasetRef

+ func (r *MemNamestore) PutName(name string, path datastore.Key) error

+ func (r MemNamestore) DeleteName(name string) error

+ func (r MemNamestore) GetName(path datastore.Key) (string, error)

+ func (r MemNamestore) GetPath(name string) (datastore.Key, error)

+ func (r MemNamestore) NameCount() (int, error)

+ func (r MemNamestore) Namespace(limit, offset int) ([]*DatasetRef, error)

+ type MemPeers map[peer.ID]*profile.Profile

+ func (m MemPeers) DeletePeer(id peer.ID) error

+ func (m MemPeers) GetID(peername string) (peer.ID, error)

+ func (m MemPeers) GetPeer(id peer.ID) (*profile.Profile, error)

+ func (m MemPeers) IPFSPeerID(peername string) (peer.ID, error)

+ func (m MemPeers) List() (map[string]*profile.Profile, error)

+ func (m MemPeers) PutPeer(id peer.ID, profile *profile.Profile) error

+ func (m MemPeers) Query(q query.Query) (query.Results, error)

+ type MemQueryLog []*QueryLogItem

+ func (ql *MemQueryLog) LogQuery(item *QueryLogItem) error

+ func (ql *MemQueryLog) QueryLogItem(q *QueryLogItem) (*QueryLogItem, error)

+ func (ql MemQueryLog) ListQueryLogs(limit, offset int) ([]*QueryLogItem, error)

+ type MemRepo struct

+ func (r *MemRepo) Analytics() analytics.Analytics

+ func (r *MemRepo) Cache() Datasets

+ func (r *MemRepo) CreateDataset(ds *dataset.Dataset, data cafs.File, pin bool) (path datastore.Key, err error)

+ func (r *MemRepo) Graph() (map[string]*dsgraph.Node, error)

+ func (r *MemRepo) Peers() Peers

+ func (r *MemRepo) Profile() (*profile.Profile, error)

+ func (r *MemRepo) SaveProfile(p *profile.Profile) error

+ func (r *MemRepo) SetPrivateKey(pk crypto.PrivKey) error

+ func (r *MemRepo) Store() cafs.Filestore

+ type Namestore interface

+ DeleteName func(name string) error

+ GetName func(path datastore.Key) (string, error)

+ GetPath func(name string) (datastore.Key, error)

+ NameCount func() (int, error)

+ Namespace func(limit, offset int) ([]*DatasetRef, error)

+ PutName func(name string, path datastore.Key) error

+ type NodeList struct

+ Nodes map[string]*dsgraph.Node

+ type Peers interface

+ DeletePeer func(id peer.ID) error

+ GetID func(peername string) (peer.ID, error)

+ GetPeer func(id peer.ID) (*profile.Profile, error)

+ IPFSPeerID func(peername string) (peer.ID, error)

+ List func() (map[string]*profile.Profile, error)

+ PutPeer func(id peer.ID, profile *profile.Profile) error

+ Query func(query.Query) (query.Results, error)

+ type QueryLog interface

+ ListQueryLogs func(limit, offset int) ([]*QueryLogItem, error)

+ LogQuery func(*QueryLogItem) error

+ QueryLogItem func(q *QueryLogItem) (*QueryLogItem, error)

+ type QueryLogItem struct

+ DatasetPath datastore.Key

+ Key datastore.Key

+ Name string

+ Query string

+ Time time.Time

+ type Repo interface

+ Analytics func() analytics.Analytics

+ Cache func() Datasets

+ CreateDataset func(ds *dataset.Dataset, data cafs.File, pin bool) (path datastore.Key, err error)

+ Graph func() (map[string]*dsgraph.Node, error)

+ Peers func() Peers

+ Profile func() (*profile.Profile, error)

+ SaveProfile func(*profile.Profile) error

+ SetPrivateKey func(pk crypto.PrivKey) error

+ Store func() cafs.Filestore

+ func NewMemRepo(p *profile.Profile, store cafs.Filestore, ps Peers, a analytics.Analytics) (Repo, error)

+ type SearchParams struct

+ Limit int

+ Offset int

+ Q string

+ type Searchable interface

+ Search func(p SearchParams) ([]*DatasetRef, error)