remote

Sep 10, 2020

Changes in this version

type Client

+ Shutdown func() <-chan struct{}

type MockClient

+ func (c *MockClient) Shutdown() <-chan struct{}

type Options

+ Policy *access.Policy

+ type OptionsFunc func(o *Options)

+ func OptLoadPolicyFileIfExists(filename string) OptionsFunc

+ func OptPolicy(p *access.Policy) OptionsFunc

+ type OtherPeer struct

type Remote

+ func (r *Remote) Policy() *access.Policy

Jul 30, 2020

Changes in this version

+ func PrintProgressBarsOnPushPull(w io.Writer, bus event.Bus)

type Client

+ Done func() <-chan struct{}

+ DoneErr func() error

+ Feed func(ctx context.Context, remoteAddr, feedName string, page, pageSize int) ([]dsref.VersionInfo, error)

+ PreviewDatasetVersion func(ctx context.Context, ref dsref.Ref, remoteAddr string) (*dataset.Dataset, error)

+ RemoveDatasetVersion func(ctx context.Context, ref dsref.Ref, remoteAddr string) error

+ type LocalPreviews struct

+ func (rp LocalPreviews) Preview(ctx context.Context, _, refStr string) (*dataset.Dataset, error)

+ func (rp LocalPreviews) PreviewComponent(ctx context.Context, _, refStr, component string) (interface{}, error)

type MockClient

+ func (c *MockClient) Done() <-chan struct{}

+ func (c *MockClient) DoneErr() error

+ func (c *MockClient) Feed(ctx context.Context, remoteAddr, feedName string, page, pageSize int) ([]dsref.VersionInfo, error)

+ func (c *MockClient) PreviewDatasetVersion(ctx context.Context, ref dsref.Ref, remoteAddr string) (*dataset.Dataset, error)

+ func (c *MockClient) PullDatasetVersion(ctx context.Context, ref *dsref.Ref, remoteAddr string) error

+ func (c *MockClient) RemoveDatasetVersion(ctx context.Context, ref dsref.Ref, remoteAddr string) error

type Remote

+ func (r *Remote) GoOnline(ctx context.Context) error

Jul 1, 2020

Changes in this version

type Client

+ NewRemoteRefResolver func(addr string) dsref.Resolver

type MockClient

+ func (c *MockClient) NewRemoteRefResolver(addr string) dsref.Resolver

type PeerSyncClient

+ func (c *PeerSyncClient) NewRemoteRefResolver(remoteAddr string) dsref.Resolver

Feb 27, 2020

Changes in this version

+ var ErrRemoteNotFound = fmt.Errorf("remote not found")

type Client

+ CloneLogs func(ctx context.Context, ref dsref.Ref, remoteAddr string) error

+ Feeds func(ctx context.Context, remoteAddr string) (map[string][]dsref.VersionInfo, error)

+ FetchLogs func(ctx context.Context, ref dsref.Ref, remoteAddr string) (*oplog.Log, error)

+ Preview func(ctx context.Context, ref dsref.Ref, remoteAddr string) (*dataset.Dataset, error)

+ type Feeds interface

+ Feed func(ctx context.Context, userID, name string, offset, limit int) ([]dsref.VersionInfo, error)

+ Feeds func(ctx context.Context, userID string) (map[string][]dsref.VersionInfo, error)

type MockClient

+ func (c *MockClient) CloneLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error

+ func (c *MockClient) Feeds(ctx context.Context, remoteAddr string) (map[string][]dsref.VersionInfo, error)

+ func (c *MockClient) FetchLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) (*oplog.Log, error)

+ func (c *MockClient) Preview(ctx context.Context, ref dsref.Ref, remoteAddr string) (*dataset.Dataset, error)

type Options

+ FeedPreCheck Hook

+ PreviewPreCheck Hook

type PeerSyncClient

+ func (c *PeerSyncClient) CloneLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error

+ func (c *PeerSyncClient) Feeds(ctx context.Context, remoteAddr string) (map[string][]dsref.VersionInfo, error)

+ func (c *PeerSyncClient) FetchLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) (*oplog.Log, error)

+ func (c *PeerSyncClient) Preview(ctx context.Context, ref dsref.Ref, remoteAddr string) (*dataset.Dataset, error)

+ type Previews interface

+ Preview func(ctx context.Context, userID, refStr string) (*dataset.Dataset, error)

+ PreviewComponent func(ctx context.Context, userID, refStr, component string) (interface{}, error)

type Remote

+ FeedPreCheck Hook

+ Feeds Feeds

+ PreviewPreCheck Hook

+ Previews Previews

+ func (r *Remote) AddDefaultRoutes(mux *http.ServeMux)

+ func (r *Remote) ComponentHTTPHandler(prefix string) http.HandlerFunc

+ func (r *Remote) FeedHTTPHandler(prefix string) http.HandlerFunc

+ func (r *Remote) FeedsHTTPHandler() http.HandlerFunc

+ func (r *Remote) Node() *p2p.QriNode

+ func (r *Remote) PreviewHTTPHandler(prefix string) http.HandlerFunc

+ type RepoFeeds struct

+ func (rf RepoFeeds) Feed(ctx context.Context, userID, name string, offset, limit int) ([]dsref.VersionInfo, error)

+ func (rf RepoFeeds) Feeds(ctx context.Context, userID string) (map[string][]dsref.VersionInfo, error)

+ type RepoPreviews struct

+ func (rp RepoPreviews) Preview(ctx context.Context, _, refStr string) (*dataset.Dataset, error)

+ func (rp RepoPreviews) PreviewComponent(ctx context.Context, _, refStr, component string) (interface{}, error)

Dec 12, 2019

Changes in this version

+ var ErrNotImplemented = fmt.Errorf("not implemented")

type Client

+ func NewMockClient(node *p2p.QriNode) (c Client, err error)

+ type MockClient struct

+ func (c *MockClient) AddDataset(ctx context.Context, ref *repo.DatasetRef, remoteAddr string) error

+ func (c *MockClient) ListDatasets(ctx context.Context, ds *repo.DatasetRef, term string, offset, limit int) (res []repo.DatasetRef, err error)

+ func (c *MockClient) PullDataset(ctx context.Context, ref *repo.DatasetRef, remoteAddr string) error

+ func (c *MockClient) PullLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error

+ func (c *MockClient) PushDataset(ctx context.Context, ref repo.DatasetRef, remoteAddr string) error

+ func (c *MockClient) PushLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error

+ func (c *MockClient) RemoveDataset(ctx context.Context, ref repo.DatasetRef, remoteAddr string) error

+ func (c *MockClient) RemoveLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error

+ func (c *MockClient) ResolveHeadRef(ctx context.Context, ref *repo.DatasetRef, remoteAddr string) error

+ type PeerSyncClient struct

+ func (c *PeerSyncClient) AddDataset(ctx context.Context, ref *repo.DatasetRef, remoteAddr string) (err error)

+ func (c *PeerSyncClient) ListDatasets(ctx context.Context, ds *repo.DatasetRef, term string, offset, limit int) (res []repo.DatasetRef, err error)

+ func (c *PeerSyncClient) PullDataset(ctx context.Context, ref *repo.DatasetRef, remoteAddr string) error

+ func (c *PeerSyncClient) PullLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error

+ func (c *PeerSyncClient) PushDataset(ctx context.Context, ref repo.DatasetRef, remoteAddr string) error

+ func (c *PeerSyncClient) PushLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error

+ func (c *PeerSyncClient) RemoveDataset(ctx context.Context, ref repo.DatasetRef, remoteAddr string) error

+ func (c *PeerSyncClient) RemoveLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error

+ func (c *PeerSyncClient) ResolveHeadRef(ctx context.Context, ref *repo.DatasetRef, remoteAddr string) error

Nov 6, 2019

Changes in this version

+ func OplogFromContext(ctx context.Context) (l *oplog.Log, ok bool)

+ func VerifySigParams(pubkey crypto.PubKey, params map[string]string) (bool, error)

type Client

+ func (c *Client) AddDataset(ctx context.Context, ref *repo.DatasetRef, remoteAddr string) (err error)

+ func (c *Client) ListDatasets(ctx context.Context, ds *repo.DatasetRef, term string, offset, limit int) (res []repo.DatasetRef, err error)

+ func (c *Client) PullLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error

+ func (c *Client) PushLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error

+ func (c *Client) RemoveLogs(ctx context.Context, ref dsref.Ref, remoteAddr string) error

type Options

+ DatasetPullPreCheck Hook

+ DatasetPushFinalCheck Hook

+ DatasetPushPreCheck Hook

+ DatasetRemovePreCheck Hook

+ LogPullPreCheck Hook

+ LogPulled Hook

+ LogPushFinalCheck Hook

+ LogPushPreCheck Hook

+ LogPushed Hook

+ LogRemovePreCheck Hook

+ LogRemoved Hook

type Remote

+ func (r *Remote) LogsyncHTTPHandler() http.HandlerFunc

+ func (r *Remote) RemoveDataset(ctx context.Context, params map[string]string) error

Sep 26, 2019

Changes in this version

+ var ErrNoRemoteClient = fmt.Errorf("not configured to make remote requests")

+ func Address(cfg *config.Config, name string) (addr string, err error)

+ type Client struct

+ func NewClient(node *p2p.QriNode) (*Client, error)

+ func (c *Client) CoreAPI() coreiface.CoreAPI

+ func (c *Client) PullDataset(ctx context.Context, ref *repo.DatasetRef, remoteAddr string) error

+ func (c *Client) PushDataset(ctx context.Context, ref repo.DatasetRef, remoteAddr string) error

+ func (c *Client) RemoveDataset(ctx context.Context, ref repo.DatasetRef, remoteAddr string) error

+ func (c *Client) ResolveHeadRef(ctx context.Context, ref *repo.DatasetRef, remoteAddr string) error

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

+ type Options struct

+ AcceptPushFinalCheck Hook

+ AcceptPushPreCheck Hook

+ DatasetPulled Hook

+ DatasetPushed Hook

+ DatasetRemoved Hook

+ type Remote struct

+ func NewRemote(node *p2p.QriNode, cfg *config.Remote, opts ...func(o *Options)) (*Remote, error)

+ func (r *Remote) DsyncHTTPHandler() http.HandlerFunc

+ func (r *Remote) RefsHTTPHandler() http.HandlerFunc

+ func (r *Remote) RemoveDatasetRef(ctx context.Context, params map[string]string) error

+ func (r *Remote) ResolveHeadRef(ctx context.Context, peername, name string) (*repo.DatasetRef, error)