dsync

package

Go to main page

Versions in this module

v0

v0.2.2

May 4, 2021

Changes in this version

+ var ErrUnknownProtocolVersion = fmt.Errorf("unknown protocol version")

+ func AddAllFromCARReader(ctx context.Context, bapi coreiface.BlockAPI, r io.Reader, progCh chan cid.Cid) (int, error)

+ func NewManifestCARReader(ctx context.Context, ng ipld.NodeGetter, mfst *dag.Manifest, ...) (io.Reader, error)

type Config

+ OpenBlockStreamCheck Hook

+ type DagStreamable interface

+ OpenBlockStream func(ctx context.Context, info *dag.Info, meta map[string]string) (io.ReadCloser, error)

+ ReceiveBlocks func(ctx context.Context, sessionID string, r io.Reader) error

type DagSyncable

+ ProtocolVersion func() (protocol.ID, error)

type Dsync

+ func (ds *Dsync) OpenBlockStream(ctx context.Context, info *dag.Info, meta map[string]string) (io.ReadCloser, error)

+ func (ds *Dsync) ProtocolVersion() (protocol.ID, error)

+ func (ds *Dsync) ReceiveBlocks(ctx context.Context, sid string, r io.Reader) error

type HTTPClient

+ BlockAPI coreiface.BlockAPI

+ NodeGetter format.NodeGetter

+ func (rem *HTTPClient) OpenBlockStream(ctx context.Context, info *dag.Info, meta map[string]string) (io.ReadCloser, error)

+ func (rem *HTTPClient) ProtocolVersion() (protocol.ID, error)

+ func (rem *HTTPClient) ReceiveBlocks(ctx context.Context, sid string, r io.Reader) error

v0.2.1

Jun 29, 2020

v0.2.0

Sep 4, 2019

Changes in this version

+ const DsyncProtocolID

+ const DsyncServiceTag

+ var DefaultDagFinalCheck = func(context.Context, dag.Info, map[string]string) error

+ var DefaultDagPrecheck = func(context.Context, dag.Info, map[string]string) error

+ var ErrRemoveNotSupported = fmt.Errorf("remove is not supported")

+ func HTTPRemoteHandler(ds *Dsync) http.HandlerFunc

+ func NewLocalNodeGetter(api coreiface.CoreAPI) (ipld.NodeGetter, error)

+ func OptLibp2pHost(host host.Host) func(cfg *Config)

+ type Config struct

+ AllowRemoves bool

+ GetDagInfoCheck Hook

+ HTTPRemoteAddress string

+ InfoStore dag.InfoStore

+ Libp2pHost host.Host

+ PinAPI coreiface.PinAPI

+ PushComplete Hook

+ PushFinalCheck Hook

+ PushPreCheck Hook

+ RemoveCheck Hook

+ RequireAllBlocks bool

+ func (cfg *Config) Validate() error

+ type DagSyncable interface

+ GetBlock func(ctx context.Context, hash string) (rawdata []byte, err error)

+ GetDagInfo func(ctx context.Context, cidStr string, meta map[string]string) (info *dag.Info, err error)

+ NewReceiveSession func(info *dag.Info, pinOnComplete bool, meta map[string]string) (sid string, diff *dag.Manifest, err error)

+ ReceiveBlock func(sid, hash string, data []byte) ReceiveResponse

+ RemoveCID func(ctx context.Context, cidStr string, meta map[string]string) (err error)

+ type Dsync struct

+ func New(localNodes ipld.NodeGetter, blockStore coreiface.BlockAPI, ...) (*Dsync, error)

+ func NewTestDsync() *Dsync

+ func (ds *Dsync) GetBlock(ctx context.Context, hash string) ([]byte, error)

+ func (ds *Dsync) GetDagInfo(ctx context.Context, hash string, meta map[string]string) (info *dag.Info, err error)

+ func (ds *Dsync) NewPull(cidStr, remoteAddr string, meta map[string]string) (*Pull, error)

+ func (ds *Dsync) NewPush(cidStr, remoteAddr string, pinOnComplete bool) (*Push, error)

+ func (ds *Dsync) NewPushInfo(info *dag.Info, remoteAddr string, pinOnComplete bool) (*Push, error)

+ func (ds *Dsync) NewReceiveSession(info *dag.Info, pinOnComplete bool, meta map[string]string) (sid string, diff *dag.Manifest, err error)

+ func (ds *Dsync) ReceiveBlock(sid, hash string, data []byte) ReceiveResponse

+ func (ds *Dsync) RemoveCID(ctx context.Context, cidStr string, meta map[string]string) error

+ func (ds *Dsync) StartRemote(ctx context.Context) error

+ type HTTPClient struct

+ URL string

+ func (rem *HTTPClient) GetBlock(ctx context.Context, id string) (data []byte, err error)

+ func (rem *HTTPClient) GetDagInfo(ctx context.Context, id string, meta map[string]string) (info *dag.Info, err error)

+ func (rem *HTTPClient) NewReceiveSession(info *dag.Info, pinOnComplete bool, meta map[string]string) (sid string, diff *dag.Manifest, err error)

+ func (rem *HTTPClient) ReceiveBlock(sid, hash string, data []byte) ReceiveResponse

+ func (rem *HTTPClient) RemoveCID(ctx context.Context, id string, meta map[string]string) (err error)

+ type Hook func(ctx context.Context, info dag.Info, meta map[string]string) error

+ type Pull struct

+ func NewPull(cidStr string, lng ipld.NodeGetter, bapi coreiface.BlockAPI, rem DagSyncable, ...) (pull *Pull, err error)

+ func NewPullWithInfo(info *dag.Info, lng ipld.NodeGetter, bapi coreiface.BlockAPI, rem DagSyncable, ...) (pull *Pull, err error)

+ func (f *Pull) Do(ctx context.Context) (err error)

+ func (f *Pull) Updates() <-chan dag.Completion

+ type Push struct

+ func NewPush(lng ipld.NodeGetter, info *dag.Info, remote DagSyncable, pinOnComplete bool) (*Push, error)

+ func (snd *Push) Do(ctx context.Context) (err error)

+ func (snd *Push) SetMeta(meta map[string]string)

+ func (snd *Push) Updates() <-chan dag.Completion

+ type ReceiveResponse struct

+ Err error

+ Hash string

+ Status ReceiveResponseStatus

+ type ReceiveResponseStatus int

+ func (s ReceiveResponseStatus) String() string

v0.1.0

Jun 3, 2019

Changes in this version

+ type Fetch struct

+ func NewFetch(ctx context.Context, id string, lng ipld.NodeGetter, bapi coreiface.BlockAPI, ...) (fetch *Fetch, err error)

+ func NewFetchWithManifest(ctx context.Context, mfst *dag.Manifest, lng ipld.NodeGetter, ...) (fetch *Fetch, err error)

+ func (f *Fetch) Do() (err error)

+ type FetchRes struct

+ Error error

+ Hash string

+ Raw []byte

+ type HTTPRemote struct

+ URL string

+ func (rem *HTTPRemote) GetBlock(ctx context.Context, id string) (data []byte, err error)

+ func (rem *HTTPRemote) PutBlock(sid, hash string, data []byte) Response

+ func (rem *HTTPRemote) ReqManifest(ctx context.Context, id string) (mfst *dag.Manifest, err error)

+ func (rem *HTTPRemote) ReqSend(mfst *dag.Manifest) (sid string, diff *dag.Manifest, err error)

+ type Receive struct

+ func NewReceive(ctx context.Context, lng ipld.NodeGetter, bapi coreiface.BlockAPI, ...) (*Receive, error)

+ func (r *Receive) Complete() bool

+ func (r *Receive) ReceiveBlock(hash string, data io.Reader) Response

+ type Receivers struct

+ TTLDur time.Duration

+ func NewReceivers(ctx context.Context, lng ipld.NodeGetter, bapi coreiface.BlockAPI) *Receivers

+ func NewTestReceivers() *Receivers

+ func (rs *Receivers) GetBlock(ctx context.Context, hash string) ([]byte, error)

+ func (rs *Receivers) HTTPHandler() http.HandlerFunc

+ func (rs *Receivers) PutBlock(sid, hash string, data []byte) Response

+ func (rs *Receivers) ReqManifest(ctx context.Context, hash string) (mfst *dag.Manifest, err error)

+ func (rs *Receivers) ReqSend(mfst *dag.Manifest) (sid string, diff *dag.Manifest, err error)

+ func (rs *Receivers) SetInfoStore(is dag.InfoStore)

+ type Remote interface

+ GetBlock func(ctx context.Context, hash string) (rawdata []byte, err error)

+ PutBlock func(sid, hash string, data []byte) Response

+ ReqManifest func(ctx context.Context, path string) (mfst *dag.Manifest, err error)

+ ReqSend func(mfst *dag.Manifest) (sid string, diff *dag.Manifest, err error)

+ type Response struct

+ Err error

+ Hash string

+ Status ResponseStatus

+ type ResponseStatus int

+ const StatusErrored

+ const StatusOk

+ const StatusRetry

+ type Send struct

+ func NewSend(ctx context.Context, lng ipld.NodeGetter, mfst *dag.Manifest, remote Remote) (*Send, error)

+ func (snd *Send) Completion() <-chan dag.Completion

+ func (snd *Send) Do() (err error)

+ func (snd *Send) PerformSend(sid string, mfst, diff *dag.Manifest) error

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