registry

type Dataset struct {
	// Dataset   dataset.Dataset
	Commit    *dataset.Commit    `json:"commit,omitempty"`
	Meta      *dataset.Meta      `json:"meta,omitempty"`
	Path      string             `json:"path,omitempty"`
	Structure *dataset.Structure `json:"structure,omitempty"`
	ProfileID string             `json:"profileID,omitempty"`

	Handle    string `json:",omitempty"`
	Name      string `json:",omitempty"`
	PublicKey string `json:",omitempty"`
}

type Datasets interface {
	// Len returns the number of records in the set
	Len() int
	// Load fetches a dataset from the list by key
	Load(key string) (value *Dataset, ok bool)
	// Range calls an iteration fuction on each element in the map until
	// the end of the list is reached or iter returns true
	Range(iter func(key string, p *Dataset) (brk bool))
	// SortedRange is like range but with deterministic key ordering
	SortedRange(iter func(key string, p *Dataset) (brk bool))

	// Store adds an entry, bypassing the register process
	// store is only exported for administrative use cases.
	// most of the time callers should use Register instead
	Store(key string, value *Dataset)
	// Delete removes a record stored at key
	// Delete is only exported for administrative use cases.
	// most of the time callers should use Deregister instead
	Delete(key string)
}

type Indexer interface {
	// IndexDatasets adds one or more datasets to a search index
	IndexDatasets([]*Dataset) error
	// UnindexDatasets removes one or more datasets from a search index
	UnindexDatasets([]*Dataset) error
}

type MemDatasets struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type MemProfiles struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type MemReputations struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type MockSearch struct {
	Datasets Datasets
}

type NilSearch bool

type Profile struct {
	ProfileID string
	Handle    string
	Signature string `json:",omitempty"`
	PublicKey string `json:",omitempty"`
	Created   time.Time
}

type Profiles interface {
	// Len returns the number of records in the set
	Len() int
	// Load fetches a profile from the list by key
	Load(key string) (value *Profile, ok bool)
	// Range calls an iteration fuction on each element in the map until
	// the end of the list is reached or iter returns true
	Range(iter func(key string, p *Profile) (brk bool))
	// SortedRange is like range but with deterministic key ordering
	SortedRange(iter func(key string, p *Profile) (brk bool))

	// Store adds an entry, bypassing the register process
	// store is only exported for administrative use cases.
	// most of the time callers should use Register instead
	Store(key string, value *Profile)
	// Delete removes a record from the set at key
	// Delete is only exported for administrative use cases.
	// most of the time callers should use Deregister instead
	Delete(key string)
}

type Registry struct {
	Profiles    Profiles
	Datasets    Datasets
	Reputations Reputations
	Search      Searchable
	Indexer     Indexer
}

type Reputation struct {
	ProfileID string
	Rep       int
}

type ReputationResponse struct {
	Reputation *Reputation
	Expiration time.Duration
}

type Reputations interface {
	// Len returns the number of records in the set
	Len() int
	// Load fetches a profile from the list by key
	Load(key string) (value *Reputation, ok bool)
	// Range calls an iteration fuction on each element in the map until
	// the end of the list is reached or iter returns true
	Range(iter func(key string, r *Reputation) (brk bool))
	// SortedRange is like range but with deterministic key ordering
	SortedRange(iter func(key string, r *Reputation) (brk bool))
	// Add adds the Reputation to the list of reputations
	Add(r *Reputation) error

	// Store adds an entry, bypassing the register process
	// store is only exported for administrative use cases.
	// most of the time callers should use Register instead
	Store(key string, value *Reputation)
	// Delete removes a record from the set at key
	// Delete is only exported for administrative use cases.
	// most of the time callers should use Deregister instead
	Delete(key string)
}

type Result struct {
	Type  string      // one of ["dataset", "profile"] for now
	ID    string      // identifier to lookup
	Value interface{} // Value returned
}

type SearchParams struct {
	Q             string
	Limit, Offset int
}

type Searchable interface {
	Search(p SearchParams) ([]Result, error)
}