Documentation ¶
Overview ¶
package shell implements a remote API interface for a running ipfs daemon
Index ¶
- Constants
- type Error
- type IdOutput
- type IpfsObject
- type LsLink
- type LsObject
- type ObjectLink
- type ObjectStats
- type PeerInfo
- type PinInfo
- type PubSubRecord
- type PubSubSubscription
- type Request
- type Response
- type Shell
- func (s *Shell) Add(r io.Reader) (string, error)
- func (s *Shell) AddDir(dir string) (string, error)
- func (s *Shell) AddLink(target string) (string, error)
- func (s *Shell) AddNoPin(r io.Reader) (string, error)
- func (s *Shell) AddWithOpts(r io.Reader, pin bool, rawLeaves bool) (string, error)
- func (s *Shell) BlockGet(path string) ([]byte, error)
- func (s *Shell) BlockPut(block []byte) (string, error)
- func (s *Shell) BlockStat(path string) (string, int, error)
- func (s *Shell) Cat(path string) (io.ReadCloser, error)
- func (s *Shell) DagGet(ref string, out interface{}) error
- func (s *Shell) DagPut(data interface{}, ienc, kind string) (string, error)
- func (s *Shell) FileList(path string) (*UnixLsObject, error)
- func (s *Shell) FindPeer(peer string) (*PeerInfo, error)
- func (s *Shell) Get(hash, outdir string) error
- func (s *Shell) ID(peer ...string) (*IdOutput, error)
- func (s *Shell) IsUp() bool
- func (s *Shell) List(path string) ([]*LsLink, error)
- func (s *Shell) NewObject(template string) (string, error)
- func (s *Shell) ObjectGet(path string) (*IpfsObject, error)
- func (s *Shell) ObjectPut(obj *IpfsObject) (string, error)
- func (s *Shell) ObjectStat(key string) (*ObjectStats, error)
- func (s *Shell) Patch(root, action string, args ...string) (string, error)
- func (s *Shell) PatchData(root string, set bool, data interface{}) (string, error)
- func (s *Shell) PatchLink(root, path, childhash string, create bool) (string, error)
- func (s *Shell) Pin(path string) error
- func (s *Shell) Pins() (map[string]PinInfo, error)
- func (s *Shell) PubSubPublish(topic, data string) (err error)
- func (s *Shell) PubSubSubscribe(topic string) (*PubSubSubscription, error)
- func (s *Shell) Publish(node string, value string) error
- func (s *Shell) Refs(hash string, recursive bool) (<-chan string, error)
- func (s *Shell) Resolve(id string) (string, error)
- func (s *Shell) ResolvePath(path string) (string, error)
- func (s *Shell) SetTimeout(d time.Duration)
- func (s *Shell) Unpin(path string) error
- func (s *Shell) Version() (string, string, error)
- type UnixLsLink
- type UnixLsObject
Constants ¶
const ( DefaultPathName = ".ipfs" DefaultPathRoot = "~/" + DefaultPathName DefaultApiFile = "api" EnvDir = "IPFS_PATH" )
const ( TRaw = iota TDirectory TFile TMetadata TSymlink )
const ( DirectPin = "direct" RecursivePin = "recursive" IndirectPin = "indirect" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IpfsObject ¶
type IpfsObject struct { Links []ObjectLink Data string }
type ObjectLink ¶
type ObjectStats ¶ added in v1.2.0
type PubSubRecord ¶ added in v1.2.0
type PubSubRecord interface { // From returns the peer ID of the node that published this record From() peer.ID // Data returns the data field Data() []byte // SeqNo is the sequence number of this record SeqNo() int64 //TopicIDs is the list of topics this record belongs to TopicIDs() []string }
PubSubRecord is a record received via PubSub.
type PubSubSubscription ¶ added in v1.2.0
type PubSubSubscription struct {
// contains filtered or unexported fields
}
PubSubSubscription allow you to receive pubsub records that where published on the network.
func (*PubSubSubscription) Cancel ¶ added in v1.2.0
func (s *PubSubSubscription) Cancel() error
Cancel cancels the given subscription.
func (*PubSubSubscription) Next ¶ added in v1.2.0
func (s *PubSubSubscription) Next() (PubSubRecord, error)
Next waits for the next record and returns that.
type Request ¶
type Request struct { ApiBase string Command string Args []string Opts map[string]string Body io.Reader Headers map[string]string }
func NewRequest ¶
type Response ¶
type Response struct { Output io.ReadCloser Error *Error }
type Shell ¶
type Shell struct {
// contains filtered or unexported fields
}
func NewLocalShell ¶ added in v1.2.0
func NewLocalShell() *Shell
func NewShellWithClient ¶ added in v1.2.0
func (*Shell) AddNoPin ¶ added in v1.2.0
AddNoPin a file to ipfs from the given reader, returns the hash of the added file without pinning the file
func (*Shell) AddWithOpts ¶ added in v1.2.0
func (*Shell) Cat ¶
func (s *Shell) Cat(path string) (io.ReadCloser, error)
Cat the content at the given path. Callers need to drain and close the returned reader after usage.
func (*Shell) FileList ¶
func (s *Shell) FileList(path string) (*UnixLsObject, error)
FileList entries at the given path using the UnixFS commands
func (*Shell) ID ¶
ID gets information about a given peer. Arguments:
peer: peer.ID of the node to look up. If no peer is specified,
return information about the local peer.
func (*Shell) ObjectStat ¶ added in v1.2.0
func (s *Shell) ObjectStat(key string) (*ObjectStats, error)
ObjectStat gets stats for the DAG object named by key. It returns the stats of the requested Object or an error.
func (*Shell) Pins ¶ added in v1.2.0
Pins returns a map of the pin hashes to their info (currently just the pin type, one of DirectPin, RecursivePin, or IndirectPin. A map is returned instead of a slice because it is easier to do existence lookup by map key than unordered array searching. The map is likely to be more useful to a client than a flat list.
func (*Shell) PubSubPublish ¶ added in v1.2.0
func (*Shell) PubSubSubscribe ¶ added in v1.2.0
func (s *Shell) PubSubSubscribe(topic string) (*PubSubSubscription, error)
func (*Shell) Resolve ¶
Resolve gets resolves the string provided to an /ipfs/hash. If asked to resolve an empty string, resolve instead resolves the node's own /ipns value.
func (*Shell) SetTimeout ¶
type UnixLsObject ¶
type UnixLsObject struct { Hash string Size uint64 Type string Links []*UnixLsLink }