Package com.illumon.iris.db.v2.locations.protocol

Interface TableDataProtocol.ResponseHandler

Enclosing class:

TableDataProtocol

public static interface TableDataProtocol.ResponseHandler

Interface to a handler that processes table data responses.

Method Summary

Modifier and Type	Method	Description
void	handleColumnFileData(TableDataProtocol.Server peer, long requestKey, long startOffset, int length, com.fishlib.io.streams.ByteBufferInputStream dataSource)
void	handleColumnFileSize(TableDataProtocol.Server peer, long requestKey, long columnFileSize)
void	handleColumnLocationExistence(TableDataProtocol.Server peer, long requestKey, boolean exists, boolean littleEndianByteOrder, boolean symbolTableExists)
void	handleRequestCompletion(TableDataProtocol.Server peer, long requestKey)
void	handleRequestRejection(TableDataProtocol.Server peer, long requestKey, TableDataProtocol.RequestRejectionType requestRejectionType, CharSequence rejectText)
void	handleTableLocationAdded(TableDataProtocol.Server peer, long requestKey, TableLocationKey locationKey)
void	handleTableLocationRemoved(TableDataProtocol.Server peer, long requestKey, TableLocationKey locationKey)
void	handleTableLocationUpdate(TableDataProtocol.Server peer, long requestKey, TableLocationState locationState)
void	lostConnection(TableDataProtocol.Server peer)

Method Details

handleRequestRejection

void handleRequestRejection(@NotNull
 TableDataProtocol.Server peer,
 long requestKey,
 @NotNull
 TableDataProtocol.RequestRejectionType requestRejectionType,
 @NotNull
 CharSequence rejectText)

handleRequestCompletion

void handleRequestCompletion(@NotNull
 TableDataProtocol.Server peer,
 long requestKey)

handleTableLocationAdded

void handleTableLocationAdded(@NotNull
 TableDataProtocol.Server peer,
 long requestKey,
 @NotNull
 TableLocationKey locationKey)

handleTableLocationRemoved

void handleTableLocationRemoved(@NotNull
 TableDataProtocol.Server peer,
 long requestKey,
 @NotNull
 TableLocationKey locationKey)

handleTableLocationUpdate

void handleTableLocationUpdate(@NotNull
 TableDataProtocol.Server peer,
 long requestKey,
 @NotNull
 TableLocationState locationState)

handleColumnLocationExistence

void handleColumnLocationExistence(@NotNull
 TableDataProtocol.Server peer,
 long requestKey,
 boolean exists,
 boolean littleEndianByteOrder,
 boolean symbolTableExists)

handleColumnFileSize

void handleColumnFileSize(@NotNull
 TableDataProtocol.Server peer,
 long requestKey,
 long columnFileSize)

handleColumnFileData

void handleColumnFileData(@NotNull
 TableDataProtocol.Server peer,
 long requestKey,
 long startOffset,
 int length,
 @NotNull
 com.fishlib.io.streams.ByteBufferInputStream dataSource)

lostConnection

void lostConnection(@NotNull
 TableDataProtocol.Server peer)