resourcepool

Documentation

Index

• Constants
• type BlockManager
  • func (bm *BlockManager) AddBlock(ctx context.Context, b blocks.Block)
  • func (bm *BlockManager) AddBlocks(ctx context.Context, bs []blocks.Block)
• type Instance
  • func NewInstance(p2pinst *p2p.Instance) *Instance
  • func (inst *Instance) NewStream() *Stream
  • func (inst *Instance) Start(ctx context.Context)
  • func (inst *Instance) Stop()
• type Stream
  • func (s *Stream) Append(message []byte)
  • func (s *Stream) Flush()
  • func (s *Stream) GetCids() []cid.Cid
  • func (s *Stream) Reset()

Constants

const DEFAULT_CHUNK_SIZE = 4096

Types

type BlockManager

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

func (*BlockManager) AddBlock

func (bm *BlockManager) AddBlock(ctx context.Context, b blocks.Block)

func (*BlockManager) AddBlocks

func (bm *BlockManager) AddBlocks(ctx context.Context, bs []blocks.Block)

type Instance

type Instance struct {
	Bservice  blockservice.BlockService
	Bstore    blockstore.Blockstore
	Bsnetwork bsnet.BitSwapNetwork
	Bsserver  *bsserver.Server
	Bsclient  *bsclient.Client

	Bmanager *BlockManager
	// contains filtered or unexported fields
}

func NewInstance

func NewInstance(p2pinst *p2p.Instance) *Instance

func (*Instance) NewStream

func (inst *Instance) NewStream() *Stream

func (*Instance) Start

func (inst *Instance) Start(ctx context.Context)

func (*Instance) Stop

func (inst *Instance) Stop()

type Stream

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

Keeps track of Cids in data.

func (*Stream) Append

func (s *Stream) Append(message []byte)

func (*Stream) Flush

func (s *Stream) Flush()

func (*Stream) GetCids

func (s *Stream) GetCids() []cid.Cid

func (*Stream) Reset

func (s *Stream) Reset()