reprovide

Documentation

Overview

此源码被清华学神尹成大魔王专业翻译分析并修改 尹成QQ77025077 尹成微信18510341407 尹成所在QQ群721929980 尹成邮箱 yinc13@mails.tsinghua.edu.cn 尹成毕业于清华大学,微软区块链领域全球最有价值专家 https://mvp.microsoft.com/zh-cn/PublicProfile/4033620

此源码被清华学神尹成大魔王专业翻译分析并修改 尹成QQ77025077 尹成微信18510341407 尹成所在QQ群721929980 尹成邮箱 yinc13@mails.tsinghua.edu.cn 尹成毕业于清华大学,微软区块链领域全球最有价值专家 https://mvp.microsoft.com/zh-cn/PublicProfile/4033620

Index

• type KeyChanFunc
  • func NewBlockstoreProvider(bstore blocks.Blockstore) KeyChanFunc
  • func NewPinnedProvider(pinning pin.Pinner, dag ipld.DAGService, onlyRoots bool) KeyChanFunc
• type Reprovider
  • func NewReprovider(ctx context.Context, rsys routing.ContentRouting, keyProvider KeyChanFunc) *Reprovider
  • func (rp *Reprovider) Reprovide() error
  • func (rp *Reprovider) Run(tick time.Duration)
  • func (rp *Reprovider) Trigger(ctx context.Context) error

Types

type KeyChanFunc

type KeyChanFunc func(context.Context) (<-chan cid.Cid, error)

keychanfunc是传递到内容路由的函数流式CID

func NewBlockstoreProvider

func NewBlockstoreProvider(bstore blocks.Blockstore) KeyChanFunc

NewblockStoreProvider使用bstore.allkeyschan返回密钥提供程序

func NewPinnedProvider

func NewPinnedProvider(pinning pin.Pinner, dag ipld.DAGService, onlyRoots bool) KeyChanFunc

NewPinnedProvider返回提供固定密钥的提供程序

type Reprovider

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

func NewReprovider

func NewReprovider(ctx context.Context, rsys routing.ContentRouting, keyProvider KeyChanFunc) *Reprovider

NewReprovider创建新的Reprovider实例。

func (*Reprovider) Reprovide

func (rp *Reprovider) Reprovide() error

将rp.keyprovider提供的所有密钥重新提供给libp2p内容路由

func (*Reprovider) Run

func (rp *Reprovider) Run(tick time.Duration)

运行重新为键提供“勾号”间隔或在触发时

func (*Reprovider) Trigger

func (rp *Reprovider) Trigger(ctx context.Context) error

触发器在rp.run中启动重新设置进程并等待它