Class Codec23

    • Constructor Detail

      • Codec23

        public Codec23()
    • Method Detail

      • writeHeader

        public HeaderParams writeHeader​(io.netty.buffer.ByteBuf buf,
                                        HeaderParams params)
        Description copied from interface: Codec
        Writes a request header with the given parameters to the transport and returns an updated header parameters.
        Specified by:
        writeHeader in interface Codec
        Overrides:
        writeHeader in class Codec22
      • keyIterator

        public <K> org.infinispan.commons.util.CloseableIterator<K> keyIterator​(RemoteCache<K,​?> remoteCache,
                                                                                OperationsFactory operationsFactory,
                                                                                int batchSize)
        Description copied from interface: Codec
        Creates a key iterator with the given batch size if applicable. This iterator does not support removal.
        Specified by:
        keyIterator in interface Codec
        Overrides:
        keyIterator in class Codec20
        Returns:
      • entryIterator

        public <K,​V> org.infinispan.commons.util.CloseableIterator<Map.Entry<K,​V>> entryIterator​(RemoteCache<K,​V> remoteCache,
                                                                                                             int batchSize)
        Description copied from interface: Codec
        Creates an entry iterator with the given batch size if applicable. This iterator does not support removal.
        Returns:
      • castEntryIterator

        protected <K,​V> org.infinispan.commons.util.CloseableIterator<Map.Entry<K,​V>> castEntryIterator​(org.infinispan.commons.util.CloseableIterator iterator)
      • writeIteratorStartOperation

        public void writeIteratorStartOperation​(io.netty.buffer.ByteBuf buf,
                                                Set<Integer> segments,
                                                String filterConverterFactory,
                                                int batchSize,
                                                boolean metadata,
                                                byte[][] filterParameters)