dtsync

Documentation

Index

• Constants
• Variables
• func NewPublisher(host host.Host, ds datastore.Batching, lsys ipld.LinkSystem, topicName string, ...) (*publisher, error)
• func NewPublisherFromExisting(dtManager dt.Manager, host host.Host, topicName string, lsys ipld.LinkSystem, ...) (*publisher, error)
• type Option
  • func WithAllowPeer(allowPeer func(peer.ID) bool) Option
  • func WithAnnounceSenders(senders ...announce.Sender) Option
  • func WithExtraData(data []byte) Option
• type Sync
  • func NewSync(host host.Host, ds datastore.Batching, lsys ipld.LinkSystem, ...) (*Sync, error)
  • func NewSyncWithDT(host host.Host, dtManager dt.Manager, gs graphsync.GraphExchange, ...) (*Sync, error)
  • func (s *Sync) Close() error
  • func (s *Sync) NewSyncer(peerID peer.ID, topicName string, rateLimiter *rate.Limiter) *Syncer
• type Syncer
  • func (s *Syncer) GetHead(ctx context.Context) (cid.Cid, error)
  • func (s *Syncer) Sync(ctx context.Context, nextCid cid.Cid, sel ipld.Node) error
• type Voucher
  • func VoucherFromNode(node datamodel.Node) (*Voucher, error)
  • func (v *Voucher) AsVoucher() datatransfer.TypedVoucher
  • func (t *Voucher) MarshalCBOR(w io.Writer) error
  • func (t *Voucher) UnmarshalCBOR(r io.Reader) error
• type VoucherResult
  • func VoucherResultFromNode(node datamodel.Node) (*VoucherResult, error)
  • func (vr *VoucherResult) AsVoucher() datatransfer.TypedVoucher
  • func (t *VoucherResult) MarshalCBOR(w io.Writer) error
  • func (t *VoucherResult) UnmarshalCBOR(r io.Reader) error

Constants

const LegsVoucherResultType = datatransfer.TypeIdentifier("LegsVoucherResult")

const LegsVoucherType = datatransfer.TypeIdentifier("LegsVoucher")

Variables

var BindnodeRegistry = bindnoderegistry.NewRegistry()

Functions

func NewPublisher

func NewPublisher(host host.Host, ds datastore.Batching, lsys ipld.LinkSystem, topicName string, options ...Option) (*publisher, error)

NewPublisher creates a new dagsync publisher.

func NewPublisherFromExisting

func NewPublisherFromExisting(dtManager dt.Manager, host host.Host, topicName string, lsys ipld.LinkSystem, options ...Option) (*publisher, error)

NewPublisherFromExisting instantiates publishing on an existing data transfer instance.

Types

type Option

type Option func(*config) error

Option is a function that sets a value in a config.

func WithAllowPeer

func WithAllowPeer(allowPeer func(peer.ID) bool) Option

WithAllowPeer sets the function that determines whether to allow or reject graphsync sessions from a peer.

func WithAnnounceSenders

func WithAnnounceSenders(senders ...announce.Sender) Option

WithAnnounceSenders sets announce.Senders to use for sending announcements.

func WithExtraData

func WithExtraData(data []byte) Option

WithExtraData sets the extra data to include in the pubsub message.

type Sync

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

Sync provides sync functionality for use with all datatransfer syncs.

func NewSync

func NewSync(host host.Host, ds datastore.Batching, lsys ipld.LinkSystem, blockHook func(peer.ID, cid.Cid)) (*Sync, error)

NewSync creates a new Sync with its own datatransfer.Manager.

func NewSyncWithDT

func NewSyncWithDT(host host.Host, dtManager dt.Manager, gs graphsync.GraphExchange, ls *ipld.LinkSystem, blockHook func(peer.ID, cid.Cid)) (*Sync, error)

NewSyncWithDT creates a new Sync with a datatransfer.Manager provided by the caller.

func (*Sync) Close

func (s *Sync) Close() error

Close unregisters datatransfer event notification. If this Sync owns the datatransfer.Manager then the Manager is stopped.

func (*Sync) NewSyncer

func (s *Sync) NewSyncer(peerID peer.ID, topicName string, rateLimiter *rate.Limiter) *Syncer

NewSyncer creates a new Syncer to use for a single sync operation against a peer.

type Syncer

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

Syncer handles a single sync with a provider.

func (*Syncer) GetHead

func (s *Syncer) GetHead(ctx context.Context) (cid.Cid, error)

GetHead queries a provider for the latest CID.

func (*Syncer) Sync

func (s *Syncer) Sync(ctx context.Context, nextCid cid.Cid, sel ipld.Node) error

Sync opens a datatransfer data channel and uses the selector to pull data from the provider.

type Voucher

type Voucher struct {
	Head *cid.Cid
}

A Voucher is used to communicate a new DAG head

func VoucherFromNode

func VoucherFromNode(node datamodel.Node) (*Voucher, error)

reads a voucher from an ipld node

func (*Voucher) AsVoucher

func (v *Voucher) AsVoucher() datatransfer.TypedVoucher

func (*Voucher) MarshalCBOR

func (t *Voucher) MarshalCBOR(w io.Writer) error

func (*Voucher) UnmarshalCBOR

func (t *Voucher) UnmarshalCBOR(r io.Reader) error

type VoucherResult

type VoucherResult struct {
	Code uint64
}

A VoucherResult responds to a voucher

func VoucherResultFromNode

func VoucherResultFromNode(node datamodel.Node) (*VoucherResult, error)

reads a voucher from an ipld node

func (*VoucherResult) AsVoucher

func (vr *VoucherResult) AsVoucher() datatransfer.TypedVoucher

func (*VoucherResult) MarshalCBOR

func (t *VoucherResult) MarshalCBOR(w io.Writer) error

func (*VoucherResult) UnmarshalCBOR

func (t *VoucherResult) UnmarshalCBOR(r io.Reader) error