pool

Nov 30, 2022

Changes in this version

type Pool

+ func (p *Pool) Pull(ctx context.Context, from peer.ID, l ipld.Link) error

+ func (p *Pool) Push(ctx context.Context, from peer.ID, l ipld.Link) error

Oct 21, 2022

Changes in this version

type Option

+ func WithDatastore(ds datastore.Batching) Option

+ func WithLinkSystem(ls *ipld.LinkSystem) Option

type Pool

+ func (p *Pool) Fetch(ctx context.Context, from peer.ID, l ipld.Link) error

+ func (p *Pool) Has(ctx context.Context, l ipld.Link) (bool, error)

+ func (p *Pool) Load(ctx context.Context, l ipld.Link, np ipld.NodePrototype) (ipld.Node, error)

+ func (p *Pool) Store(ctx context.Context, n ipld.Node) (ipld.Link, error)

Sep 23, 2022

Changes in this version

+ const Version0

+ var PubSubPrototypes struct

+ type Announcement struct

+ Addrs []string

+ Type AnnouncementType

+ Version string

+ func (a *Announcement) GetAddrs() ([]multiaddr.Multiaddr, error)

+ func (a *Announcement) MarshalBinary() ([]byte, error)

+ func (a *Announcement) SetAddrs(ma ...multiaddr.Multiaddr)

+ func (a *Announcement) UnmarshalBinary(b []byte) error

+ type AnnouncementType int

+ const IExistAnnouncementType

+ const UnknownAnnouncementType

+ type Option func(*options) error

+ func WithAnnounceInterval(i time.Duration) Option

+ func WithHost(h host.Host) Option

+ func WithPoolName(n string) Option

+ func WithTopicName(n string) Option

+ type Pool struct

+ func New(o ...Option) (*Pool, error)

+ func (p *Pool) Shutdown(ctx context.Context) error

+ func (p *Pool) Start(ctx context.Context) error