|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
ILnkServerEndpoint.acceptCancel(int)
ILnkServerEndpointCore.acceptCancel(int)
ILnkServerEndpointCore.acceptCancel(int)
ILnkServerEndpointCore.acceptCancel(int)
ILnkServerEndpoint.acceptPost(com.neeve.emx.IEmxDispatcher, com.neeve.link.ILnkEventHandler, int, int)
ILnkServerEndpointCore.acceptPost(com.neeve.emx.IEmxDispatcher, com.neeve.link.ILnkEventHandlerCore, int)
ILnkServerEndpointCore.acceptPost(com.neeve.emx.IEmxDispatcher, com.neeve.link.ILnkEventHandlerCore, int)
ILnkServerEndpointCore.acceptPost(com.neeve.emx.IEmxDispatcher, com.neeve.link.ILnkEventHandlerCore, int)
IStoreObject.acquire()
MessageMetadata
preventing it from being
returned to the underlying pool.
MessageView.acquire()
QueryRepository
from being updated.
QueryEngine
with the given alias.
AepStuckAlertEvent
to
be emitted.IStoBufferManager.allocate(int)
IStoBufferManager.allocate(int)
AppStat
containers.IStoreBinding
as a IStoreQueryRepository
.
QueryResultSet
object,
just before the first row.
ClientConnectionPoolEvents.EVENT_CONGESTION
event.ClientConnectionPoolEvents.EVENT_FAILURE
event.ClientEvents.EVENT_CONGESTION
event.ClientEvents.EVENT_FAILURE
event.ILnkClientEndpoint.close()
ILnkClientEndpointCore.close()
ILnkPeerEndpoint.close(short)
ILnkServerEndpoint.close()
ILnkClientEndpointCore.close()
ILnkServerEndpointCore.close()
ILnkClientEndpointCore.close()
ILnkServerEndpointCore.close()
ILnkClientEndpointCore.close()
ILnkServerEndpointCore.close()
QueryEngine
.
QueryIndexer
.
IStorePersister.close()
and IRogMessageLogger.open()
RogLogReader
to release
the resources it holds.
Handler.close()
This method closes the downstream handler.
Handler.close()
Handler.close()
QueryIndexer.commit(long)
.
RogLog
s.
ILnkClientEndpoint.connectCancel(int)
ILnkClientEndpointCore.connectCancel(int)
ILnkClientEndpointCore.connectCancel(int)
ILnkClientEndpointCore.connectCancel(int)
ILnkClientEndpointCore.connectCancel(int)
ILnkClientEndpoint.connectPost(com.neeve.emx.IEmxDispatcher, com.neeve.link.ILnkEventHandler, int, int)
ILnkClientEndpointCore.connectPost(com.neeve.emx.IEmxDispatcher, com.neeve.link.ILnkEventHandlerCore, int)
ILnkClientEndpointCore.connectPost(com.neeve.emx.IEmxDispatcher, com.neeve.link.ILnkEventHandlerCore, int)
ILnkClientEndpointCore.connectPost(com.neeve.emx.IEmxDispatcher, com.neeve.link.ILnkEventHandlerCore, int)
ILnkClientEndpointCore.connectPost(com.neeve.emx.IEmxDispatcher, com.neeve.link.ILnkEventHandlerCore, int)
IStoreObjectFactory.create(short, com.eaio.uuid.UUID, com.neeve.ods.IStoreObject.EncodingType, com.neeve.pkt.PktPacket)
IStoreObjectFactory.create(short, com.eaio.uuid.UUID, com.neeve.ods.IStoreObject.EncodingType, com.neeve.pkt.PktPacket)
MessageViewFactory.create(short)
RogLog
's files.
QueryEngine
's XPQL query syntax and creates an
index for it.
QueryEngine
's repositories.
QueryEngine
's repositories.
QueryIndexer
.
QueryRepository
.
createPacket(context, null)
Query
that can be executed against this QueryEngine
.
Query
corresponding to the provided SELECT statement.
RogLogQueryEngine
for querying a log.
MessageChannel.RawKeyResolutionTable
.
PktSerializable.deserialize(com.neeve.pkt.PktSerializable.DeserializeContext, int, com.neeve.trace.Tracer)
PktSerializable.deserialize(com.neeve.pkt.PktSerializable.DeserializeContext, int, com.neeve.trace.Tracer)
.
PktSerializable.deserialize(com.neeve.pkt.PktSerializable.DeserializeContext, int, com.neeve.trace.Tracer)
.
MessageView.deserializeFromByteArray(byte[])
MessageView.deserializeFromByteBuffer(java.nio.ByteBuffer)
MessageView.deserializeFromPacket(com.neeve.pkt.PktPacket)
DiscoveryCacheEvents.EVENT_ENTITY_ADD
event type.DiscoveryCacheEvents.EVENT_ENTITY_REMOVE
event type.IStoreObject.dispose()
This is the default implementation of the dispose method.
RogLog.Entry
will no longer be used to indicate that
it's backing objects can be returned to their pools
MessageMetadata
MessageView.dispose()
This is the default implementation of the dispose method.
MessagingProviderBase.doCreateBinding(java.lang.String, com.neeve.sma.MessageBusDescriptor, com.neeve.event.IEventHandler)
PktBody.doGetSerializedLength()
This method returns the fixed length of the body contents.
PktBody.doGetSerializedLength()
This method returns the fixed length of the body contents.
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
PktBody.doGetSerializedLength()
QueryRepository
.
QueryEngine
's QueryRepository
s.
QueryRepository
.
QueryRepository
.
IStoreObject
object or its metadata in json format.
StringBuilder
ILnkPeerEndpoint.enque(short, com.neeve.pkt.PktPacket, com.neeve.link.ILnkPeerEndpoint.FlushContext, int)
LoopbackBus.Agent.equals(java.lang.Object)
QueryResult
.
IStoreQueryEngine
.
QueryEngine
.
Query
against this QueryEngine
.
RogLogQueryEngine
.
ILnkPeerEndpoint.fail(java.lang.Exception)
QueryResultSet
to the first
result.
EmxActionExecutor.invoke(com.neeve.emx.IEmxDispatcher, com.neeve.emx.IEmxAction, E, int)
should not wait for the action to complete before returning.
ILnkPeerEndpoint.flush(short, com.neeve.link.ILnkPeerEndpoint.FlushContext)
IRogMessageLogger.flush(boolean)
Handler.flush()
This method flushes the downstream handler.
Handler.flush()
Handler.flush()
QueryRepository
as returned by
QueryRepository.getName()
or by an alias with which it was registered
when added to the QueryEngine.addRepository(QueryRepository, String)
IStoreObject.EncodingType
columnName
as an int.
columnIndex
as an array.
ILnkPeerEndpoint.getAttachment()
columnName
as an BigDecimal
.
columnIndex
as a BigDecimal
.
columnName
as an BigInteger
.
columnIndex
as a BigInteger
.
columnName
as an boolean.
columnIndex
as a boolean.
IAepBusManagerStats
without producing garbage.
columnName
as a byte.
columnIndex
as a byte.
RogLogQueryEngine.RogLogField
's canonical name is computed as follows:
Entry field
For a field directly on the RogLog.Entry
itself, the canonical field name
is simply "entry.
columnName
as an char.
columnIndex
as a char.
StoreDescriptor.getCheckpointingType()
ILnkPeerEndpoint.getContainer()
MessageView.getCreateTs()
columnName
as a Currency
.
columnIndex
as a Currency
.
LnkContainer.getCurrentReader()
columnName
as an Date
.
columnIndex
as a Date
.
AepEngine.sendMessage(com.neeve.sma.MessageChannel, com.neeve.rog.IRogMessage, java.util.Properties)
disposes sent messages.
columnName
as an double.
columnIndex
as a double.
ILnkPeerEndpoint.getEnqueuedSize()
IStorePersister.getErrorHandler()
Query
.
columnName
as a float.
columnIndex
as a float.
IDmnConfigDescriptor.getGroup()
.
ILnkPeerEndpoint.getHandlerChain()
RogLog.Entry.toString()
.
IStoreObject.getId()
IdxIndex
.
IdxIndex
for the given Class
's field if an index exists, or null
no index exists.
QueryEngine
's
QueryRepository
s
IdxIndex
es.
columnName
as an int.
columnIndex
as an int.
IDmnConfigDescriptor.getIOThreadCount()
.
IDmnConfigDescriptor.getIOThreadCPUAffinityMask(int)
.
IDmnConfigDescriptor.getIOThreadCPUAffinityMasks()
.
RogLog
from which this entry was read.
RogLog.Entry
for the current result or null if there
is no current result.
RogLog.Entry
's log.
columnName
as an long.
columnIndex
as a long.
ILnkPeerEndpoint.getLtp()
IDmnConfigDescriptor.getMaxOnDemandThreadCount()
.
IDmnConfigDescriptor.getMemoryReservePct()
.
MessageView.getMessage()
MessageView.getMessageBus()
RawString
form.
MessageView.getMessageBusAsRaw()
MessageChannelEvent.getMessageChannel()
MessageView.getMessageChannel()
RawString
form.
MessageView.getMessageChannelAsRaw()
MessageView.getMessageEncodingType()
MessageView.getMessageFlow()
MessageView.getMessageKey()
MessageView.getMessageKeyAsRaw()
MessageView.getMessageSender()
MessageView.getMessageSequenceNumber()
ILnkPeerEndpoint.getName()
IStorePersister.getName()
and IRogMessageLogger.getName()
IDmnConfigDescriptor.getName()
.
MessageBusBinding
's name as a RawString
RawString
.
ILnkPeerEndpoint.getNameInternal()
ILnkPeerEndpoint.getNextSequenceNum()
IdxNonUniqueIndex
.
IdxNonUniqueIndex
for the given Class
's field if such an index exists, or null
no index exists.
columnName
as an Object.
columnIndex
as an object.
IStoreObjectFactory.getOfid()
IStoreObjectFactory.getOfid()
MessageView.getOriginTs()
MessageView.getOutTs()
MessageView.getOwnershipCount()
MessageView.getOwnershipCount()
MessageView.getPostDeserializeTs()
MessageView.getPostProcessingTs()
MessageView.getPostSerializeTs()
MessageView.getPostWireTs()
MessageView.getPreDeserializeTs()
MessageView.getPreProcessingTs()
MessageView.getPreSerializeTs()
MessageView.getPreWireTs()
IStoreQueryEngine
.
QueryResult
for the Query.
MessageView.getReceiveTs()
QueryEngine
's current QueryRepository
s.
QueryRepository
IRogMetadata
for the current result or null if there
is no current result.
IRogNode
for the current result or null if there
is no current result.
ILnkPeerEndpoint.getRootEndpoint()
QueryResult
.
MessageView.getSendTs()
PktSerializable.getSerializedLength()
PktSerializable.getSerializedLength()
This method returns the serialized length of the static header plus
the serialized length of all attached subheaders.
PktSerializable.getSerializedLength()
.
PktSubheader.getSerializedLength(ByteBuffer)
PktSubheader.getSerializedLength(ByteBuffer)
PktSubheader.getSerializedLength(ByteBuffer)
PktSubheader.getSerializedLength(ByteBuffer)
PktSubheader.getSerializedLength(ByteBuffer)
PktSubheader.getSerializedLength(ByteBuffer)
columnName
as a short.
columnIndex
as a short.
ILnkPeerEndpoint.getState()
IStorePersister.getStats()
IStoreObject
for the current result or null if there
is no current result.
columnName
as an String.
columnIndex
as a String.
MessageView.getTag(int)
ILnkPeerEndpoint.getType()
IStorePersister.getType()
MessageChannel.getType()
MessageView.getType()
IdxUniqueIndex
.
IdxUniqueIndex
for the given Class
's corresponding field if such an index exists,
or null
no index exists.
IStats.Counter
stats.
IStats.Gauge
stats.
IDmnConfigDescriptor.getVersion()
.
MessageView.getVfid()
MessageViewFactory.getVfid()
ILnkPeerEndpoint.getWhenCreated()
IdxField
to the group-by clause of the query.
LoopbackBus.Agent.hashCode()
AepEngine
's
normal dispatcher.IConfigRepository.traverse(java.lang.String, com.neeve.config.IConfigTraversalCallback)
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBody.initialize()
PktBuffer.Initializer.initializeBuffer()
The default implementation of this method is no-op.
PktBuffer.Initializer.initializeBuffer()
PktBuffer.Initializer.initializeBuffer()
PktBuffer.Initializer.initializeBuffer()
PktBuffer.Initializer.initializeBuffer()
PktBuffer.Initializer.initializeBuffer()
PktBuffer.Initializer.initializeBuffer()
IRogRawMessage
encapsulates an opaque payload.IDmnConfigDescriptor.isChecked()
.
LnkContainer.isCompatible(com.neeve.link.ILnkPeerEndpoint)
.
ILnkPeerEndpoint.isGroupEndpoint()
ILnkPeerEndpoint.isJoined(short)
IDmnConfigDescriptor.isMultiThreaded()
.
IStorePersister.isOpen()
MessageView.isPossibleDuplicate()
MessageView.isPossibleDuplicate()
IDmnConfigDescriptor.isPrintDescriptor()
.
ILnkPeerEndpoint.isReadOperational()
ILnkPeerEndpoint.isRootEndpoint()
IStoreObject
.IStoreQuery
is used to query a IStoreBinding
.IStoreQueryEngine
provides indexing and query capabilities
for IStoreBinding
s.QueryRepository
based on IStoreBinding
IStoreQueryResultSet
provides an familiar SQL-like result set for navigating Query
results
from a IStoreQueryEngine
.StoField.isVariableLength()
StoField.isVariableLength()
StoField.isVariableLength()
StoField.isVariableLength()
StoField.isVariableLength()
StoField.isVariableLength()
StoField.isVariableLength()
StoField.isVariableLength()
StoField.isVariableLength()
StoField.isVariableLength()
StoField.isVariableLength()
ILnkPeerEndpoint.join(short, com.neeve.link.ILnkEventHandler)
ILnkPeerEndpoint.leave(short, int)
LnkEvents.EVENT_CONNECT_COMPLETE
and the
LnkEvents.EVENT_ACCEPT_COMPLETE
event types.LnkEvents.EVENT_CONTINUOUS_ACCEPT_COMPLETE
event.LnkEvents.EVENT_CONTINUOUS_CONNECT_COMPLETE
event.LnkSTRContainer
.IRogMessageLogger.log(IRogMessage)
IRogMessageLogger.log(IRogMessage, boolean)
MessageChannel.RawKeyResolutionTable
is used to build a message key
from a given channel key, by providing substitution values for
variable components in the key.IStoreObject.EncodingType
StoBufferField.getValue()
is asynchronously changed.
IEventHandler.onEvent(com.neeve.event.Event)
IEventHandler.onEvent(com.neeve.event.Event)
This method is the engine multiplexer's event handler, it should never be invoked
directly by the application.
IStoreEventHandler.onEvent(com.neeve.ods.IStoreEvent)
This method is the store event handler and should never be invoked
directly by the application.
IEventHandler.onEvent(com.neeve.event.Event)
QueryIndexer
.
IStorePersister.open(PktBuffer, boolean)
IStorePersister.open(com.neeve.pkt.PktBuffer, boolean)
and IRogMessageLogger.open()
PktBody.postDeserialize(int)
PktBody.postDeserialize(int)
PktBody.postDeserialize(int)
PktBody.postDeserialize(int)
PktBody.postDeserialize(int)
PktBody.postDeserialize(int)
PktBody.postDeserialize(int)
PktBody.postDeserialize(int)
PktBody.postDeserialize(int)
PktBody.postDeserialize(int)
PktBody.postDeserialize(int)
PktBody.postDeserialize(int)
PktBody.postDeserialize(int)
Handler.publish(java.util.logging.LogRecord)
This method stores the supplied log record into the history buffer
and then publishes the record to the downstream handler.
Handler.publish(java.util.logging.LogRecord)
Handler.publish(java.util.logging.LogRecord)
PktBuffer
to this PktBuffer
.
Query
is used to build a query that can be executed
against a QueryEngine
.QueryEngine
provides query functionality across one or more QueryRepository
s
that have homogeneous key and value types.QueryEngineProvider
is responsible for creating a query engineQueryException
QueryException
QueryException
QueryIndexer
handles creation and retrieval of IdxIndex
es
against an indexable repository.QueryRepository
is an indexable store of Object
s that can be queried by a QueryEngine
.QueryResult
is the raw output of a Query
on a QueryEngine
.QueryEngine
query.IStoreReader.read(com.neeve.ods.IStoreReader.ReadCallback)
IStoreReader.readMetadata(com.neeve.pkt.PktBuffer)
PktPacket.dispose()
once it is done writing
the object during commit.
MessageView.getOwnershipCount()
QueryRepository
s write lock.
QueryRepository
from the QueryEngine
.
QueryIndexer
.
MessageBusBinding.FlushContext.reset()
MessageBusBinding.FlushContext.reset()
MessageBusBinding.FlushContext.reset()
StoField.reset()
StoField.reset()
StoField.reset()
StoField.reset()
StoField.reset()
StoField.reset()
StoField.reset()
StoField.reset()
StoField.reset()
StoField.reset()
StoField.reset()
RawString
.
Iterable
of all values in the QueryRepository
for the given
keys.
QueryRepository
.
RogLog.Entry
s are not safe for concurrent access by multiple threads.RogLogCompactionReader.run(int, long)
invocation completesRogLogQuery
is used to query a RogLog
.RogLogQueryEngine
provides query access to a set of RogLog
files.IdxField
for a RogLogQueryEngine
QueryRepository
based on RogLog
RogLogResultSet
provides an familiar SQL-like result set for navigating Query
results
from a RogLogQueryEngine
.IStoreBinding
implementation used internally by the platform.Runnable.run()
QueryResult
.
RawString
key resolution table.
MessageChannel.sendMessage(MessageView, Properties, com.neeve.sma.MessageBusBinding.FlushContext, int)
,
except that it accepts a MessageChannel.RawKeyResolutionTable
allow the message key to be resolved without producing
garbage.
PktSerializable.serialize(com.neeve.pkt.PktSerializable.SerializeContext, com.neeve.trace.Tracer)
This method serializes the packet body into the buffer list
in the specified serialization context.
PktSerializable.serialize(com.neeve.pkt.PktSerializable.SerializeContext, com.neeve.trace.Tracer)
.
PktSerializable.serialize(com.neeve.pkt.PktSerializable.SerializeContext, com.neeve.trace.Tracer)
.
MessageView.serializeToByteArray()
MessageView.serializeToByteBuffer()
MessageView.serializeToPacket()
setAsLastTransaction(cause, ignoreIfStarting, false)
ILnkPeerEndpoint.setAttachment(java.lang.Object)
QueryResultSet.Collation
.
ILnkPeerEndpoint.setContainer(com.neeve.link.LnkContainer)
IRogMessageLogger.setContainsInboundMessages(boolean)
IRogMessageLogger.setContainsOutboundMessages(boolean)
MessageView.setCreateTs(long)
Package
within which to find classes that are used in queries.
PktSerializable.setDeserializationPolicy(int)
.
PktSerializable.setDeserializationPolicy(int)
.
IStorePersister.setErrorHandler(com.neeve.ods.IStorePersister.ErrorHandler)
Query
.
Handler.setFormatter(java.util.logging.Formatter)
This method sets the formatter of the downstream handler.
IDmnConfigDescriptor.setGroup(java.lang.String)
.
IDmnConfigDescriptor.setIOThreadCount(int)
.
IDmnConfigDescriptor.setIOThreadCPUAffinityMask(int, long)
.
IDmnConfigDescriptor.setMaxOnDemandThreadCount(int)
.
IDmnConfigDescriptor.setMemoryReservePct(int)
.
MessageView.setMessageBus(java.lang.String)
MessageView.setMessageBusAsRaw(com.neeve.raw.RawString)
MessageView.setMessageChannel(java.lang.String)
MessageView.setMessageChannelAsRaw(com.neeve.raw.RawString)
MessageView.setMessageFlow(int)
MessageView.setMessageKey(java.lang.String)
MessageView.setMessageKey(java.lang.String)
MessageView.setMessageSender(int)
MessageView.setMessageSequenceNumber(long)
IDmnConfigDescriptor.setMultiThreaded(boolean)
.
MessageView.setOriginTs(long)
MessageView.setOutTs(long)
MessageView.setPossibleDuplicate()
MessageView.setPostDeserializeTs(long)
MessageView.setPostProcessingTs(long)
MessageView.setPostSerializeTs(long)
MessageView.setPostWireTs(long)
MessageView.setPreDeserializeTs(long)
MessageView.setPreProcessingTs(long)
MessageView.setPreSerializeTs(long)
MessageView.setPreWireTs(long)
IDmnConfigDescriptor.setPrintDescriptor(boolean)
.
RogLogReader
to use for recovery.
MessageView.setReceiveTs(long)
MessageView.setSendTs(long)
PktSerializable.setSerializationPolicy(int)
.
PktSerializable.setSerializationPolicy(int)
.
IStorePersister.setStartupExpectation(com.neeve.ods.IStoreJournallingPersister.StartupExpectation, java.lang.Enum>)
IAepAsynchronousEventHandler
.
MessageView.setTag(int, java.lang.Object)
QueryResult
.
Thread.start()
LnkContainer.startRead(com.neeve.link.ILnkPeerEndpoint)
LnkContainer.stopRead(com.neeve.link.ILnkPeerEndpoint)
MessageView.sync()
RogLog.Entry
.
RogLog.Entry
LoopbackBus.Agent.toString()
System.err
RogLog
logs.LoopbackBus.waitForPendingAcks(long, TimeUnit)
with TimeUnit.MILLISECONDS
IStoreJournallingPersister.wasRepaired()
MessageViewFactory.wrap(short, int, java.lang.Object)
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |