remote

type Client interface {
	ListDatasets(ctx context.Context, ds *reporef.DatasetRef, term string, offset, limit int) ([]reporef.DatasetRef, error)
	ResolveHeadRef(ctx context.Context, ref *reporef.DatasetRef, remoteAddr string) error
	NewRemoteRefResolver(addr string) dsref.Resolver

	PushDataset(ctx context.Context, ref reporef.DatasetRef, remoteAddr string) error
	PullDataset(ctx context.Context, ref *reporef.DatasetRef, remoteAddr string) error
	RemoveDataset(ctx context.Context, ref reporef.DatasetRef, remoteAddr string) error
	AddDataset(ctx context.Context, ref *reporef.DatasetRef, remoteAddr string) error

	PushLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error
	FetchLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) (*oplog.Log, error)
	CloneLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error
	RemoveLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error

	Feeds(ctx context.Context, remoteAddr string) (map[string][]dsref.VersionInfo, error)
	Preview(ctx context.Context, ref dsref.Ref, remoteAddr string) (*dataset.Dataset, error)
}

type Feeds interface {
	// Feeds returns a set of feeds keyed by name, the number of results in each
	// feed, and the number of feeds themselves is up to the server
	Feeds(ctx context.Context, userID string) (map[string][]dsref.VersionInfo, error)
	// Feed fetches a bounded set of VersionInfos for a given feed name
	Feed(ctx context.Context, userID, name string, offset, limit int) ([]dsref.VersionInfo, error)
}

type Hook func(ctx context.Context, pid profile.ID, ref reporef.DatasetRef) error

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

type Options struct {
	// called when a client requests to push a dataset, before any data has been
	// received
	DatasetPushPreCheck Hook
	// called when a dataset has been pushed, but before it's saved
	DatasetPushFinalCheck Hook
	// called after successfully publishing a dataset version
	DatasetPushed Hook
	// called when a client has unpublished a dataset version
	DatasetRemovePreCheck Hook
	// called after a dataset version has been removed
	DatasetRemoved Hook
	// called before a version pull is permitted
	DatasetPullPreCheck Hook
	// called when a client pulls a dataset
	DatasetPulled Hook

	// called before any log data is accepted from a client
	LogPushPreCheck Hook
	// called after a log has been received by a client, before it's saved
	LogPushFinalCheck Hook
	// called after a log has been pushed
	LogPushed Hook
	// called before a log pull is allowed
	LogPullPreCheck Hook
	// called after a log has been pulled
	LogPulled Hook
	// called before a log remove is performed
	LogRemovePreCheck Hook
	// called after a log has been removed
	LogRemoved Hook

	// called before any feed data request is processed
	FeedPreCheck Hook
	// called before a preview request is processed
	PreviewPreCheck Hook

	// Use a custom feeds interface implementation. Default creates a Feeds
	// instance from node.Repo
	Feeds
	// Use a custom previews interface implementation. Default creates a
	// Previews instance from node.Repo
	Previews
}

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

type Previews interface {
	Preview(ctx context.Context, userID, refStr string) (*dataset.Dataset, error)
	PreviewComponent(ctx context.Context, userID, refStr, component string) (interface{}, error)
}

type Remote struct {
	Feeds    Feeds
	Previews Previews

	FeedPreCheck    Hook
	PreviewPreCheck Hook
	// contains filtered or unexported fields
}

type RepoFeeds struct {
	repo.Repo
}

type RepoPreviews struct {
	repo.Repo
}