reprovide

Documentation

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中启动重新设置进程并等待它