legs

Aug 10, 2022

Changes in this version

type Option

+ func FilterIPs(enable bool) Option

Jul 20, 2022

Changes in this version

type Option

+ func IdleHandlerTTL(ttl time.Duration) Option

type Subscriber

+ func (s *Subscriber) RemoveHandler(peerID peer.ID) bool

Jun 21, 2022

Changes in this version

type Option

+ func ResendAnnounce(enable bool) Option

May 23, 2022

Changes in this version

type Option

+ func SegmentDepthLimit(depth int64) Option

+ type SegmentBlockHookFunc func(peer.ID, cid.Cid, SegmentSyncActions)

+ type SegmentSyncActions interface

+ FailSync func(error)

+ SetNextSyncCid func(cid.Cid)

type SyncOption

+ func ScopedSegmentDepthLimit(depth int64) SyncOption

Apr 21, 2022

Changes in this version

type Subscriber

+ func (s *Subscriber) Announce(ctx context.Context, nextCid cid.Cid, peerID peer.ID, ...) error

Apr 14, 2022

Changes in this version

type Subscriber

+ func (s *Subscriber) HttpPeerStore() peerstore.Peerstore

Mar 31, 2022

Changes in this version

type Option

+ func RateLimiter(limiterFor RateLimiterFor) Option

+ type RateLimiterFor func(publisher peer.ID) *rate.Limiter

type SyncOption

+ func ScopedRateLimiter(l *rate.Limiter) SyncOption

Mar 10, 2022

Changes in this version

+ type DefaultLatestSyncHandler struct

+ func (h *DefaultLatestSyncHandler) GetLatestSync(p peer.ID) (cid.Cid, bool)

+ func (h *DefaultLatestSyncHandler) SetLatestSync(p peer.ID, c cid.Cid)

+ type LatestSyncHandler interface

+ GetLatestSync func(peer peer.ID) (cid.Cid, bool)

+ SetLatestSync func(peer peer.ID, cid cid.Cid)

type Option

+ func UseLatestSyncHandler(h LatestSyncHandler) Option

Feb 23, 2022

Changes in this version

+ type SyncOption func(*syncCfg)

+ func AlwaysUpdateLatest() SyncOption

+ func CheckAlreadySynced() SyncOption

+ func ScopedBlockHook(hook BlockHookFunc) SyncOption

Feb 22, 2022

Changes in this version

type BlockHookFunc

+ func WrapBlockHookWithSyncedCidTracker(cidsSeenSoFar *[]cid.Cid, blockHook BlockHookFunc) BlockHookFunc

type Subscriber

+ func (s *Subscriber) SyncWithHook(ctx context.Context, peerID peer.ID, nextCid cid.Cid, sel ipld.Node, ...) (cid.Cid, error)

type SyncFinished

+ SyncedCids []cid.Cid

Jan 28, 2022

Changes in this version

type Publisher

+ SetRoot func(context.Context, cid.Cid) error

Jan 26, 2022

Changes in this version

type Option

+ func SyncRecursionLimit(limit selector.RecursionLimit) Option

Dec 22, 2021

Changes in this version

+ type AllowPeerFunc func(peer.ID) (bool, error)

+ type BlockHookFunc func(peer.ID, cid.Cid)

+ type Option func(*config) error

+ func AddrTTL(addrTTL time.Duration) Option

+ func AllowPeer(allowPeer AllowPeerFunc) Option

+ func BlockHook(blockHook BlockHookFunc) Option

+ func DtManager(dtManager dt.Manager) Option

+ func HttpClient(client *http.Client) Option

+ func Topic(topic *pubsub.Topic) Option

+ type Publisher interface

+ Close func() error

+ UpdateRoot func(context.Context, cid.Cid) error

+ UpdateRootWithAddrs func(context.Context, cid.Cid, []ma.Multiaddr) error

+ type Subscriber struct

+ func (s *Subscriber) Close() error

+ func (s *Subscriber) GetLatestSync(peerID peer.ID) ipld.Link

+ func (s *Subscriber) OnSyncFinished() (<-chan SyncFinished, context.CancelFunc)

+ func (s *Subscriber) SetAllowPeer(allowPeer AllowPeerFunc)

+ func (s *Subscriber) SetLatestSync(peerID peer.ID, latestSync cid.Cid) error

+ func (s *Subscriber) Sync(ctx context.Context, peerID peer.ID, c cid.Cid, sel ipld.Node, ...) (cid.Cid, error)

+ type SyncFinished struct

+ Cid cid.Cid

+ PeerID peer.ID

+ type Syncer interface

+ GetHead func(context.Context) (cid.Cid, error)

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

Dec 16, 2021

Changes in this version

+ func ExploreRecursiveWithStop(limit selector.RecursionLimit, sequence selectorbuilder.SelectorSpec, ...) ipld.Node

+ func ExploreRecursiveWithStopNode(limit selector.RecursionLimit, sequence ipld.Node, stopLnk ipld.Link) ipld.Node

+ func LegSelector(stopLnk ipld.Link) ipld.Node

+ type LegMultiSubscriber interface

+ Close func(ctx context.Context) error

+ DataTransfer func() dt.Manager

+ GraphSync func() graphsync.GraphExchange

+ NewSubscriber func(PolicyHandler) (LegSubscriber, error)

+ NewSubscriberPartiallySynced func(PolicyHandler, cid.Cid) (LegSubscriber, error)

+ func NewMultiSubscriber(ctx context.Context, host host.Host, ds datastore.Batching, ...) (LegMultiSubscriber, error)

+ type LegPublisher interface

+ Close func() error

+ UpdateRoot func(context.Context, cid.Cid) error

+ UpdateRootWithAddrs func(context.Context, cid.Cid, []ma.Multiaddr) error

+ func NewPublisher(ctx context.Context, host host.Host, ds datastore.Batching, ...) (LegPublisher, error)

+ func NewPublisherFromExisting(ctx context.Context, dt dt.Manager, host host.Host, topic string, ...) (LegPublisher, error)

+ type LegSubscriber interface

+ Close func() error

+ OnChange func() (chan cid.Cid, context.CancelFunc)

+ SetLatestSync func(c cid.Cid) error

+ SetPolicyHandler func(PolicyHandler) error

+ Sync func(ctx context.Context, p peer.ID, c cid.Cid, selector ipld.Node) (<-chan cid.Cid, context.CancelFunc, error)

+ func NewSubscriber(ctx context.Context, host host.Host, ds datastore.Batching, ...) (LegSubscriber, error)

+ func NewSubscriberPartiallySynced(ctx context.Context, host host.Host, ds datastore.Batching, ...) (LegSubscriber, error)

+ type PolicyHandler func(*pubsub.Message) (bool, error)

+ func FilterPeerPolicy(p peer.ID) PolicyHandler

+ type Voucher struct

+ Head *cid.Cid

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

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

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

+ type VoucherResult struct

+ Code uint64

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

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

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