core/org.gnit.lucenekmp.index/DocumentsWriterFlushQueue

DocumentsWriterFlushQueue

class DocumentsWriterFlushQueue

Constructors

DocumentsWriterFlushQueue

constructor()

Types

class FlushTicket(frozenUpdates: FrozenBufferedUpdates?, val hasSegment: Boolean)

Functions

fun addSegment(ticket: DocumentsWriterFlushQueue.FlushTicket, segment: DocumentsWriterPerThread.FlushedSegment)

fun addTicket(ticketSupplier: () -> DocumentsWriterFlushQueue.FlushTicket?): DocumentsWriterFlushQueue.FlushTicket?

fun forcePurge(consumer: IOConsumer<DocumentsWriterFlushQueue.FlushTicket>)

fun getTicketCount(): Int

fun hasTickets(): Boolean

markTicketFailed

fun markTicketFailed(ticket: DocumentsWriterFlushQueue.FlushTicket)

fun tryPurge(consumer: IOConsumer<DocumentsWriterFlushQueue.FlushTicket>)