cservmgr

type Opts struct {
	// The datastore path of the piece serving manager.
	Path string
}

type PieceServingManager interface {
	// Serve is used to serve a piece.
	//
	// @input - context, piece id, currency id, price-per-byte.
	//
	// @output - error.
	Serve(ctx context.Context, id cid.Cid, currencyID byte, ppb *big.Int) error

	// Stop is used to stop serving a piece.
	//
	// @input - context, piece id, currency id.
	//
	// @output - error.
	Stop(ctx context.Context, id cid.Cid, currencyID byte) error

	// Inspect is used to inspect a piece serving state.
	//
	// @input - context, piece id, currency id.
	//
	// @output - if served, price-per-byte, error.
	Inspect(ctx context.Context, id cid.Cid, currencyID byte) (bool, *big.Int, error)

	// ListPieceIDs lists all pieces.
	//
	// @input - context.
	//
	// @output - piece id chan out, error chan out.
	ListPieceIDs(ctx context.Context) (<-chan cid.Cid, <-chan error)

	// ListCurrencyIDs lists all currencies.
	//
	// @input - context, piece id.
	//
	// @output - currency chan out, error chan out.
	ListCurrencyIDs(ctx context.Context, id cid.Cid) (<-chan byte, <-chan error)

	// RegisterPublishHook adds a hook function to call when a new serving presents.
	//
	// @input - hook function.
	RegisterPublishFunc(hook func(cid.Cid))

	// DeregisterPublishHook deregister the hook function.
	DeregisterPublishHook()
}

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