piecer

Documentation

Index

• type Piecer
  • func New(postgresURI string, ipfsEndpoints []multiaddr.Multiaddr, mb mbroker.MsgBroker, ...) (*Piecer, error)
  • func (p *Piecer) Close() error
  • func (p *Piecer) ReadyToPrepare(ctx context.Context, sdID broker.BatchID, dataCid cid.Cid) error

Types

type Piecer

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

Piecer provides a data-preparation pipeline for Batchs.

func New

func New(
	postgresURI string,
	ipfsEndpoints []multiaddr.Multiaddr,
	mb mbroker.MsgBroker,
	daemonFrequency time.Duration,
	retryDelay time.Duration,
	padToSize uint64) (*Piecer, error)

New returns a new Piecer.

func (*Piecer) Close

func (p *Piecer) Close() error

Close closes the piecer.

func (*Piecer) ReadyToPrepare

func (p *Piecer) ReadyToPrepare(ctx context.Context, sdID broker.BatchID, dataCid cid.Cid) error

ReadyToPrepare signals the Piecer that a new batch is ready to be prepared.