int

event count

n * CacheEntryEvent

BinaryObject	key
BinaryObject	old value
BinaryObject	value
byte	event type (0 = CREATED, 1 = UPDATED, 2 = REMOVED, 3 = EXPIRED)

Risks & Assumptions

Flow control & backpressure: We assume no special flow control and rely on GridNioServer to handle "slow client, fast server" scenario.
Fault tolerance: Initial implementation does not provide failover in case when server node that holds the query goes down or client connection fails. It is up to specific client implementation to notify user code about the connection loss (for example, by providing special CacheEntryEvent instance that throws an exception from all members).

...

Tickets

Jira

...