MCPcopy Create free account

hub / github.com/oracle/coherence / functions

Functions78,752 in github.com/oracle/coherence

⨍ Functions 78,752◇ Types & classes 10,274
↓ 3 callersMethodonCompleted
()
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/v1/GrpcConnectionV1.java:424
↓ 3 callersMethodonDelete
Handle a Delete request. @param request the Request @param response the Response @throws IOException
prj/coherence-core/src/main/java/com/tangosol/coherence/memcached/RequestHandler.java:137
↓ 3 callersMethodonDistributionCompleted
Called on the service thread when the distribution from the specified member has completed (either by finished the receive successfully, or departure
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:12498
↓ 3 callersMethodonEOS
Called when a SocketChannel has reached end-of-stream This method unregisters the key in order to prevent subsequent EOS triggers, and schedules a gr
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/peer/acceptor/TcpAcceptor.java:5469
↓ 3 callersMethodonError
(Throwable throwable)
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/MapListenerProxy.java:210
↓ 3 callersMethodonEvent
(com.tangosol.util.MapEvent event)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/Grid.java:8389
↓ 3 callersMethodonException
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofBufferWriter.java:3052
↓ 3 callersMethodonException
Process an exception that is thrown during a task execution. The default implementation logs the exception and continues. @param e Throwable obje
prj/coherence-core/src/main/java/com/tangosol/util/TaskDaemon.java:545
↓ 3 callersMethodonException
This event occurs when an exception is thrown from onEnter, onWait, onNotify and onExit. If the exception should terminate the daemon, call stop(). T
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/Daemon.java:960
↓ 3 callersMethodonInitialized
Indicate to the connector that the subscriber has been intialized.
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/SubscriberConnector.java:294
↓ 3 callersMethodonInt32
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/pof/DuplexingPofHandler.java:87
↓ 3 callersMethodonLaunching
( Platform platform, MetaClass metaClass, OptionsByType optionsByType)
prj/coherence-bedrock/coherence-bedrock/src/main/java/com/oracle/bedrock/runtime/coherence/options/Pof.java:106
↓ 3 callersMethodonLeaseLockRequest
Process the lock request. This method is called on the service thread and should not be called externally. @param msgRequest the request message
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ReplicatedCache.java:1592
↓ 3 callersMethodonMapEvent
Invoked when a map entry has been inserted, updated or deleted. To determine what action has occurred, use {@link MapEvent#getId()}. @param evt the
prj/coherence-core/src/main/java/com/tangosol/util/MultiplexingMapListener.java:29
↓ 3 callersMethodonMapEvent
Convert a {@link MapEvent} into a {@link MapEventResponse} and send it to the {@link StreamObserver}, converting the{@link Binary} key and values if r
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/MapListenerProxy.java:707
↓ 3 callersMethodonMapEvent
Called when a MapEvent has been raised by the NamedCache that this MapListener has been registered with. @param evt the MapEvent
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/proxy/MapListenerProxy.java:609
↓ 3 callersMethodonMappingAdded
Increase the size of the index by the size of an index map entry.
prj/coherence-core/src/main/java/com/tangosol/util/SimpleMapIndex.java:1014
↓ 3 callersMethodonMappingRemoved
Decrease the size of the index by the size of an index map entry.
prj/coherence-core/src/main/java/com/tangosol/util/SimpleMapIndex.java:988
↓ 3 callersMethodonMemberEvent
Helper method to submit a {@link MemberEventRunnable} on a {@link MemberEvent}. @param event the {@link MemberEvent} to process.
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/internal/LiveObjectEventInterceptor.java:441
↓ 3 callersMethodonMemberJoined
(com.tangosol.coherence.component.net.Member member)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:3504
↓ 3 callersMethodonMissingCoordinator
Called when no config coordinator member is found to receive config requests to update the map.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/ServiceConfig.java:255
↓ 3 callersMethodonNext
Invoked when a {@link Coordinator} has produced an item for consumption. <p> If this method throws an exception, the {@link Subscriber} will be closed
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/Task.java:622
↓ 3 callersMethodonNext
(@NonNull MapEvent<K, V> kvMapEvent)
prj/test/functional/grpc-proxy-tck/src/main/java/grpc/proxy/BaseGrpcIT.java:520
↓ 3 callersMethodonPacketAdd
Called as a packet is being added to the resend queue.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/packetProcessor/PacketPublisher.java:5932
↓ 3 callersMethodonPacketDone
Called when a sent packet has been confirmed by all living receipients. Packet does not need to be resent any longer; remove it from the associated ou
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/packetProcessor/PacketPublisher.java:5954
↓ 3 callersMethodonReady
Called when the channel has been selected. <p> The handler implementation is expected to handle all exceptions. Any unchecked exception thrown from th
prj/coherence-core/src/main/java/com/oracle/coherence/common/net/SelectionService.java:110
↓ 3 callersMethodonReceived
This is the event that is executed when a Message is received. <p> It is the main processing event of the Message called by the <code>Service.onMessag
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:15220
↓ 3 callersMethodonReceived
This is the event that is executed when a Message is received. <p> It is the main processing event of the Message called by the <code>Service.onMessag
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/SimpleCache.java:1753
↓ 3 callersMethodonRemoved
An event callback that will be called when an entity is removed from the repository. @param entity removed entity
prj/coherence-core/src/main/java/com/oracle/coherence/repository/AbstractRepositoryBase.java:380
↓ 3 callersMethodonServiceJoining
Event notification informing the ClusterService that a service is joining the cluster. @param info the service info @param member the cluster member
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:4034
↓ 3 callersMethodonStopJoining
This event is invoked when a Member cannot join a cluster (State=JOINING) because this Member was rejected. This event must stop the ClusterService o
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:4132
↓ 3 callersMethodonStoreOpenFailed
Called when a PersistentStore failed to open; either in opening an existing store or a new store based on an existing store.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:7261
↓ 3 callersMethodonSubscribe
(Task.Subscription<? extends T> subscription)
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/subscribers/RecordingSubscriber.java:94
↓ 3 callersMethodonTruncate
The cache has been truncated.
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/NamedCacheClientChannel.java:575
↓ 3 callersMethodonUpdated
An event callback that will be called when an entity is updated. @param oldEntity previous entity @param newEntity new entity
prj/coherence-core/src/main/java/com/oracle/coherence/repository/AbstractRepositoryBase.java:370
↓ 3 callersMethodopen
Open or create a {@link PersistentStore} associated with the specified identifier and based on the provided {@link PersistentStore store}. <p> Upon a
prj/coherence-core/src/main/java/com/oracle/coherence/persistence/PersistenceManager.java:80
↓ 3 callersMethodopen
Open a connection to the specified URI. @param uri the URI to open @return the HTTP connection @throws IOException if the connection cannot be ope
prj/coherence-rag-parent/coherence-rag/src/main/java/com/oracle/coherence/rag/api/RagSecurity.java:930
↓ 3 callersMethodopenAiApiKey
Returns the OpenAI API key from configuration. @return the API key for OpenAI service @throws ConfigException if the API key is not configured or is
prj/coherence-rag-parent/models/coherence-rag-openai/src/main/java/com/oracle/coherence/rag/model/openai/OpenAiModelProvider.java:189
↓ 3 callersMethodopenBackup
Open and return a singleton PersistenceManager to store backup data. @return the singleton backup PersistenceManager or null if an active Per
prj/coherence-core/src/main/java/com/oracle/coherence/persistence/PersistenceEnvironment.java:26
↓ 3 callersMethodopenChannel
(com.tangosol.net.messaging.Protocol protocol, String sName, ClassLoader loader, com.tangosol.net.messaging.Ch
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/Connection.java:1226
↓ 3 callersMethodopenChannelOnNewProxy
(StreamObserver<ProxyResponse> observer)
prj/test/functional/grpc-proxy-tck/src/main/java/grpc/proxy/version_1/BaseVersionOneGrpcServiceIT.java:53
↓ 3 callersMethodopenStore
()
prj/test/performance/benchmarks/src/main/java/com/tangosol/coherence/performance/benchmarks/persistence/PersistenceStoreBenchmark.java:252
↓ 3 callersMethodorderedInsert
Scan the list and insert the supplied packet just before the first packet which has a later resend time. Return the insertion index, or -1 if it the
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/packetProcessor/PacketPublisher.java:3991
↓ 3 callersMethodoutAttributes
(Attribute[] aAttr, String sIndent)
prj/coherence-core/src/main/java/com/tangosol/dev/disassembler/Disassembler.java:143
↓ 3 callersMethodoutputResult
Output summary information about the given TestResult. @param result the TestResult
prj/test/performance/psr/src/main/java/com/tangosol/coherence/performance/psr/Console.java:2601
↓ 3 callersMethodparamTypes
Enumerate parameter lists for all methods on this type that have a specified name and number of parameters. @param sMethod the method name @param cP
prj/coherence-core/src/main/java/com/tangosol/dev/compiler/TypeInfo.java:111
↓ 3 callersMethodpark
Invoke LockSupport.park() while still respecting the calling thread's {@link Timeout timeout}. @param oBlocker the blocker
prj/coherence-core/src/main/java/com/oracle/coherence/common/base/Blocking.java:137
↓ 3 callersMethodparse
Parse a POF value that is in the passed BufferInput. @param in the BufferInput to read the POF value from
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofParser.java:49
↓ 3 callersMethodparseArgument
Parses an argument into a name/value pair and returns the name and value in a 2-element String array. @param sArg the argument value @return a Stri
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/Application.java:1079
↓ 3 callersMethodparseBufferedEntry
Parse a journal entry fully buffered in memory. @param abEntry entry bytes @param ofEntry entry offset within the byte array @param cbE
prj/coherence-core/src/main/java/com/tangosol/io/journal2/JournalUtils.java:304
↓ 3 callersMethodparseEntryHeader
Parse a journal entry header at the specified buffer offset. <p> For STORE entries, this method parses all metadata while intentionally skipping value
prj/coherence-core/src/main/java/com/tangosol/io/journal2/JournalEntry.java:193
↓ 3 callersMethodparseFilterList
Parse the XML and return a filter list specified by use-filters. @param xml the parent of the use-filters element @return the list of filter names
prj/coherence-core/src/main/java/com/tangosol/internal/net/LegacyXmlConfigHelper.java:52
↓ 3 callersMethodparseHex
Parse the passed String of hexadecimal characters into a binary value. This implementation allows the passed String to be prefixed with "0x". @param
prj/coherence-core/src/main/java/com/oracle/coherence/common/base/Formatting.java:1113
↓ 3 callersMethodparseLongProperty
Parse a long-valued journal system property. @param sProperty the system property name @param sValue the configured value @return the parsed lo
prj/coherence-core/src/main/java/com/tangosol/coherence/config/builder/PersistenceEnvironmentParamBuilder.java:549
↓ 3 callersMethodparseMisc
Parse comments / other PIs. @param xml the XML element @throws CompilerException if compiler error occurs
prj/coherence-core/src/main/java/com/tangosol/run/xml/SimpleParser.java:643
↓ 3 callersMethodparseMultiplicativeExpression
Parse a multiplicative expression. MultiplicativeExpression: UnaryExpression MultiplicativeExpression UnaryExpression Multiplicat
prj/coherence-core/src/main/java/com/tangosol/dev/compiler/java/Compiler.java:1748
↓ 3 callersMethodparsePercentage
Parse the given string representation of a percentage value and return its value as a float in the inclusive range of 0.0 and 1.0. The supplied string
prj/coherence-core/src/main/java/com/tangosol/util/Base.java:1873
↓ 3 callersMethodparsePi
Parse &lt;?xml. @param xml the XML element @throws CompilerException if compiler error occurs
prj/coherence-core/src/main/java/com/tangosol/run/xml/SimpleParser.java:376
↓ 3 callersMethodparseQueryString
Parse a query string containing parameter type hints. <p> Parameter type hints allow users to specify the type conversion that should be performed on
prj/coherence-rest/src/main/java/com/tangosol/coherence/rest/query/AbstractQueryEngine.java:56
↓ 3 callersMethodparseRelationalExpression
Parse a relational test expression. RelationalExpression: ShiftExpression RelationalExpression < ShiftExpression RelationalExpres
prj/coherence-core/src/main/java/com/tangosol/dev/compiler/java/Compiler.java:1638
↓ 3 callersMethodparseTimeNanos
Parse the given string representation of a time duration and return its value as a number of nanoseconds. The supplied string must be in the format: <
prj/coherence-core/src/main/java/com/oracle/coherence/common/base/Formatting.java:1972
↓ 3 callersMethodparseTypeName
Parse specified platform-specific type name and return the {@link TypeDescriptor} that corresponds to it. @param name the type name to parse @retur
prj/coherence-core/src/main/java/com/oracle/coherence/common/schema/lang/XmlTypeHandler.java:141
↓ 3 callersMethodparseWithRootElement
Parse a Coherence configuration XML document with the given root element. This element contains the XSD schema location which is used to load the XSD
prj/test/unit/coherence-tests/src/test/java/com/tangosol/run/xml/SaxParserTest.java:108
↓ 3 callersMethodparserFor
(String json)
prj/coherence-json/src/test/java/com/oracle/coherence/io/json/genson/ext/jsr353/JsonParserTest.java:189
↓ 3 callersMethodpeekAll
Checks for a valid entry corresponding to each specified key in the cache, and places the corresponding value in the returned map if it is. For each k
prj/coherence-core/src/main/java/com/tangosol/net/cache/LocalCache.java:1074
↓ 3 callersMethodpeekAll
Checks for a valid entry corresponding to each specified key in the cache, and places the corresponding value in the returned map if it is. For each k
prj/test/unit/coherence-tests/src/test/java/com/tangosol/net/cache/OldLocalCache.java:495
↓ 3 callersMethodpeekAtBucket
Returns an {@link Iterator} that iterates over the elements in the bucket with the specified id. If there is no bucket with the specified id then null
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/paged/BinaryPagedNamedQueue.java:236
↓ 3 callersMethodpeekAtBucket
Returns an {@link Iterator} that iterates over the elements in the bucket with the specified id. If there is no bucket with the specified id then null
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/paged/PagedNamedQueue.java:212
↓ 3 callersMethodpeekPageEntry
Returns a read-only copy of the specified page entry or {code null} if the requested page number is (@link {@link Page#NULL_PAGE}). @param lPageId t
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/PagedTopicPartition.java:674
↓ 3 callersMethodpersistGlobalMetadata
Ensure that the global metadata is properly persisted as part of this partition's persistent form (if applicable). @param nPartition the partition
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java:6743
↓ 3 callersMethodplanAppend
Validate and pre-compute append metadata for an entry. @param bType entry type @param bufKey entry key, or {@code null} @param bufValue entry
prj/coherence-core/src/main/java/com/tangosol/io/journal2/PartitionJournal.java:409
↓ 3 callersMethodpofTest
(Duration d)
prj/test/functional/jcache/src/main/java/com/tangosol/coherence/jcachetesting/ConfigurationDurationTests.java:118
↓ 3 callersMethodpoll
(long timeout, TimeUnit unit)
prj/coherence-core/src/main/java/com/oracle/coherence/common/collections/SingleConsumerBlockingQueue.java:117
↓ 3 callersMethodpollLast
()
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/SimpleNamedMapDeque.java:173
↓ 3 callersMethodpopCacheContext
Pop cache context from a thread-local storage. @return the popped cache context
prj/coherence-core/src/main/java/com/tangosol/net/DefaultConfigurableCacheFactory.java:4075
↓ 3 callersMethodpopulate
Populate the dependencies and test the getters. @param deps the DefaultPeerDependencies to populate @return the DefaultPeerDependencies that was pa
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/service/peer/PeerDependenciesTest.java:78
↓ 3 callersMethodpopulate
Populate the dependencies and test the getters. @param deps the AbstractAcceptorDependencies to populate @return the AbstractAcceptorDependencies t
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/service/peer/acceptor/AcceptorDependenciesTest.java:89
↓ 3 callersMethodpopulate
Populate the dependencies and test the getters. @param deps the DefaultPartitionedCacheDependencies to populate @return the DefaultPartitionedCache
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/service/grid/PartitionedCacheDependenciesTest.java:126
↓ 3 callersMethodpopulate
Populate the dependencies and test the getters. @param deps the DefaultServiceProxyDependencies to populate @return the DefaultServiceProxyDependen
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/service/extend/proxy/ServiceProxyDependenciesTest.java:65
↓ 3 callersMethodpopulateRepository
()
prj/test/functional/repository/src/main/java/repository/AbstractAsyncRepositoryTests.java:83
↓ 3 callersMethodpopulateRepository
()
prj/test/functional/repository/src/main/java/repository/AbstractRepositoryTests.java:75
↓ 3 callersMethodpopulateSchema
(Schema schema)
prj/coherence-core/src/main/java/com/oracle/coherence/common/schema/ClassFileSchemaSource.java:271
↓ 3 callersMethodpost
Asynchronous Message send implementation. @param message the Message to send asynchronously
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/Channel.java:1440
↓ 3 callersMethodpostStart
Called after the application is started. At this point, services marked with {@code <autostart>} will have been started. These services (and caches)
prj/coherence-core/src/main/java/com/tangosol/application/LifecycleListener.java:48
↓ 3 callersMethodpotentialStreamClosedException
Check if an NPE is caused by the stream being closed. Either throws an IO exception if the stream is closed or throws the original NPE. @param e an
prj/coherence-core/src/main/java/com/tangosol/io/nio/ByteBufferInputStream.java:275
↓ 3 callersMethodpreStart
Called before the application is activated. In general this occurs before services in a cache configuration file are started thus allowing for pre se
prj/coherence-core/src/main/java/com/tangosol/application/LifecycleListener.java:38
↓ 3 callersMethodprecompileTest
Perform semantic checks, parse tree re-organization, name binding, and optimizations. @param ctx the compiler context @param setUVars the se
prj/coherence-core/src/main/java/com/tangosol/dev/compiler/java/ConditionalStatement.java:66
↓ 3 callersMethodprepareEvent
Prepares an {@link Event} to be accepted for processing. @param event the {@link Event} to prepare @return the prepared {@link Event} (or <code>nul
prj/coherence-core/src/main/java/com/tangosol/util/fsm/NonBlockingFiniteStateMachine.java:555
↓ 3 callersMethodprepareStatement
Realize an instance of the {@link Statement} that will execute the CohQL statement represented by the AST node. @param term the parsed AST
prj/coherence-core/src/main/java/com/tangosol/coherence/dslquery/CoherenceQueryLanguage.java:586
↓ 3 callersMethodprintCache
(NamedCache cache)
prj/test/functional/aggregator/src/main/java/aggregator/AbstractEntryAggregatorTests.java:1557
↓ 3 callersMethodprintStackTrace
Print this {@code PortableException} and its stack trace to the specified stream. @param stream the {@link PrintStream} to use for the output
prj/coherence-core/src/main/java/com/tangosol/io/pof/PortableException.java:236
↓ 3 callersMethodprintWithIndent
Using the specified PrintWriter and indentation string, print the contents of this Node and all Nodes under it recursively. @param out a PrintWr
prj/coherence-core/src/main/java/com/tangosol/util/BinaryRadixTree.java:1020
↓ 3 callersMethodprintableString
Converts the string to a printable string (escapes are de-escaped). @return the string (escaped as necessary)
prj/coherence-core/src/main/java/com/tangosol/dev/compiler/java/LiteralToken.java:437
↓ 3 callersMethodproceed
(Object oResult)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:17592
↓ 3 callersMethodprocess
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/coherence/config/xml/processor/HttpAcceptorDependenciesProcessor.java:49
↓ 3 callersMethodprocess
Provess the given event by updating the tracked versions and delegating to the wrapped if listener iff the event has not been seen. @param event
prj/coherence-core/src/main/java/com/tangosol/internal/util/listener/VersionAwareListeners.java:290
↓ 3 callersMethodprocessEntry
Process an {@link BinaryEntry} from an interceptor event. @param event the {@link Event} @param binaryEntry the {@link BinaryEntry} @param ca
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/internal/LiveObjectEventInterceptor.java:186
↓ 3 callersMethodprocessEvent
Process an arbitrary event that has occurred against either the front or back map. @param status the Status object representing the Overflow Map's
prj/coherence-core/src/main/java/com/tangosol/net/cache/OverflowMap.java:2468
↓ 3 callersMethodprocessQuorumElement
Process a specific quorum group.
prj/coherence-core/src/main/java/com/tangosol/internal/net/cluster/LegacyXmlConfigurableQuorumPolicy.java:161
↓ 3 callersMethodprocessRemainingElementOf
Request that the last remaining unprocessed child element contained within the specified {@link XmlElement} is processed using an appropriate {@link E
prj/coherence-core/src/main/java/com/tangosol/config/xml/ProcessingContext.java:465
← previousnext →12,101–12,200 of 78,752, ranked by callers