| Package | Description |
|---|---|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.direct | |
| org.apache.ignite.internal.direct.stream.v1 | |
| org.apache.ignite.internal.direct.stream.v2 | |
| org.apache.ignite.internal.direct.stream.v3 | |
| org.apache.ignite.internal.managers.communication |
TODO.
|
| org.apache.ignite.internal.util.nio |
NIO server interfaces and common utility classes for NIO.
|
| org.apache.ignite.plugin.extensions.communication |
Contains extendable components for communication.
|
| org.apache.ignite.spi |
Contains common classes and interfaces for SPI implementations.
|
| org.apache.ignite.spi.communication.tcp.internal.shmem |
| Modifier and Type | Method and Description |
|---|---|
@Nullable MessageFactory |
IgniteComponentType.messageFactory()
Creates message factory for the component.
|
| Constructor and Description |
|---|
DirectMessageReader(MessageFactory msgFactory,
byte protoVer) |
| Constructor and Description |
|---|
DirectByteBufferStreamImplV1(MessageFactory msgFactory) |
| Constructor and Description |
|---|
DirectByteBufferStreamImplV2(MessageFactory msgFactory) |
| Constructor and Description |
|---|
DirectByteBufferStreamImplV3(MessageFactory msgFactory) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridIoMessageFactory
Message factory implementation.
|
class |
IgniteMessageFactoryImpl
Message factory implementation which is responsible for instantiation of all communication messages.
|
| Modifier and Type | Field and Description |
|---|---|
static MessageFactory[] |
GridIoManager.EMPTY
Empty array of message factories.
|
| Modifier and Type | Method and Description |
|---|---|
MessageFactory |
GridIoManager.messageFactory() |
| Constructor and Description |
|---|
IgniteMessageFactoryImpl(MessageFactory[] factories)
Contructor.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable MessageFactory |
GridNioMessageReader.messageFactory() |
| Modifier and Type | Method and Description |
|---|---|
MessageReader |
GridNioMessageReaderFactory.reader(GridNioSession ses,
MessageFactory msgFactory)
Creates new reader.
|
| Constructor and Description |
|---|
GridDirectParser(IgniteLogger log,
MessageFactory msgFactory,
GridNioMessageReaderFactory readerFactory) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
IgniteMessageFactory
Message factory for all communication messages registered using
IgniteMessageFactory.register(short, Supplier) method call. |
interface |
MessageFactoryProvider
Provider of communication message factories.
|
| Modifier and Type | Method and Description |
|---|---|
MessageReader |
MessageFormatter.reader(UUID rmtNodeId,
MessageFactory msgFactory)
Creates new message reader instance.
|
| Modifier and Type | Method and Description |
|---|---|
MessageFactory |
IgniteSpiContext.messageFactory()
Gets message factory.
|
| Constructor and Description |
|---|
ShmemAcceptWorker(String igniteInstanceName,
GridNioServerListener<Message> srvLsnr,
IpcSharedMemoryServerEndpoint srv,
TcpCommunicationMetricsListener metricsLsnr,
IgniteLogger log,
MessageFactory msgFactory,
GridNioMessageWriterFactory writerFactory,
GridNioMessageReaderFactory readerFactory,
Tracing tracing) |
ShmemWorker(String igniteInstanceName,
IgniteLogger log,
Tracing tracing,
IpcEndpoint endpoint,
GridNioServerListener<Message> srvLsnr,
TcpCommunicationMetricsListener metricsLsnr,
GridNioMessageReaderFactory readerFactory,
GridNioMessageWriterFactory writerFactory,
MessageFactory msgFactory) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.0 Release Date : September 11 2021