*     System.out.println(indexed.getIndex());
 *     System.out.println(indexed.getElement());
 * }
 * </pre>
 *
 * <pre>
 * import static org.codelibs.core.collection.IndexedIterator.*;
 * import static org.codelibs.core.io.LineIterator.*;
 *
 * BufferedReader reader = ...;
 * for (Indexed&lt;String&gt; indexed : indexed(iterable(reader))) {
 *     System.out.println(indexed.getIndex());

                    final BulkRequestBuilder bulkRequest = client.prepareBulk();
                    for (final SearchHit hit : hits) {
                        bulkRequest.add(client.prepareDelete().setIndex(hit.getIndex()).setId(hit.getId()));
                    }
                    return bulkRequest.execute();
                });
                if (bulkResponse.hasFailures()) {

        SuggestResponse response = new SuggestResponse("test-index", 100, words, 10, items);

        assertNotNull(response);
        assertEquals("test-index", response.getIndex());
        assertEquals(100, response.getTookMs());
        assertEquals(2, response.getNum());
        assertEquals(10, response.getTotal());
        assertEquals(2, response.getWords().size());

        /** Index of the SID in the domain list. */
        public int sid_index;

        @Override
        public void encode(final NdrBuffer _dst) throws NdrException {
            _dst.align(4);
            _dst.enc_ndr_short(this.sid_type);
            _dst.enc_ndr_long(this.rid);
            _dst.enc_ndr_long(this.sid_index);

        }

        @Override

        public int rid;
        /** Index of the SID in the domain list. */
        public int sid_index;

        @Override
        public void encode(final NdrBuffer _dst) throws NdrException {
            _dst.align(4);
            _dst.enc_ndr_short(sid_type);
            _dst.enc_ndr_long(rid);
            _dst.enc_ndr_long(sid_index);

        }

        @Override

        PopularWordsResponse response = new PopularWordsResponse("test-index", 100, words, 10, items);

        assertNotNull(response);
        assertEquals("test-index", response.getIndex());
        assertEquals(100, response.getTookMs());
        assertEquals(2, response.getNum());
        assertEquals(10, response.getTotal());
        assertEquals(2, response.getWords().size());

                    for (final SearchHit searchHit : searchHits) {
                        final UpdateRequestBuilder updateRequest =
                                c.prepareUpdate().setIndex(index).setId(searchHit.getId()).setDoc(SESSION_ID, newSessionId);
                        builder.add(updateRequest);
                    }

                    return builder.execute();
                });

     *
     * @return the element
     */
    public T getElement() {
        return element;
    }

    /**
     * Returns the index.
     *
     * @return the index
     */
    public int getIndex() {
        return index;
    }

var OfflineDisk StorageAPI // zero value is nil

// erasureObjects - Implements ER object layer.
type erasureObjects struct {
	setDriveCount      int
	defaultParityCount int

	setIndex  int
	poolIndex int

	// getDisks returns list of storageAPIs.
	getDisks func() []StorageAPI

	// getLockers returns list of remote and local lockers.
	getLockers func() ([]dsync.NetLocker, string)

        if (logger.isInfoEnabled()) {
            logger.info("Indexing from query logs: count={}, index={}", queryLogs.length, ctx.getIndex());
        }
        try {
            final long start = System.currentTimeMillis();
            Stream<QueryLog> stream = Stream.of(queryLogs);
            if (parallel) {