lib

package

Go to main page

Versions in this module

v0

v0.10.0

May 7, 2021

Changes in this version

+ const AEActivity

+ const AEApply

+ const AECanInitDatasetWorkDir

+ const AEChanges

+ const AECheckout

+ const AEComponentStatus

+ const AEConnect

+ const AEConnectedQriProfiles

+ const AEConnections

+ const AECreateAuthToken

+ const AEDAGInfo

+ const AEDiff

+ const AEDisconnect

+ const AEEnsureRef

+ const AEFSICreateLink

+ const AEFSIUnlink

+ const AEFSIWrite

+ const AEFeeds

+ const AEGet

+ const AEGetProfile

+ const AEInit

+ const AEList

+ const AEManifest

+ const AEManifestMissing

+ const AEPeer

+ const AEPeers

+ const AEPreview

+ const AEPull

+ const AEPush

+ const AERegistryNew

+ const AERegistryProve

+ const AERemoteDSync

+ const AERemoteLogSync

+ const AERemoteRefs

+ const AERemoteRemove

+ const AERemove

+ const AERename

+ const AERender

+ const AERestore

+ const AESQL

+ const AESave

+ const AESearch

+ const AESetPosterPhoto

+ const AESetProfile

+ const AESetProfilePhoto

+ const AEStatus

+ const AEValidate

+ const DenyHTTP

+ const QriStTagFspath

+ const QriStTagRefOrPath

+ var ErrDispatchNilInstance = errors.New("instance is nil, cannot dispatch")

+ var ErrDispatchNilParam = errors.New("param is nil, cannot dispatch")

+ var ErrListWarning = base.ErrUnlistableReferences

+ var ErrUnsupportedRPC = errors.New("method is not supported over RPC")

+ func DecodeParams(r *http.Request, p interface{}) error

+ func DsRefFromPath(path string) (dsref.Ref, error)

+ func HTTPPathToQriPath(path string) string

+ func IsSelectorScriptFile(selector string) bool

+ func NewHTTPRequestHandler(inst *Instance, libMethod string) http.HandlerFunc

+ func SourceFromRequest(r *http.Request) string

+ type APIEndpoint string

+ func (ae APIEndpoint) NoTrailingSlash() string

+ func (ae APIEndpoint) String() string

+ func (ae APIEndpoint) WithSuffix(suffix string) APIEndpoint

+ type AccessMethods struct

+ func (m AccessMethods) Attributes() map[string]AttributeSet

+ func (m AccessMethods) CreateAuthToken(ctx context.Context, p *CreateAuthTokenParams) (string, error)

+ func (m AccessMethods) Name() string

+ type ActivityParams struct

+ Pull bool

+ Ref string

+ type ApplyParams struct

+ Ref string

+ ScriptOutput io.Writer

+ Secrets map[string]string

+ Transform *dataset.Transform

+ Wait bool

+ func (p *ApplyParams) Validate() error

+ type ApplyResult struct

+ Data *dataset.Dataset

+ RunID string

+ type AttributeSet struct

+ DefaultSource string

+ DenyRPC bool

+ Endpoint APIEndpoint

+ HTTPVerb string

+ type AutomationMethods struct

+ func (m AutomationMethods) Apply(ctx context.Context, p *ApplyParams) (*ApplyResult, error)

+ func (m AutomationMethods) Attributes() map[string]AttributeSet

+ func (m AutomationMethods) Name() string

+ type ChangeReport = changes.ChangeReportResponse

+ type ChangeReportParams struct

+ LeftRef string

+ RightRef string

+ type CollectionMethods struct

+ func (m CollectionMethods) Attributes() map[string]AttributeSet

+ func (m CollectionMethods) List(ctx context.Context, p *ListParams) ([]dsref.VersionInfo, error)

+ func (m CollectionMethods) ListRawRefs(ctx context.Context, p *EmptyParams) (string, error)

+ func (m CollectionMethods) Name() string

type ConfigMethods

+ func (m ConfigMethods) Attributes() map[string]AttributeSet

+ func (m ConfigMethods) Name() string

+ type ConnectParamsPod struct

+ Multiaddr string

+ NetworkID string

+ Peername string

+ ProfileID string

+ func NewConnectParamsPod(s string) *ConnectParamsPod

+ func (p ConnectParamsPod) Decode() (cp p2p.PeerConnectionParams, err error)

+ func (p ConnectParamsPod) String() string

+ type ConnectionsParams struct

+ Limit int

+ Offset int

+ type CreateAuthTokenParams struct

+ GranteeProfileID string

+ GranteeUsername string

+ TTL time.Duration

+ func (p *CreateAuthTokenParams) SetNonZeroDefaults()

+ func (p *CreateAuthTokenParams) Validate() error

+ type Cursor interface

type DAGInfoParams

+ Ref string

+ type DataResponse struct

+ Data json.RawMessage

+ Path string

type DatasetMethods

+ func (m DatasetMethods) Activity(ctx context.Context, params *ActivityParams) ([]dsref.VersionInfo, error)

+ func (m DatasetMethods) Attributes() map[string]AttributeSet

+ func (m DatasetMethods) ComponentStatus(ctx context.Context, p *LinkParams) ([]StatusItem, error)

+ func (m DatasetMethods) GetCSV(ctx context.Context, p *GetParams) ([]byte, error)

+ func (m DatasetMethods) GetZip(ctx context.Context, p *GetParams) (*GetZipResults, error)

+ func (m DatasetMethods) Name() string

+ func (m DatasetMethods) Push(ctx context.Context, p *PushParams) (*dsref.Ref, error)

+ func (m DatasetMethods) Render(ctx context.Context, p *RenderParams) ([]byte, error)

+ type DiffMethods struct

+ func (m DiffMethods) Attributes() map[string]AttributeSet

+ func (m DiffMethods) Changes(ctx context.Context, p *ChangeReportParams) (*ChangeReport, error)

+ func (m DiffMethods) Diff(ctx context.Context, p *DiffParams) (*DiffResponse, error)

+ func (m DiffMethods) Name() string

+ type EmptyParams struct

type FSIMethods

+ func (m FSIMethods) Attributes() map[string]AttributeSet

+ func (m FSIMethods) Init(ctx context.Context, p *InitDatasetParams) (string, error)

+ func (m FSIMethods) Name() string

type FSIWriteParams

+ Dataset *dataset.Dataset

type GetParams

+ Ref string

+ func (p *GetParams) SetNonZeroDefaults()

+ func (p *GetParams) UnmarshalFromRequest(r *http.Request) error

+ func (p *GetParams) Validate() error

type GetResult

+ Value interface{}

+ type GetZipResults struct

+ Bytes []byte

+ GeneratedName string

+ type HTTPClient struct

+ Address string

+ Protocol string

+ func NewHTTPClient(multiaddr string) (*HTTPClient, error)

+ func NewHTTPClientWithProtocol(multiaddr string, protocol string) (*HTTPClient, error)

+ func (c HTTPClient) Call(ctx context.Context, apiEndpoint APIEndpoint, source string, ...) error

+ func (c HTTPClient) CallMethod(ctx context.Context, apiEndpoint APIEndpoint, httpMethod string, source string, ...) error

+ func (c HTTPClient) CallMethodRaw(ctx context.Context, apiEndpoint APIEndpoint, httpMethod string, source string, ...) error

+ func (c HTTPClient) CallRaw(ctx context.Context, apiEndpoint APIEndpoint, source string, ...) error

+ type InitDatasetParams = fsi.InitParams

type Instance

+ func (inst *Instance) Access() AccessMethods

+ func (inst *Instance) AllMethods() []MethodSet

+ func (inst *Instance) Automation() AutomationMethods

+ func (inst *Instance) Collection() CollectionMethods

+ func (inst *Instance) Dataset() DatasetMethods

+ func (inst *Instance) Diff() DiffMethods

+ func (inst *Instance) Dispatch(ctx context.Context, method string, param interface{}) (res interface{}, cur Cursor, err error)

+ func (inst *Instance) Filesys() FSIMethods

+ func (inst *Instance) GetConfig() *config.Config

+ func (inst *Instance) GiveAPIServer(middleware func(handler http.HandlerFunc) http.HandlerFunc, ...) *mux.Router

+ func (inst *Instance) HTTPClient() *HTTPClient

+ func (inst *Instance) Log() LogMethods

+ func (inst *Instance) NewInputParam(method string) interface{}

+ func (inst *Instance) Peer() PeerMethods

+ func (inst *Instance) Profile() ProfileMethods

+ func (inst *Instance) RegisterMethods()

+ func (inst *Instance) Registry() RegistryClientMethods

+ func (inst *Instance) RemoteServer() *remote.Remote

+ func (inst *Instance) SQL() SQLMethods

+ func (inst *Instance) Search() SearchMethods

+ func (inst *Instance) WithSource(source string) *InstanceSourceWrap

+ type InstanceSourceWrap struct

+ func (isw *InstanceSourceWrap) Dataset() DatasetMethods

+ func (isw *InstanceSourceWrap) Dispatch(ctx context.Context, method string, param interface{}) (res interface{}, cur Cursor, err error)

+ func (isw *InstanceSourceWrap) Log() LogMethods

+ func (isw *InstanceSourceWrap) Remote() RemoteMethods

+ func (isw *InstanceSourceWrap) SQL() SQLMethods

type ListParams

+ Username string

+ func (p *ListParams) SetNonZeroDefaults()

type LogMethods

+ func (m LogMethods) Attributes() map[string]AttributeSet

+ func (m LogMethods) Name() string

+ func (m LogMethods) RawLogbook(ctx context.Context, p *RawLogbookParams) (*RawLogs, error)

+ type ManifestMissingParams struct

+ Manifest *dag.Manifest

+ type ManifestParams struct

+ Ref string

+ type MethodSet interface

+ Attributes func() map[string]AttributeSet

+ Name func() string

+ type NZDefaultSetter interface

+ SetNonZeroDefaults func()

type Option

+ func OptBus(bus event.Bus) Option

+ func OptDscache(dscache *dscache.Dscache) Option

+ func OptProfiles(pros profile.Store) Option

+ type ParamValidator interface

+ Validate func() error

type PeerMethods

+ func (m PeerMethods) Attributes() map[string]AttributeSet

+ func (m PeerMethods) Connect(ctx context.Context, p *ConnectParamsPod) (*config.ProfilePod, error)

+ func (m PeerMethods) Connections(ctx context.Context, p *ConnectionsParams) ([]string, error)

+ func (m PeerMethods) Disconnect(ctx context.Context, p *ConnectParamsPod) error

+ func (m PeerMethods) Name() string

type ProfileMethods

+ func (m ProfileMethods) Attributes() map[string]AttributeSet

+ func (m ProfileMethods) Name() string

+ func (m ProfileMethods) SetProfile(ctx context.Context, p *SetProfileParams) (*config.ProfilePod, error)

+ type ProfileParams struct

type PushParams

+ Remote string

+ type RawLogbookParams struct

type RegistryClientMethods

+ func (m RegistryClientMethods) Attributes() map[string]AttributeSet

+ func (m RegistryClientMethods) Name() string

+ type RegistryProfileParams struct

+ Profile *RegistryProfile

type RemoteMethods

+ func (m RemoteMethods) Attributes() map[string]AttributeSet

+ func (m RemoteMethods) Name() string

type RemoveParams

+ func (p *RemoveParams) SetNonZeroDefaults()

type RenderParams

+ Format string

+ Selector string

+ func (p *RenderParams) SetNonZeroDefaults()

type RestoreParams

+ Selector string

+ Version string

type SQLMethods

+ func (m SQLMethods) Attributes() map[string]AttributeSet

+ func (m SQLMethods) Name() string

type SQLQueryParams

+ Format string

+ func (p *SQLQueryParams) SetNonZeroDefaults()

type SaveParams

+ Apply bool

+ func (p *SaveParams) SetNonZeroDefaults()

type SearchMethods

+ func (m SearchMethods) Attributes() map[string]AttributeSet

+ func (m SearchMethods) Name() string

type SearchParams

+ Query string

+ type SetProfileParams struct

+ Pro *config.ProfilePod

+ type WebsocketHandler interface

+ WSConnectionHandler func(w http.ResponseWriter, r *http.Request)

+ func NewWebsocketHandler(ctx context.Context, inst *Instance) (WebsocketHandler, error)

v0.9.13

Oct 12, 2020

Changes in this version

+ var ErrNoRepo = errors.New("no repo exists")

+ func PathJoinPosix(left, right string) string

+ type ValidateParams struct

+ BodyFilename string

+ Ref string

+ SchemaFilename string

+ StructureFilename string

+ type ValidateResponse struct

+ Errors []jsonschema.KeyError

+ Structure *dataset.Structure

v0.9.12

Sep 10, 2020

Changes in this version

type PullParams

+ Remote string

v0.9.11

Aug 10, 2020

v0.9.10

Jul 30, 2020

Changes in this version

+ func QriRepoExists(path string) error

type DatasetMethods

+ func (m *DatasetMethods) Pull(p *PullParams, res *dataset.Dataset) error

type DiffParams

+ Remote string

type Instance

+ func NewInstanceFromConfigAndNodeAndBus(ctx context.Context, cfg *config.Config, node *p2p.QriNode, bus event.Bus) *Instance

+ func (inst *Instance) NewParseResolveLoadFunc(remote string) (dsref.ParseResolveLoad, error)

+ func (inst *Instance) ServeWebsocket(ctx context.Context)

type ListParams

+ Public bool

type Option

+ func OptEnableRemote() Option

+ func OptEventHandler(handler event.Handler, events ...event.Type) Option

+ func OptNoBootstrap() Option

+ func OptSetOpenFileTimeout(d time.Duration) Option

+ type PullParams struct

+ LinkDir string

+ LogsOnly bool

+ Ref string

+ RemoteAddr string

type PushParams

+ All bool

type RemoteMethods

+ func (r *RemoteMethods) Pull(p *PushParams, res *dataset.Dataset) error

+ func (r *RemoteMethods) Push(p *PushParams, res *dsref.Ref) error

+ func (r *RemoteMethods) Remove(p *PushParams, res *dsref.Ref) error

type RenderParams

+ Remote string

type SetupParams

+ Overwrite bool

v0.9.9

Jul 1, 2020

Changes in this version

+ func NewParseResolveLoadFunc(username string, resolver dsref.Resolver, loader dsref.Loader) dsref.ParseResolveLoad

+ type DatasetMethods struct

+ func NewDatasetMethods(inst *Instance) *DatasetMethods

+ func (DatasetMethods) CoreRequestsName() string

+ func (m *DatasetMethods) Add(p *AddParams, res *reporef.DatasetRef) error

+ func (m *DatasetMethods) DAGInfo(s *DAGInfoParams, i *dag.Info) error

+ func (m *DatasetMethods) Diff(p *DiffParams, res *DiffResponse) (err error)

+ func (m *DatasetMethods) Get(p *GetParams, res *GetResult) error

+ func (m *DatasetMethods) List(p *ListParams, res *[]dsref.VersionInfo) error

+ func (m *DatasetMethods) ListRawRefs(p *ListParams, text *string) error

+ func (m *DatasetMethods) Manifest(refstr *string, mfst *dag.Manifest) error

+ func (m *DatasetMethods) ManifestMissing(a, b *dag.Manifest) error

+ func (m *DatasetMethods) Remove(p *RemoveParams, res *RemoveResponse) error

+ func (m *DatasetMethods) Rename(p *RenameParams, res *dsref.VersionInfo) error

+ func (m *DatasetMethods) Save(p *SaveParams, res *reporef.DatasetRef) error

+ func (m *DatasetMethods) Stats(p *StatsParams, res *StatsResponse) error

+ func (m *DatasetMethods) Validate(p *ValidateDatasetParams, valerrs *[]jsonschema.KeyError) error

+ type DiffMode int

+ const DatasetRefDiffMode

+ const FilepathDiffMode

+ const InvalidDiffMode

+ const PrevVersionDiffMode

+ const WorkingDirectoryDiffMode

type DiffParams

+ LeftSide string

+ RightSide string

+ UseLeftPrevVersion bool

type FSIMethods

+ func (m *FSIMethods) CanInitDatasetWorkDir(p *InitFSIDatasetParams, ok *bool) error

type GetParams

+ GenFilename bool

+ Outfile string

+ Remote string

type GetResult

+ Message string

type Instance

+ func (inst *Instance) Dscache() *dscache.Dscache

+ func (inst *Instance) LoadDataset(ctx context.Context, ref dsref.Ref, source string) (*dataset.Dataset, error)

+ func (inst *Instance) ParseAndResolveRef(ctx context.Context, refStr, source string) (dsref.Ref, string, error)

+ func (inst *Instance) ParseAndResolveRefWithWorkingDir(ctx context.Context, refStr, source string) (dsref.Ref, string, error)

+ func (inst *Instance) ResolveReference(ctx context.Context, ref *dsref.Ref, mode string) (string, error)

+ func (inst *Instance) ServeRPC(ctx context.Context)

+ func (inst *Instance) Shutdown() <-chan error

+ type LogMethods struct

+ func NewLogMethods(inst *Instance) *LogMethods

+ func (m *LogMethods) Log(params *LogParams, res *[]DatasetLogItem) error

+ func (m *LogMethods) Logbook(p *RefListParams, res *[]LogEntry) error

+ func (m *LogMethods) LogbookSummary(p *struct{}, res *string) (err error)

+ func (m *LogMethods) PlainLogs(p *PlainLogsParams, res *PlainLogs) (err error)

+ func (m LogMethods) CoreRequestsName() string

type LogParams

+ Pull bool

+ Source string

+ type PeerMethods struct

+ func NewPeerMethods(inst *Instance) *PeerMethods

+ func (m *PeerMethods) ConnectToPeer(p *PeerConnectionParamsPod, res *config.ProfilePod) error

+ func (m *PeerMethods) ConnectedIPFSPeers(limit *int, peers *[]string) error

+ func (m *PeerMethods) ConnectedQriProfiles(limit *int, peers *[]*config.ProfilePod) (err error)

+ func (m *PeerMethods) DisconnectFromPeer(p *PeerConnectionParamsPod, res *bool) error

+ func (m *PeerMethods) GetReferences(p *PeerRefsParams, res *[]reporef.DatasetRef) error

+ func (m *PeerMethods) Info(p *PeerInfoParams, res *config.ProfilePod) error

+ func (m *PeerMethods) List(p *PeerListParams, res *[]*config.ProfilePod) (err error)

+ func (m PeerMethods) CoreRequestsName() string

+ type RenderMethods struct

+ func NewRenderMethods(inst *Instance) *RenderMethods

+ func (RenderMethods) CoreRequestsName() string

+ func (m *RenderMethods) RenderReadme(p *RenderParams, res *string) (err error)

+ func (m *RenderMethods) RenderViz(p *RenderParams, res *[]byte) (err error)

type SQLQueryParams

+ ResolverMode string

type SaveParams

+ Drop string

type SetupParams

+ RepoPath string

type TeardownParams

+ RepoPath string

v0.9.8

Apr 20, 2020

Changes in this version

type ConfigMethods

+ func (m *ConfigMethods) GetConfigKeys(p *GetConfigParams, res *[]byte) (err error)

v0.9.7

Apr 7, 2020

Changes in this version

type FSIMethods

+ func (m *FSIMethods) WhatChanged(ref *string, res *[]StatusItem) (err error)

type GetParams

+ Refstr string

type GetResult

+ FSIPath string

+ Published bool

+ type SQLMethods struct

+ func NewSQLMethods(inst *Instance) *SQLMethods

+ func (m *SQLMethods) Exec(p *SQLQueryParams, results *[]byte) error

+ func (m SQLMethods) CoreRequestsName() string

+ type SQLQueryParams struct

+ OutputFormat string

+ Query string

v0.9.6

Mar 5, 2020

Changes in this version

type DiffResponse

+ Schema []*Delta

+ SchemaStat *DiffStat

type SaveParams

+ UseDscache bool

v0.9.5

Feb 27, 2020

Changes in this version

type AddParams

+ LogsOnly bool

type Instance

+ func (inst *Instance) Bus() event.Bus

type ListParams

+ UseDscache bool

type LogRequests

+ func (r *LogRequests) PlainLogs(p *PlainLogsParams, res *PlainLogs) (err error)

+ type PlainLogs = []logbook.PlainLog

+ type PlainLogsParams struct

+ type PreviewParams struct

+ Ref string

+ RemoteName string

type RemoteMethods

+ func (r *RemoteMethods) Feeds(remoteName *string, res *map[string][]dsref.VersionInfo) error

+ func (r *RemoteMethods) Preview(p *PreviewParams, res *dataset.Dataset) error

type RemoveResponse

+ Message string

type RenameParams

+ Next dsref.Ref

type RenderParams

+ Dataset *dataset.Dataset

+ func (p *RenderParams) Validate() error

v0.9.4

Jan 21, 2020

Changes in this version

type Instance

+ Watcher *watchfs.FilesysWatcher

type Option

+ func OptSetLogAll(logAll bool) Option

type ValidateDatasetParams

+ SchemaFilename string

+ StructureFilename string

+ UseFSI bool

v0.9.3

Dec 12, 2019

Changes in this version

+ var ErrCantRemoveDirectoryDirty = fmt.Errorf("cannot remove files while working directory is dirty")

type DatasetRequests

+ func (r *DatasetRequests) ListRawRefs(p *bool, text *string) (err error)

+ type EnsureParams struct

+ Dir string

+ Ref string

type FSIMethods

+ func (m *FSIMethods) EnsureRef(p *EnsureParams, out *bool) error

type Instance

+ func (inst *Instance) FSI() *fsi.FSI

+ type InstanceContextKey string

type ListParams

+ EnsureFSIExists bool

type Option

+ func OptLogbook(bk *logbook.Book) Option

type SaveParams

+ NewName bool

v0.9.2

Nov 18, 2019

Changes in this version

type DatasetRequests

+ func (r *DatasetRequests) Stats(p *StatsParams, res *StatsResponse) (err error)

type FSIMethods

+ func (m *FSIMethods) ModifyLink(p *LinkParams, res *bool) (err error)

type LinkParams

+ ToModify string

type Option

+ func OptStatsCache(statsCache *stats.Cache) Option

type RemoveParams

+ Force bool

+ KeepFiles bool

+ type StatsParams struct

+ Dataset *dataset.Dataset

+ Ref string

+ type StatsResponse struct

+ StatsBytes []byte

v0.9.1

Nov 6, 2019

Changes in this version

+ type DatasetLogItem = base.DatasetLogItem

type DiffParams

+ IsLeftAsPrevious bool

+ WorkingDir string

+ type FetchParams struct

+ Ref string

+ RemoteName string

+ type LogEntry = logbook.LogEntry

type LogRequests

+ func (r *LogRequests) Logbook(p *RefListParams, res *[]LogEntry) error

+ func (r *LogRequests) RawLogs(p *RawLogsParams, res *RawLogs) (err error)

+ type RawLogs = []logbook.Log

+ type RawLogsParams struct

+ type RefListParams struct

+ Limit int

+ Offset int

+ Ref string

type RemoteMethods

+ func (r *RemoteMethods) Fetch(p *FetchParams, res *repo.DatasetRef) error

type RenderParams

+ OutFormat string

+ UseFSI bool

type RenderRequests

+ func (r *RenderRequests) RenderReadme(p *RenderParams, res *string) (err error)

+ func (r *RenderRequests) RenderViz(p *RenderParams, res *[]byte) (err error)

v0.9.0

Sep 26, 2019

Changes in this version

+ type AddParams struct

+ LinkDir string

+ Ref string

+ RemoteAddr string

+ type CheckoutParams struct

+ Dir string

+ Ref string

type DatasetRequests

+ func NewDatasetRequestsInstance(inst *Instance) *DatasetRequests

+ func (r *DatasetRequests) MergeDiffs(merged *DiffResponse, inputs []DiffResponse, comps []string) (err error)

+ type FSIBodyParams struct

+ All bool

+ Format string

+ FormatConfig dataset.FormatConfig

+ Limit int

+ Offset int

+ Path string

+ type FSIMethods struct

+ func NewFSIMethods(inst *Instance) *FSIMethods

+ func (m *FSIMethods) Checkout(p *CheckoutParams, out *string) (err error)

+ func (m *FSIMethods) CreateLink(p *LinkParams, res *string) (err error)

+ func (m *FSIMethods) FSIDatasetBody(p *FSIBodyParams, res *[]byte) error

+ func (m *FSIMethods) FSIDatasetForRef(refStr *string, res *repo.DatasetRef) error

+ func (m *FSIMethods) InitDataset(p *InitFSIDatasetParams, name *string) (err error)

+ func (m *FSIMethods) LinkedRefs(p *ListParams, res *[]repo.DatasetRef) (err error)

+ func (m *FSIMethods) Restore(p *RestoreParams, out *string) (err error)

+ func (m *FSIMethods) Status(dir *string, res *[]StatusItem) (err error)

+ func (m *FSIMethods) StatusAtVersion(ref *string, res *[]StatusItem) (err error)

+ func (m *FSIMethods) StatusForAlias(alias *string, res *[]StatusItem) (err error)

+ func (m *FSIMethods) Unlink(p *LinkParams, res *string) (err error)

+ func (m *FSIMethods) UpdateLink(p *LinkParams, res *string) (err error)

+ func (m *FSIMethods) Write(p *FSIWriteParams, res *[]StatusItem) (err error)

+ func (m FSIMethods) CoreRequestsName() string

+ type FSIWriteParams struct

+ Ds *dataset.Dataset

+ Ref string

type GetParams

+ UseFSI bool

type GetResult

+ Ref *repo.DatasetRef

+ type InitFSIDatasetParams = fsi.InitParams

type Instance

+ func (inst *Instance) Connect(ctx context.Context) (err error)

+ func (inst *Instance) Remote() *remote.Remote

+ func (inst *Instance) RemoteClient() *remote.Client

+ type LinkParams struct

+ Dir string

+ Ref string

type Option

+ func OptQriNode(node *p2p.QriNode) Option

+ func OptRegistryClient(cli *regclient.Client) Option

+ func OptRemoteOptions(fn func(opt *remote.Options)) Option

+ type PublicationParams struct

+ All bool

+ Ref string

+ RemoteName string

type PushParams

+ PinOnComplete bool

+ type RegistryClientMethods struct

+ func NewRegistryClientMethods(inst *Instance) *RegistryClientMethods

+ func (RegistryClientMethods) CoreRequestsName() string

+ func (m RegistryClientMethods) CreateProfile(p *RegistryProfile, ok *bool) (err error)

+ func (m RegistryClientMethods) ProveProfileKey(p *RegistryProfile, ok *bool) error

+ type RegistryProfile = registry.Profile

+ type RemoteMethods struct

+ func NewRemoteMethods(inst *Instance) *RemoteMethods

+ func (*RemoteMethods) CoreRequestsName() string

+ func (r *RemoteMethods) Publish(p *PublicationParams, res *repo.DatasetRef) error

+ func (r *RemoteMethods) PullDataset(p *PublicationParams, res *bool) error

+ func (r *RemoteMethods) Unpublish(p *PublicationParams, res *repo.DatasetRef) error

type RemoveParams

+ DeleteFSIFiles bool

+ Unlink bool

type RemoveResponse

+ DeletedFSIFiles bool

+ Unlinked bool

+ type RestoreParams struct

+ Component string

+ Dir string

+ Ref string

type SaveParams

+ ReadFSI bool

+ Replace bool

+ WriteFSI bool

+ type SearchMethods struct

+ func NewSearchMethods(inst *Instance) *SearchMethods

+ func (m *SearchMethods) Search(p *SearchParams, results *[]SearchResult) error

+ func (m SearchMethods) CoreRequestsName() string

type SearchResult

+ URL string

+ type StatusItem = fsi.StatusItem

type ValidateDatasetParams

+ Body io.Reader

+ BodyFilename string

v0.9.0-alpha

Sep 4, 2019

v0.8.2

Jun 26, 2019

v0.8.1

Jun 11, 2019

Changes in this version

type DiffResponse

+ A interface{}

+ B interface{}

v0.8.0

Jun 5, 2019

Changes in this version

+ func GenerateFilename(ds *dataset.Dataset, format string) (string, error)

+ type ConfigMethods struct

+ func NewConfigMethods(inst *Instance) *ConfigMethods

+ func (m *ConfigMethods) GetConfig(p *GetConfigParams, res *[]byte) (err error)

+ func (m *ConfigMethods) SetConfig(update *config.Config, set *bool) (err error)

+ func (m ConfigMethods) CoreRequestsName() string

+ type Instance struct

+ func NewInstance(ctx context.Context, repoPath string, opts ...Option) (qri *Instance, err error)

+ func NewInstanceFromConfigAndNode(cfg *config.Config, node *p2p.QriNode) *Instance

+ func (inst *Instance) ChangeConfig(cfg *config.Config) (err error)

+ func (inst *Instance) Config() *config.Config

+ func (inst *Instance) Context() context.Context

+ func (inst *Instance) Node() *p2p.QriNode

+ func (inst *Instance) RPC() *rpc.Client

+ func (inst *Instance) Repo() repo.Repo

+ func (inst *Instance) RepoPath() string

+ func (inst *Instance) Teardown()

+ type InstanceOptions struct

+ Cfg *config.Config

+ Streams ioes.IOStreams

+ type Job = cron.Job

type ListParams

+ Term string

+ type Methods interface

+ CoreRequestsName func() string

+ type Option func(o *InstanceOptions) error

+ func OptCheckConfigMigrations(cfgPath string) Option

+ func OptConfig(cfg *config.Config) Option

+ func OptIOStreams(streams ioes.IOStreams) Option

+ func OptSetIPFSPath(path string) Option

+ func OptStdIOStreams() Option

+ type ProfileMethods struct

+ func NewProfileMethods(inst *Instance) *ProfileMethods

+ func (ProfileMethods) CoreRequestsName() string

+ func (m *ProfileMethods) GetProfile(in *bool, res *config.ProfilePod) (err error)

+ func (m *ProfileMethods) PosterPhoto(req *config.ProfilePod, res *[]byte) (err error)

+ func (m *ProfileMethods) ProfilePhoto(req *config.ProfilePod, res *[]byte) (err error)

+ func (m *ProfileMethods) SaveProfile(p *config.ProfilePod, res *config.ProfilePod) error

+ func (m *ProfileMethods) SetPosterPhoto(p *FileParams, res *config.ProfilePod) error

+ func (m *ProfileMethods) SetProfilePhoto(p *FileParams, res *config.ProfilePod) error

type SaveParams

+ BodyPath string

+ Message string

+ Ref string

+ Title string

+ func (p *SaveParams) AbsolutizePaths() error

+ type ScheduleParams struct

+ Name string

+ Periodicity string

+ RepoPath string

+ SaveParams *SaveParams

+ type ServiceStatus struct

+ Address string

+ Daemonized bool

+ Metrics map[string]interface{}

+ Name string

+ Running bool

+ Started *time.Time

+ type UpdateMethods struct

+ func NewUpdateMethods(inst *Instance) *UpdateMethods

+ func (m *UpdateMethods) CoreRequestsName() string

+ func (m *UpdateMethods) Job(name *string, job *Job) (err error)

+ func (m *UpdateMethods) List(p *ListParams, jobs *[]*Job) error

+ func (m *UpdateMethods) LogFile(logName *string, data *[]byte) error

+ func (m *UpdateMethods) Logs(p *ListParams, res *[]*Job) error

+ func (m *UpdateMethods) Run(p *Job, res *repo.DatasetRef) (err error)

+ func (m *UpdateMethods) Schedule(in *ScheduleParams, out *cron.Job) (err error)

+ func (m *UpdateMethods) ServiceRestart(in, out *bool) error

+ func (m *UpdateMethods) ServiceStart(p *UpdateServiceStartParams, started *bool) error

+ func (m *UpdateMethods) ServiceStatus(in *bool, out *ServiceStatus) error

+ func (m *UpdateMethods) ServiceStop(in, out *bool) error

+ func (m *UpdateMethods) Unschedule(name *string, unscheduled *bool) error

+ type UpdateServiceStartParams struct

+ Ctx context.Context

+ Daemonize bool

+ RepoPath string

+ UpdateCfg *config.Update

v0.7.3

Apr 3, 2019

Changes in this version

+ func ReadDatasetFiles(pathList ...string) (*dataset.Dataset, error)

+ type CompleteParams struct

+ SessionID string

+ type DAGInfoParams struct

+ Label string

+ RefStr string

type DatasetRequests

+ func (r *DatasetRequests) DAGInfo(s *DAGInfoParams, i *dag.Info) (err error)

+ type PushParams struct

+ Ref string

+ RemoteName string

+ type ReceiveParams struct

+ DagInfo *dag.Info

+ Name string

+ Peername string

+ ProfileID profile.ID

+ type ReceiveResult struct

+ Diff *dag.Manifest

+ RejectReason string

+ SessionID string

+ Success bool

+ type RemoteRequests struct

+ Receivers *dsync.Receivers

+ Sessions map[string]*ReceiveParams

+ func NewRemoteRequests(node *p2p.QriNode, cli *rpc.Client) *RemoteRequests

+ func (RemoteRequests) CoreRequestsName() string

+ func (r *RemoteRequests) Complete(p *CompleteParams, res *bool) (err error)

+ func (r *RemoteRequests) PushToRemote(p *PushParams, out *bool) error

+ func (r *RemoteRequests) Receive(p *ReceiveParams, res *ReceiveResult) (err error)

type SaveParams

+ FilePaths []string

+ ShouldRender bool

type SetPublishStatusParams

+ PublishStatus bool

type UpdateParams

+ ShouldRender bool

v0.7.2

Mar 14, 2019

v0.7.1

Mar 7, 2019

Changes in this version

+ type Delta = deepdiff.Delta

type DiffParams

+ All bool

+ Concise bool

+ LeftPath string

+ Limit int

+ Offset int

+ RightPath string

+ Selector string

+ type DiffResponse struct

+ Diff []*Delta

+ Stat *DiffStat

+ type DiffStat = deepdiff.Stats

type ExportParams

+ Output string

+ TargetDir string

+ Zipped bool

type ListParams

+ ShowNumVersions bool

type SaveParams

+ FilePath string

+ Force bool

v0.7.0

Feb 5, 2019

Changes in this version

type GetParams

+ All bool

+ Concise bool

+ Format string

+ FormatConfig dataset.FormatConfig

+ Limit int

+ Offset int

+ Path string

+ Selector string

+ type GetResult struct

+ Bytes []byte

+ Dataset *dataset.Dataset

+ type RemoveResponse struct

+ NumDeleted int

+ Ref string

v0.6.2

Jan 22, 2019

Changes in this version

+ type ExportParams struct

+ Format string

+ PeerDir bool

+ Ref repo.DatasetRef

+ RootDir string

+ type ExportRequests struct

+ func NewExportRequests(node *p2p.QriNode, cli *rpc.Client) *ExportRequests

+ func (r *ExportRequests) Export(p *ExportParams, ok *bool) error

+ func (r ExportRequests) CoreRequestsName() string

+ type RemoveParams struct

+ Ref *repo.DatasetRef

+ Revision rev.Rev

type SaveParams

+ ScriptOutput io.Writer

type UpdateParams

+ ScriptOutput io.Writer

v0.6.1

Dec 12, 2018

Changes in this version

type DatasetRequests

+ func (r *DatasetRequests) Manifest(refstr *string, m *dag.Manifest) (err error)

+ func (r *DatasetRequests) ManifestMissing(a, b *dag.Manifest) (err error)

+ type RegistryListParams struct

+ Limit int

+ Offset int

+ Refs []*repo.DatasetRef

type RegistryRequests

+ func (r *RegistryRequests) GetDataset(ref *repo.DatasetRef, res *repo.DatasetRef) error

+ func (r *RegistryRequests) List(params *RegistryListParams, done *bool) error

+ func (r *RegistryRequests) Pin(ref *repo.DatasetRef, done *bool) (err error)

+ func (r *RegistryRequests) Unpin(ref *repo.DatasetRef, done *bool) error

type SaveParams

+ ConvertFormatToPrev bool

+ Secrets map[string]string

+ type SetPublishStatusParams struct

+ Ref *repo.DatasetRef

+ UpdateRegistry bool

+ UpdateRegistryPin bool

v0.6.0

Nov 9, 2018

Changes in this version

+ func AbsPath(path *string) (err error)

+ func ReadDatasetFile(path string) (dsp *dataset.DatasetPod, err error)

type DatasetRequests

+ func (r *DatasetRequests) SetPublishStatus(ref *repo.DatasetRef, res *bool) error

+ func (r *DatasetRequests) Update(p *UpdateParams, res *repo.DatasetRef) error

type ListParams

+ Published bool

type SaveParams

+ DatasetPath string

+ Recall string

+ type UpdateParams struct

+ DryRun bool

+ Message string

+ Publish bool

+ Recall string

+ Ref string

+ ReturnBody bool

+ Secrets map[string]string

+ Title string

v0.5.6

Oct 10, 2018

Changes in this version

type SetupParams

+ Generator gen.CryptoGenerator

v0.5.5

Oct 5, 2018

v0.5.4

Oct 1, 2018

v0.5.3

Sep 24, 2018

Changes in this version

type SaveParams

+ DryRun bool

+ ReturnBody bool

v0.5.2

Sep 14, 2018

Changes in this version

+ var ErrBadArgs = errors.New("bad arguments provided")

type DatasetRequests

+ func (r *DatasetRequests) New(p *SaveParams, res *repo.DatasetRef) (err error)

+ type LogRequests struct

+ func NewLogRequests(node *p2p.QriNode, cli *rpc.Client) *LogRequests

+ func (r *LogRequests) Log(params *LogParams, res *[]repo.DatasetRef) (err error)

+ func (r LogRequests) CoreRequestsName() string

type SetupParams

+ Register bool

v0.5.1

Jul 19, 2018

Changes in this version

+ const VersionNumber

+ var DefaultTemplate = ...

+ type Error struct

+ func NewError(err error, msg string) Error

+ func (e Error) Error() string

+ func (e Error) Message() string

+ type PublishParams struct

+ Pin bool

+ Ref repo.DatasetRef

type RegistryRequests

+ func NewRegistryRequestsWithNode(r repo.Repo, cli *rpc.Client, node *p2p.QriNode) *RegistryRequests

+ func (r *RegistryRequests) Status(ref *repo.DatasetRef, done *bool) error

v0.5.1-rc1

Jul 14, 2018

v0.5.0

Jun 18, 2018

Changes in this version

+ const DefaultPageSize

+ var Config *config.Config

+ var ConfigFilepath string

+ var ErrHandleTaken = fmt.Errorf("handle is taken")

+ var ErrUpdateRequired = fmt.Errorf("update required")

+ var LastPubVerHash = "/ipfs/QmcXZCLAgUdvXpt1fszjNGVGn6WnhsrJahkQXY3JJqxUWJ"

+ var PrevIPNSName = "/ipns/cli.previous.qri.io"

+ var SaveConfig = func() error

+ func CheckVersion(ctx context.Context, res namesys.Resolver, lookupAddr, localHash string) (latest string, err error)

+ func DefaultSelectedRef(r repo.Repo, ref *repo.DatasetRef) (err error)

+ func DefaultSelectedRefs(r repo.Repo, refs *[]repo.DatasetRef) (err error)

+ func GetConfig(p *GetConfigParams, res *[]byte) error

+ func LoadConfig(path string) (err error)

+ func SetConfig(res *config.Config) error

+ func Setup(p SetupParams) error

+ func Teardown(p TeardownParams) error

+ type DatasetRequests struct

+ Node *p2p.QriNode

+ func NewDatasetRequests(r repo.Repo, cli *rpc.Client) *DatasetRequests

+ func NewDatasetRequestsWithNode(r repo.Repo, cli *rpc.Client, node *p2p.QriNode) *DatasetRequests

+ func (DatasetRequests) CoreRequestsName() string

+ func (r *DatasetRequests) Add(ref *repo.DatasetRef, res *repo.DatasetRef) (err error)

+ func (r *DatasetRequests) Diff(p *DiffParams, diffs *map[string]*dsdiff.SubDiff) (err error)

+ func (r *DatasetRequests) Get(p *repo.DatasetRef, res *repo.DatasetRef) (err error)

+ func (r *DatasetRequests) Init(p *SaveParams, res *repo.DatasetRef) (err error)

+ func (r *DatasetRequests) List(p *ListParams, res *[]repo.DatasetRef) error

+ func (r *DatasetRequests) LookupBody(p *LookupParams, data *LookupResult) (err error)

+ func (r *DatasetRequests) Remove(p *repo.DatasetRef, ok *bool) (err error)

+ func (r *DatasetRequests) Rename(p *RenameParams, res *repo.DatasetRef) (err error)

+ func (r *DatasetRequests) Repo() repo.Repo

+ func (r *DatasetRequests) Save(p *SaveParams, res *repo.DatasetRef) (err error)

+ func (r *DatasetRequests) Select(p *SelectParams, res *[]byte) (err error)

+ func (r *DatasetRequests) Validate(p *ValidateDatasetParams, errors *[]jsonschema.ValError) (err error)

+ type DiffParams struct

+ DiffAll bool

+ DiffComponents map[string]bool

+ Left repo.DatasetRef

+ Right repo.DatasetRef

+ type FileParams struct

+ Data io.Reader

+ Filename string

+ type GetConfigParams struct

+ Concise bool

+ Field string

+ Format string

+ WithPrivateKey bool

+ type GetParams struct

+ Hash string

+ Name string

+ Username string

+ type HistoryRequests struct

+ Node *p2p.QriNode

+ func NewHistoryRequests(r repo.Repo, cli *rpc.Client) *HistoryRequests

+ func (d *HistoryRequests) Log(params *LogParams, res *[]repo.DatasetRef) (err error)

+ func (d HistoryRequests) CoreRequestsName() string

+ type ListParams struct

+ Limit int

+ Offset int

+ OrderBy string

+ Peername string

+ ProfileID profile.ID

+ RPC bool

+ func ListParamsFromRequest(r *http.Request) ListParams

+ func NewListParams(orderBy string, page, pageSize int) ListParams

+ func (lp ListParams) Page() util.Page

+ type LogParams struct

+ Ref repo.DatasetRef

+ type LookupParams struct

+ All bool

+ Format dataset.DataFormat

+ FormatConfig dataset.FormatConfig

+ Limit int

+ Offset int

+ Path string

+ type LookupResult struct

+ Data []byte

+ Path string

+ type PeerConnectionParamsPod struct

+ Multiaddr string

+ NetworkID string

+ Peername string

+ ProfileID string

+ func NewPeerConnectionParamsPod(s string) *PeerConnectionParamsPod

+ func (p PeerConnectionParamsPod) Decode() (cp p2p.PeerConnectionParams, err error)

+ type PeerInfoParams struct

+ Peername string

+ ProfileID profile.ID

+ Verbose bool

+ type PeerListParams struct

+ Cached bool

+ Limit int

+ Offset int

+ type PeerRefsParams struct

+ Limit int

+ Offset int

+ PeerID string

+ type PeerRequests struct

+ func NewPeerRequests(node *p2p.QriNode, cli *rpc.Client) *PeerRequests

+ func (d *PeerRequests) ConnectToPeer(p *PeerConnectionParamsPod, res *config.ProfilePod) error

+ func (d *PeerRequests) ConnectedIPFSPeers(limit *int, peers *[]string) error

+ func (d *PeerRequests) ConnectedQriProfiles(limit *int, peers *[]*config.ProfilePod) error

+ func (d *PeerRequests) DisconnectFromPeer(p *PeerConnectionParamsPod, res *bool) error

+ func (d *PeerRequests) GetReferences(p *PeerRefsParams, res *[]repo.DatasetRef) error

+ func (d *PeerRequests) Info(p *PeerInfoParams, res *config.ProfilePod) error

+ func (d *PeerRequests) List(p *PeerListParams, res *[]*config.ProfilePod) error

+ func (d PeerRequests) CoreRequestsName() string

+ type ProfileRequests struct

+ func NewProfileRequests(r repo.Repo, cli *rpc.Client) *ProfileRequests

+ func (ProfileRequests) CoreRequestsName() string

+ func (r *ProfileRequests) GetProfile(in *bool, res *config.ProfilePod) (err error)

+ func (r *ProfileRequests) PosterPhoto(req *config.ProfilePod, res *[]byte) (err error)

+ func (r *ProfileRequests) ProfilePhoto(req *config.ProfilePod, res *[]byte) (err error)

+ func (r *ProfileRequests) SaveProfile(p *config.ProfilePod, res *config.ProfilePod) error

+ func (r *ProfileRequests) SetPosterPhoto(p *FileParams, res *config.ProfilePod) error

+ func (r *ProfileRequests) SetProfilePhoto(p *FileParams, res *config.ProfilePod) error

+ type RegistryRequests struct

+ func NewRegistryRequests(r repo.Repo, cli *rpc.Client) *RegistryRequests

+ func (RegistryRequests) CoreRequestsName() string

+ func (r *RegistryRequests) Publish(ref *repo.DatasetRef, done *bool) error

+ func (r *RegistryRequests) Unpublish(ref *repo.DatasetRef, done *bool) error

+ type RenameParams struct

+ Current repo.DatasetRef

+ New repo.DatasetRef

+ type RenderParams struct

+ All bool

+ Limit int

+ Offset int

+ Ref string

+ Template []byte

+ TemplateFormat string

+ type RenderRequests struct

+ func NewRenderRequests(r repo.Repo, cli *rpc.Client) *RenderRequests

+ func (RenderRequests) CoreRequestsName() string

+ func (r *RenderRequests) Render(p *RenderParams, res *[]byte) error

+ type Requests interface

+ CoreRequestsName func() string

+ func Receivers(node *p2p.QriNode) []Requests

+ type SaveParams struct

+ Dataset *dataset.DatasetPod

+ Private bool

+ Publish bool

+ type SearchParams struct

+ Limit int

+ Offset int

+ QueryString string

+ type SearchRequests struct

+ func NewSearchRequests(r repo.Repo, cli *rpc.Client) *SearchRequests

+ func (sr *SearchRequests) Search(p *SearchParams, results *[]SearchResult) error

+ func (sr SearchRequests) CoreRequestsName() string

+ type SearchResult struct

+ ID string

+ Type string

+ Value interface{}

+ type SelectParams struct

+ Concise bool

+ Format string

+ Path string

+ Refs []repo.DatasetRef

+ type SelectionRequests struct

+ func NewSelectionRequests(r repo.Repo, cli *rpc.Client) *SelectionRequests

+ func (r *SelectionRequests) SelectedRefs(done *bool, sel *[]repo.DatasetRef) (err error)

+ func (r *SelectionRequests) SetSelectedRefs(sel *[]repo.DatasetRef, done *bool) error

+ func (r SelectionRequests) CoreRequestsName() string

+ type SetupParams struct

+ Config *config.Config

+ ConfigFilepath string

+ IPFSFsPath string

+ QriRepoPath string

+ SetupIPFS bool

+ SetupIPFSConfigData []byte

+ type TeardownParams struct

+ Config *config.Config

+ ConfigFilepath string

+ QriRepoPath string

+ type ValidateDatasetParams struct

+ Data io.Reader

+ DataFilename string

+ Ref repo.DatasetRef

+ Schema io.Reader

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL