dtsync

Documentation

Index

• func EncodeMessage(m Message) []byte
• func NewPublisher(host host.Host, ds datastore.Batching, lsys ipld.LinkSystem, topic string, ...) (*publisher, error)
• func NewPublisherFromExisting(dtManager dt.Manager, host host.Host, topic string, lsys ipld.LinkSystem, ...) (*publisher, error)
• type Message
  • func DecodeMessage(data []byte) (Message, error)
• type Option
  • func Topic(topic *pubsub.Topic) Option
• type Sync
  • func NewSync(host host.Host, ds datastore.Batching, lsys ipld.LinkSystem, ...) (*Sync, error)
  • func NewSyncWithDT(host host.Host, dtManager dt.Manager) (*Sync, error)
  • func (s *Sync) Close() error
  • func (s *Sync) NewSyncer(peerID peer.ID, topicName string) *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 (t *Voucher) MarshalCBOR(w io.Writer) error
  • func (v *Voucher) Type() datatransfer.TypeIdentifier
  • func (t *Voucher) UnmarshalCBOR(r io.Reader) error
• type VoucherResult
  • func (t *VoucherResult) MarshalCBOR(w io.Writer) error
  • func (v *VoucherResult) Type() datatransfer.TypeIdentifier
  • func (t *VoucherResult) UnmarshalCBOR(r io.Reader) error

Functions

func EncodeMessage

func EncodeMessage(m Message) []byte

func NewPublisher

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

NewPublisher creates a new legs publisher

func NewPublisherFromExisting

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

NewPublisherFromExisting instantiates go-legs publishing on an existing data transfer instance

Types

type Message

type Message struct {
	Cid   cid.Cid
	Addrs []multiaddr.Multiaddr
}

func DecodeMessage

func DecodeMessage(data []byte) (Message, error)

type Option

type Option func(*config) error

func Topic

func Topic(topic *pubsub.Topic) Option

Topic provides an existing pubsub topic.

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) (*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) *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 (*Voucher) MarshalCBOR

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

func (*Voucher) Type

func (v *Voucher) Type() datatransfer.TypeIdentifier

Type provides an identifier for the voucher to go-data-transfer

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 (*VoucherResult) MarshalCBOR

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

func (*VoucherResult) Type

func (v *VoucherResult) Type() datatransfer.TypeIdentifier

Type provides an identifier for the voucher result to go-data-transfer

func (*VoucherResult) UnmarshalCBOR

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