MCPcopy Create free account

hub / github.com/oracle/coherence / functions

Functions78,752 in github.com/oracle/coherence

↓ 10 callersMethodwithEventInterceptors
Add the {@link EventInterceptor} instances that will be added to all {@link Session} instances as they are created on start-up. @param interceptors
prj/coherence-core/src/main/java/com/tangosol/net/CoherenceConfiguration.java:304
↓ 10 callersMethodwithRawTypes
Obtains a {@link TypeAssertion} that allows NamedCaches to be acquired and assigned to a raw NamedCache reference. A debug log message will be raised
prj/coherence-core/src/main/java/com/tangosol/net/cache/TypeAssertion.java:92
↓ 10 callersMethodwithSessions
Add the {@link SessionConfiguration} instances to the {@link Coherence} instance that will be used to create the corresponding {@link Session} instanc
prj/coherence-core/src/main/java/com/tangosol/net/CoherenceConfiguration.java:246
↓ 10 callersMethodwrite
Request a write into the peer's memory from the specified BufferSequence. <p> Upon {@link Event.Type#RECEIPT completion} of the asynchronous operation
prj/coherence-core/src/main/java/com/oracle/coherence/common/net/exabus/MemoryBus.java:105
↓ 10 callersMethodwriteToFile
(byte[] ba, String dataType)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/pof/data/PofStreamTest.java:234
↓ 9 callersMethod__init
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:15842
↓ 9 callersMethod__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/proxy/NamedCacheProxy.java:186
↓ 9 callersMethod__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/transactionCache/Local.java:87
↓ 9 callersMethod__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/peer/acceptor/TcpAcceptor.java:331
↓ 9 callersMethod__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:15853
↓ 9 callersMethod__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ProxyService.java:307
↓ 9 callersMethod_newInstance
Create a new instance of a component with the specified fully qualified name (i.e. "Component.GUI.Color.Red"). The algorithm works out of the assump
prj/coherence-core-components/src/main/java/com/tangosol/coherence/Component.java:1052
↓ 9 callersMethodaccept
This method should be called by the client immediately after it determines that it can successfully use an address returned by the {@link #getNextAddr
prj/coherence-core/src/main/java/com/tangosol/net/SocketAddressProvider.java:46
↓ 9 callersMethodaccepted
Determines if the tracked {@link Event} was accepted for processing. @return if the {@link Event} was accepted for processing
prj/test/unit/coherence-tests/src/test/java/com/tangosol/util/fsm/misc/TrackingEvent.java:107
↓ 9 callersMethodadd
(Object o)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/memberSet/ActualMemberSet.java:146
↓ 9 callersMethodaddAll
Helper method for colThis.addAll(colThat)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/Collections.java:104
↓ 9 callersMethodaddAvailable
Add the specified node to the available set. @param node the available node @return true
prj/coherence-core/src/main/java/com/oracle/coherence/common/util/ConcurrentAssociationPile.java:203
↓ 9 callersMethodaddDeleteHandler
Add the event handler for DELETE events. @param onDelete the event handler to execute @return this MapListener
prj/coherence-core/src/main/java/com/tangosol/util/listener/SimpleMapListener.java:63
↓ 9 callersMethodaddEvent
Requests that the specified event be prepared for dispatching to the specified type of listeners. @param listenerClass the class of {@link javax.cach
prj/coherence-jcache/src/main/java/com/tangosol/coherence/jcache/common/CoherenceCacheEventEventDispatcher.java:56
↓ 9 callersMethodaddIndex
Asynchronous implementation of {@link NamedCache#addIndex}. @param extractor the ValueExtractor object that is used to extract an
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/NamedCacheClientChannel.java:87
↓ 9 callersMethodaddReason
Add a reason to the provided list (could be null).
prj/coherence-core/src/main/java/com/tangosol/net/ConfigurableQuorumPolicy.java:899
↓ 9 callersMethodaddResourceLink
Add a resource link to the response links. @param sRel the name of link @param uri the URI of the link @return
prj/coherence-core/src/main/java/com/tangosol/internal/management/MBeanResponse.java:159
↓ 9 callersMethodaddSchemaSource
Add {@link SchemaSource} to this {@code SchemaBuilder}. @param schemaSource the {@link SchemaSource} to add @return this {@code SchemaBuilder}
prj/coherence-core/src/main/java/com/oracle/coherence/common/schema/SchemaBuilder.java:82
↓ 9 callersMethodadjust
Adjust the offset of this BufferOutput based on a write that by-passed this BufferOutput's own super-class implementation that is responsible for main
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/OldMultiBufferWriteBuffer.java:760
↓ 9 callersMethodaggregate
Perform an aggregating operation asynchronously against all the entries. @param <R> the type of value returned by the EntryAggregator @param
prj/coherence-core/src/main/java/com/tangosol/net/AsyncNamedMap.java:791
↓ 9 callersMethodapply
(ManagedChannelBuilder<?> builder)
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/GrpcChannelConfigurer.java:21
↓ 9 callersMethodassertIO
Similar to _assert(), but IOException is thrown.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/packet/MessagePacket.java:303
↓ 9 callersMethodassertSingleEvent
(EventCollector collector, Filter filter, boolean fClear)
prj/test/functional/transformer/src/main/java/transformer/AbstractMapEventTransformerTests.java:335
↓ 9 callersMethodassertSnapshotExists
Assert a snapshot exists. @param sSnapshotName the snapshot name @param sType the type of snapshot, archive or snapshot @return true if it
prj/test/functional/management/src/main/java/management/BaseManagementInfoResourceTests.java:4341
↓ 9 callersMethodasync
Return an asynchronous wrapper for this NamedCache. <p> By default, the order of execution of asynchronous operation invoked on the returned AsyncName
prj/coherence-core/src/main/java/com/tangosol/net/NamedCache.java:162
↓ 9 callersMethodawaitNanos
(long nanosTimeout)
prj/coherence-core/src/main/java/com/oracle/coherence/common/util/NullLock.java:93
↓ 9 callersMethodawaitReleased
Wait for the permit released event. @param timeout the maximum amount of time to wait @return the global order of the permit released event
prj/test/functional/concurrent/src/main/java/concurrent/AbstractClusteredRemoteSemaphoreIT.java:910
↓ 9 callersMethodawaitReleased
Wait for the lock released event. @param timeout the maximum amount of time to wait @return the global order of the lock released event
prj/test/functional/concurrent/src/main/java/concurrent/locks/AbstractClusteredRemoteLockIT.java:688
↓ 9 callersMethodawaitStarted
()
prj/test/functional/core/src/main/java/com/tangosol/coherence/component/util/DaemonPoolIT.java:1503
↓ 9 callersMethodbegin
Begin a new sequence of mutating operations that should be committed to the store as an atomic unit. The returned token should be passed to all mutati
prj/coherence-core/src/main/java/com/oracle/coherence/persistence/PersistentStore.java:239
↓ 9 callersMethodbeginNextObjectMetadata
This method is a kind of cheat as it allows us to start writing metadata and then still be able to call beginObject. This is mainly intended to be use
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/stream/ObjectWriter.java:264
↓ 9 callersMethodbruteForce
Force brute force search, ignoring any available indexes. @return this instance
prj/coherence-core/src/main/java/com/oracle/coherence/ai/search/SimilaritySearch.java:128
↓ 9 callersMethodcalculateQueueHash
Calculate the hash from the queue name. <p/> This hash will be consistent across versions and JVMs, which is important as the hash is used in queue ke
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/model/QueueKey.java:209
↓ 9 callersMethodcalculateUnbalanced
Calculate the total number of unbalanced partitions. Used by the JMX and tests.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:1541
↓ 9 callersMethodcheckDate
Validate date information. @param nYear the year number @param nMonth the month number @param nDay the day number
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofHelper.java:1767
↓ 9 callersMethodcheckReadOnly
Check the read-only setting to verify that the cache is NOT read-only. @throws IllegalStateException if the {@code ContinuousQueryCache} is read-only
prj/coherence-core/src/main/java/com/tangosol/net/cache/ContinuousQueryCache.java:1608
↓ 9 callersMethodcheckResultCode
This method checks the result code coming from the native execution is correct otherwise throws an exception. @throws UnexpectedNativeException when
prj/coherence-hnsw/src/main/java/com/oracle/coherence/hnswlib/Index.java:402
↓ 9 callersMethodcheckType
Validate a type identifier. @param nType the type identifier
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofHelper.java:1598
↓ 9 callersMethodclearEvent
Reset the MapEvent property.
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/TestMapListener.java:104
↓ 9 callersMethodconfigureStore
()
prj/coherence-rag-parent/coherence-rag/src/test/java/com/oracle/coherence/rag/api/StoreIT.java:116
↓ 9 callersMethodconnect
Explicitly connect to the server, if the client is not already connected. @throws IOException on connection error
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/net/EchoClient.java:66
↓ 9 callersMethodcontainsEntry
Create a {@link ContainsEntryRequest}. @param scope the scope name to use to obtain the cache from. @param cacheName the name of the cache to c
prj/coherence-grpc/src/main/java/com/oracle/coherence/grpc/v0/Requests.java:330
↓ 9 callersMethodcontainsValue
Helper method for confirm presence of the value within the cache. @param value the value to check @return a {@link CompletableFuture} returning {@cod
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/NamedCacheClientChannel.java:177
↓ 9 callersMethodcontainsValue
Returns {@code true} if this map contains a mapping for the specified value. @param request the request which contains the value whose presence
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/NamedCacheService.java:140
↓ 9 callersMethodcontainsValue
Create a {@link ContainsValueRequest}. @param scope the scope name to use to obtain the cache from. @param cacheName the name of the cache to c
prj/coherence-grpc/src/main/java/com/oracle/coherence/grpc/v0/Requests.java:372
↓ 9 callersMethodconvertAssignable
Some types are considered assignable although they require conversion. @param ctx the compilation context @param dtThat the type to assign to @
prj/coherence-core/src/main/java/com/tangosol/dev/compiler/java/Expression.java:890
↓ 9 callersMethodconvertEL
Serialize the input value using ExternalizableLite then de-serialize it. @param inVal the input value @return the output value that was de-serializ
prj/test/unit/coherence-tests/src/test/java/com/tangosol/config/TestSerializableHelper.java:35
↓ 9 callersMethodconvertPof
Serialize the input value using POF then de-serialize it. @param inVal the input value @return the output value that was de-serialized
prj/test/unit/coherence-tests/src/test/java/com/tangosol/config/TestSerializableHelper.java:55
↓ 9 callersMethodcopyBytes
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/MultiBufferReadBuffer.java:219
↓ 9 callersMethodcount
A {@link Task.Collector} that counts the number of non-null results that have been made. @param <T> the type of result @return a {@link Task.Collec
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/TaskCollectors.java:94
↓ 9 callersMethodcreate
Returns an immutable default {@link CoherenceConfiguration} instance. <p> This configuration will include the default system session, and any session
prj/coherence-core/src/main/java/com/tangosol/net/CoherenceConfiguration.java:52
↓ 9 callersMethodcreateNestedPofWriter
Obtain a PofWriter that can be used to write a set of properties into a single property of the current user type. The returned PofWriter is only valid
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofWriter.java:1618
↓ 9 callersMethodcreatePartition
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/net/partition/ObservableSplittingBackingCache.java:80
↓ 9 callersMethodcreatePk
(int nId)
prj/test/functional/jpa/src/main/java/orm/AbstractPersistenceTests.java:264
↓ 9 callersMethodcreateResizeTask
(ResizeTaskDaemonPoolStub pool, int cThreads, int cMin, int cMax)
prj/test/functional/core/src/main/java/com/tangosol/coherence/component/util/DaemonPoolIT.java:708
↓ 9 callersMethodcreateResponse
Create an entity response. @param request the {@link HttpRequest} @param parentUri the parent URI which needs to be added to the response @pa
prj/coherence-core/src/main/java/com/tangosol/internal/management/resources/AbstractManagementResource.java:1297
↓ 9 callersMethodcreateSubscriber
(CoherenceClusterMember member, String sId, String sTopic, Subscriber.Option... options)
prj/test/distribution/topics-compatibility/topics-14.1.1.2206.3/src/test/java/topics/TopicSubscriber.java:37
↓ 9 callersMethodcreateWriter
Creates a new ObjectWriter with this Genson instance configuration and default encoding to UTF8.
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/Genson.java:645
↓ 9 callersMethoddisassemble
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/dev/assembler/StackMapTableAttribute.java:62
↓ 9 callersMethoddiscoverFileIds
Discover existing journal file ids in a partition directory. @param dir partition directory @return sorted journal file ids
prj/coherence-core/src/main/java/com/tangosol/io/journal2/JournalUtils.java:93
↓ 9 callersMethoddispatchEvent
(com.tangosol.util.MapEvent event)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/CacheHandler.java:535
↓ 9 callersMethoddistance
(BitSet v1, BitSet v2)
prj/coherence-core/src/main/java/com/oracle/coherence/ai/distance/CosineDistance.java:26
↓ 9 callersMethoddistance
(BitSet v1, BitSet v2)
prj/coherence-core/src/main/java/com/oracle/coherence/ai/distance/InnerProductDistance.java:22
↓ 9 callersMethoddistance
(BitSet v1, BitSet v2)
prj/coherence-core/src/main/java/com/oracle/coherence/ai/distance/L2SquaredDistance.java:22
↓ 9 callersMethoddumpHeap
Collect a heap dump of live objects and write it into a dynamically named file in the temp directory, or <tt>-Dcom.oracle.coherence.common.internal.ut
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/util/HeapDump.java:105
↓ 9 callersMethodenlist
Enlist the resource with the specified transaction. <p> This method is invoked for all resources that are "used" by the transaction immediately before
prj/coherence-core/src/main/java/com/tangosol/util/TransactionMap.java:345
↓ 9 callersMethodensureCache
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/net/DefaultConfigurableCacheFactory.java:307
↓ 9 callersMethodensureInputStream
Return the underlying InputStream. @return the underlying InputStream @throws IllegalStateException if the underlying stream has not been
prj/coherence-core/src/main/java/com/tangosol/io/WrapperInputStream.java:68
↓ 9 callersMethodensureInternalListener
Obtain the internal MapListener, creating one if necessary. @return an instance of MapListener; never null
prj/coherence-core/src/main/java/com/tangosol/util/WrapperObservableMap.java:811
↓ 9 callersMethodensureMapJsonBodyHandler
Load a {@link MapJsonBodyHandler} using the JVM's {@link ServiceLoader} mechanism. @return a {@link MapJsonBodyHandler} loaded via the {@link Service
prj/coherence-core/src/main/java/com/tangosol/net/management/MapJsonBodyHandler.java:86
↓ 9 callersMethodensureMessageSnapshot
Ensure that there is a relatively recent snapshot from the message duration histogram. @return a relatively recent snapshot from the message
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/GrpcProxyMetrics.java:504
↓ 9 callersMethodensureNotNull
Return the specified {@link com.google.protobuf.ByteString} if it is not {@code null} otherwise return {@link com.google.protobuf.ByteString#EMPTY}.
prj/coherence-grpc/src/main/java/com/oracle/coherence/grpc/v0/Requests.java:1177
↓ 9 callersMethodensureRequestSnapshot
Ensure that there is a relatively recent snapshot from the request duration histogram. @return a relatively recent snapshot from the request
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/GrpcProxyMetrics.java:482
↓ 9 callersMethodensureResponse
Return the Response for this Request. <p> If not already available, the Response must be created using the {@link Protocol.MessageFactory} associated
prj/coherence-core/src/main/java/com/tangosol/net/messaging/Request.java:67
↓ 9 callersMethodensureReturnEntry
Ensure that if entry has a {@link #NULL} key or value, return NullableEntry; @param e an entry @return an entry that can contain a null key or null
prj/coherence-core/src/main/java/com/tangosol/util/SafeSortedMap.java:1071
↓ 9 callersMethodensureSubscription
Ensure the specified subscriber is created in a subscription. @param sTopicName the name of the topic @param groupId the {@link SubscriberGr
prj/coherence-core/src/main/java/com/tangosol/net/PagedTopicService.java:42
↓ 9 callersMethodfinalizeResult
Return the final result of the aggregation. @return the final result of the aggregation
prj/coherence-core/src/main/java/com/tangosol/util/InvocableMap.java:966
↓ 9 callersMethodfind
Scan for the argument {@link Annotation} on the argument {@link AccessibleObject}. @param annotation the {@link Annotation} to scan for @param onObje
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/reflect/BeanMutatorAccessorResolver.java:412
↓ 9 callersMethodfinisher
Perform the final transformation from the intermediate accumulation type A to the final result type R. @return a function which transforms the interm
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/Task.java:172
↓ 9 callersMethodfromBinary
Decode a Binary into a ContentKey @param bin the binary @return the ContentKey
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/model/ContentKey.java:159
↓ 9 callersMethodgetActionPolicyBuilder
Return the ActionPolicyBuilder which is a pluggable policy builder that defines certain aspects of a service's behavior at runtime. @return the Actio
prj/coherence-core/src/main/java/com/tangosol/internal/net/service/grid/GridDependencies.java:34
↓ 9 callersMethodgetAggregator
Returns an aggregator instance. @param asArgs aggregator configuration arguments @return an aggregator instance
prj/coherence-rest/src/main/java/com/tangosol/coherence/rest/util/aggregator/AggregatorFactory.java:29
↓ 9 callersMethodgetAll
Get all the specified keys, if they are in the cache. For each key that is in the cache, that key and its corresponding value will be placed in the ma
prj/coherence-core/src/main/java/com/tangosol/net/cache/CacheMap.java:64
↓ 9 callersMethodgetAll
Obtain a stream of mappings of keys to values for all the specified keys. @param request the {@link GetAllRequest} request containing the cache nam
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/NamedCacheService.java:190
↓ 9 callersMethodgetAll
Create a {@link GetAllRequest}. @param scope the scope name to use to obtain the cache from. @param cacheName the name of the cache to clear @p
prj/coherence-grpc/src/main/java/com/oracle/coherence/grpc/v0/Requests.java:492
↓ 9 callersMethodgetAllLocalAddresses
Return a list of all InetAddress objects bound to all the network interfaces on this machine. @return a list of InetAddress objects
prj/coherence-core/src/main/java/com/oracle/coherence/common/net/InetAddresses.java:615
↓ 9 callersMethodgetAnnotations
Reads the {@code attribute} structure processing any {@code RuntimeVisibleAnnotation} or {@code RuntimeInvisibleAnnotation} or method parameter equiva
prj/coherence-core/src/main/java/com/tangosol/dev/introspect/ClassAnnotationScanner.java:198
↓ 9 callersMethodgetArguments
Returns the arguments passed to this class for interpretation and ultimately used by the {@link PofConfigGenerator}. @return the arguments passed to
prj/coherence-core/src/main/java/com/tangosol/io/pof/generator/Executor.java:120
↓ 9 callersMethodgetAttributes
Provides a predictable {@link Iterator} over {@link AttributeMetadata} for the attributes of the type represented by this TypeMetadata. @return Itera
prj/coherence-core/src/main/java/com/tangosol/io/pof/reflect/internal/TypeMetadata.java:51
↓ 9 callersMethodgetBackupOwner
Determine the backup owner of the specified partition. It is possible that during partition re-distribution (e.g. as a result of a failover) that thi
prj/coherence-core/src/main/java/com/tangosol/net/PartitionedService.java:169
↓ 9 callersMethodgetBigDecimal
Return the <tt>BigDecimal</tt> which this PofValue represents. @return the <tt>BigDecimal</tt> value
prj/coherence-core/src/main/java/com/tangosol/io/pof/reflect/PofValue.java:282
↓ 9 callersMethodgetBinaryValue
Getter for property BinaryValue.<p> Binary value.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java:13018
↓ 9 callersMethodgetBody
Returns the notification text. @return the notification text
prj/examples/guides/905-key-association/src/main/java/com/oracle/coherence/guides/notifications/model/Notification.java:51
↓ 9 callersMethodgetBodyLength
Getter for property BodyLength.<p> The length in bytes of this Packet's body.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/packet/MessagePacket.java:469
↓ 9 callersMethodgetBufferOffset
Determine the offset of the specified buffer. The offset of a buffer is the absolute offset of the first byte stored in the buffer. @param iBuffer a
prj/coherence-core/src/main/java/com/tangosol/io/MultiBufferReadBuffer.java:1083
← previousnext →4,001–4,100 of 78,752, ranked by callers