Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/oracle/coherence
/ functions
Functions
78,752 in github.com/oracle/coherence
⨍
Functions
78,752
◇
Types & classes
10,274
↓ 25 callers
Method
registerMiss
()
prj/coherence-core/src/main/java/com/tangosol/net/queue/MutableQueueStatistics.java:32
↓ 25 callers
Method
relaunch
Relaunch the cluster. @param version the version con to use to relaunch
prj/test/distribution/topics-compatibility/topics-14.1.1.2206.3/src/test/java/topics/ClosableCluster.java:166
↓ 25 callers
Method
remoteSemaphore
Return a singleton instance of a {@link RemoteSemaphore} with a specified name and number of permits. @param sName the cluster-wide, unique name of
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/Semaphores.java:37
↓ 25 callers
Method
resetBroadcastCounter
LICENSE WARNING: This method name is obfuscated. Incorporate any additional / updated licenses being contributed by a new member. Called from NewM
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:4534
↓ 25 callers
Method
resetStats
Reset the statistics.
prj/coherence-core/src/main/java/com/tangosol/coherence/http/HttpServerStats.java:59
↓ 25 callers
Method
sendQueueRequest
(StreamObserver<ProxyRequest> channel, TestStreamObserver<ProxyResponse> observer, int queueId, Na
prj/test/functional/grpc-proxy-tck/src/main/java/grpc/proxy/version_1/NamedQueueProxyProtocolIT.java:968
↓ 25 callers
Method
set
Sets the value to {@code newValue}. @param fNewValue the new value
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/atomic/AtomicBoolean.java:45
↓ 25 callers
Method
setPage
Set the subscriber's page within the partition @param lPage the page
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/model/Subscription.java:101
↓ 25 callers
Method
size
()
prj/coherence-core/src/main/java/com/tangosol/net/cache/LocalCache.java:133
↓ 25 callers
Method
testEmpty
Test empty aggregation request results. @param cache the target cache @param agent the agent to run
prj/test/functional/aggregator/src/main/java/aggregator/AbstractEntryAggregatorTests.java:1387
↓ 25 callers
Method
toDecString
Format the passed non-negative integer as a fixed-length decimal string. @param n the value @param cDigits the length of the resulting decima
prj/coherence-core/src/main/java/com/tangosol/util/Base.java:912
↓ 25 callers
Method
value
Return an OrderBy which will compute the unit-of-order based on the {@link #publish sent value}. @param supplierOrderId the function that should be
prj/coherence-core/src/main/java/com/tangosol/net/topic/Publisher.java:567
↓ 25 callers
Method
withConverter
Return a Convert option with the specified extractor. @param extractor the converter extractor @param <V> the type of the elements being recei
prj/coherence-core/src/main/java/com/tangosol/net/topic/Subscriber.java:939
↓ 24 callers
Method
acquire
Acquire a free ByteBuffer. <p> The returned buffer will be at least the requested size. If a larger buffer is returned the limit will have been pre-se
prj/coherence-core/src/main/java/com/oracle/coherence/common/io/BufferManager.java:37
↓ 24 callers
Method
addNull
(String name)
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/ext/jsr353/GensonJsonBuilderFactory.java:76
↓ 24 callers
Method
addSuppressed
(Exception exception, Exception e)
prj/test/performance/benchmarks/src/main/java/com/tangosol/coherence/performance/benchmarks/daemonpool/MultiMemberBenchmarkState.java:664
↓ 24 callers
Method
availablePermits
Returns the current number of permits available in this semaphore. <p>This method is typically used for debugging and testing purposes. @return the
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/RemoteSemaphore.java:395
↓ 24 callers
Method
beginArray
()
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/stream/JsonReader.java:164
↓ 24 callers
Method
byteAt
Returns the byte at the specified offset. An offset ranges from <code>0</code> to <code>length() - 1</code>. The first byte of the sequence is at offs
prj/coherence-core/src/main/java/com/tangosol/io/ReadBuffer.java:55
↓ 24 callers
Method
clear
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/ServiceConfig.java:591
↓ 24 callers
Method
clearAndPopulate
Clear the specified cache and populate it with entries. @param cache the cache to clear and populate @param count the number of entries to add to t
prj/test/functional/grpc-client-tck/src/main/java/grpc/client/AbstractGrpcClientIT.java:2502
↓ 24 callers
Method
close
Close this {@link Coherence} instance.
prj/coherence-core/src/main/java/com/tangosol/net/Coherence.java:1282
↓ 24 callers
Method
configureBlocking
Update the Socket's blocking (and possibly interruptible mode). <p> When set via this method a non-blocking socket will also be made non-interruptible
prj/coherence-core/src/main/java/com/oracle/coherence/common/net/Sockets.java:278
↓ 24 callers
Method
convertKeyDown
Convert the {@link ByteString} data serialized in the request format to a {@link Binary} key serialized in the cache's serialization format. @param b
prj/coherence-grpc/src/main/java/com/oracle/coherence/grpc/v0/CacheRequestHolder.java:136
↓ 24 callers
Method
copyFileTo
(String sourceFileName, File root, String destinationDir, String destinationFilename)
prj/plugins/gradle/src/test/java/com/oracle/coherence/gradle/support/TestUtils.java:72
↓ 24 callers
Method
createByteArray
Create a new Byte array of cSize bytes. The content of the array will initialized to index % 255. @param cSize the number of bytes in the array @re
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/ByteArrayReadBufferTest.java:443
↓ 24 callers
Method
createNamedQueryResource
(NamedCache cache, NamedQuery query, int cMaxResults)
prj/coherence-rest/src/test/java/com/tangosol/coherence/rest/NamedQueryResourceTest.java:482
↓ 24 callers
Method
createReadBuffers
@param cReadBuffers @param cSize
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/MultiBufferReadBufferTest.java:612
↓ 24 callers
Method
delegate
Return the delegate LongArray. @return the delegate
prj/coherence-core/src/main/java/com/tangosol/util/WrapperCollections.java:2563
↓ 24 callers
Method
ensureRuntimeException
Convert the passed exception to a RuntimeException if necessary.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/management/Gateway.java:792
↓ 24 callers
Method
equalsElement
Compare one XML element with another XML element for equality. @param xml1 a non-null XmlElement object @param xml2 a non-null XmlElement object @
prj/coherence-core/src/main/java/com/tangosol/run/xml/XmlHelper.java:3143
↓ 24 callers
Method
evaluate
Return {@code true} if {@code clz} can be accessed via reflection. @param clz class name that is compared against filter's patterns @return {@code
prj/coherence-core/src/main/java/com/tangosol/internal/util/extractor/ReflectionAllowedFilter.java:91
↓ 24 callers
Method
failedFuture
Create a failed {@link CompletableFuture}. @param t the error to use @param <T> the type of the future @return a failed {@link CompletableFuture}
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/BaseGrpcClient.java:316
↓ 24 callers
Method
getAddress
Getter for property Address.<p> The IP address of the member's DatagramSocket for point-to-point communication. This is part of the unique identifier
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/Member.java:1073
↓ 24 callers
Method
getAnnotation
(Class<A> aClass)
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/Wrapper.java:57
↓ 24 callers
Method
getBehavior
Determine the behavior signature that corresponds to the specified method signature. @param sMethodSignature the signature of the Java Class Signatur
prj/coherence-core/src/main/java/com/tangosol/dev/component/Integration.java:1358
↓ 24 callers
Method
getCacheConfig
Obtains {@link CacheConfig} for an {@link ExtensibleConfigurableCacheFactory}. @return the {@link CacheConfig}
prj/coherence-core/src/main/java/com/tangosol/net/ExtensibleConfigurableCacheFactory.java:1350
↓ 24 callers
Method
getCacheId
Getter for property CacheId.<p> Id of the cache this storage represents.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java:3495
↓ 24 callers
Method
getCacheName0
Return the name of a named cache. @return the name of a named cache
prj/test/functional/processor/src/main/java/processor/IndexIntegrityTests.java:1102
↓ 24 callers
Method
getChannel
Returns the gRPC {@link Channel}. <p> This method must not return {@code null}. @return the gRPC {@link Channel}
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/BaseGrpcClient.java:344
↓ 24 callers
Method
getCity
()
prj/test/functional/io/src/main/java/data/Address.java:48
↓ 24 callers
Method
getConverterCache
Getter for property ConverterCache.<p> The client view of the BinaryCache.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/RemoteNamedCache.java:524
↓ 24 callers
Method
getDependencies
Return the dependencies for this channel. @return the dependencies for this channel
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/NamedCacheClientChannel.java:72
↓ 24 callers
Method
getFilter
Obtain a {@link Filter} from the serialized data in a {@link ByteString}. @param bytes the {@link ByteString} containing the serialized {@link
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/NamedCacheService.java:422
↓ 24 callers
Method
getHours
Determine the number of hours in the time interval. @return the number of hours in the time interval
prj/coherence-core/src/main/java/com/tangosol/io/pof/RawTimeInterval.java:49
↓ 24 callers
Method
getInterceptorMap
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/net/events/internal/AbstractEventDispatcher.java:218
↓ 24 callers
Method
getIssuerId
Getter for property IssuerId.<p> Member id of the issuer (registrar) for this Lease. Value of 0 indicates that currently there is no issuer for this L
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/Lease.java:599
↓ 24 callers
Method
getKeyPartitioningStrategy
Determine the strategy for key partitioning that this service has been configured to use. @return the KeyPartitioningStrategy for this service
prj/coherence-core/src/main/java/com/tangosol/net/PartitionedService.java:80
↓ 24 callers
Method
getMappingRegistry
Obtain the cache/topic {@link ResourceMappingRegistry} for the {@link CacheConfig}. @return the cache/topic {@link ResourceMappingRegistry} @since C
prj/coherence-core/src/main/java/com/tangosol/coherence/config/CacheConfig.java:111
↓ 24 callers
Method
getMinutes
Determine the number of minutes in the time interval. @return the number of minutes in the time interval
prj/coherence-core/src/main/java/com/tangosol/io/pof/RawTimeInterval.java:59
↓ 24 callers
Method
getOptions
Getter for property Options.<p>
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/SafeAsyncNamedCache.java:582
↓ 24 callers
Method
getPersistentStore
Return the persistent store for the specified partition. @param nPartition the partition id @return the partition's persistent store, or {@code nul
prj/coherence-core/src/main/java/com/tangosol/internal/util/PartitionedCacheComponent.java:39
↓ 24 callers
Method
getProjectName
{@inheritDoc}
prj/test/functional/persistence/src/main/java/persistence/BerkeleyDBCleanupTests.java:127
↓ 24 callers
Method
getRunnerSet
Return the set of running Runner processes. @return the set of running Runner processes
prj/test/performance/psr/src/main/java/com/tangosol/coherence/performance/psr/Console.java:2688
↓ 24 callers
Method
getService
Getter for property Service.<p>
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:29476
↓ 24 callers
Method
getServiceSchemeRegistry
Obtain the {@link ServiceSchemeRegistry} for the {@link CacheConfig}. @return the {@link ServiceSchemeRegistry}
prj/coherence-core/src/main/java/com/tangosol/coherence/config/CacheConfig.java:209
↓ 24 callers
Method
getSubscriberGroups
Returns the {@link SubscriberGroupId subscriber groups} for a topic known to this service. @return the {@link SubscriberGroupId subscriber groups} fo
prj/coherence-core/src/main/java/com/tangosol/net/TopicService.java:153
↓ 24 callers
Method
getUndecorated
If the passed Binary is decorated, extract the original Binary value that the decorations were added to, otherwise return the passed Binary value. <p>
prj/coherence-core/src/main/java/com/tangosol/util/ExternalizableHelper.java:5332
↓ 24 callers
Method
getVersionId
Determine the version identifier of the user type that is currently being written. @return the integer version ID of the user type; always non-negat
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofWriter.java:1586
↓ 24 callers
Method
get_Publisher
Getter for property _Publisher.<p>
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/management/model/localModel/ClusterNodeModel.java:422
↓ 24 callers
Method
isEmpty
Returns <tt>true</tt> if this map contains no key-value mappings. @return <tt>true</tt> if this map contains no key-value mappings
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/NamedCacheClientChannel.java:394
↓ 24 callers
Method
isOpen
Getter for property Open.<p> True if the Connection is open; false otherwise. @see com.tangosol.net.messaging.Connection#isOpen @volatile
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/Connection.java:1181
↓ 24 callers
Method
isPublic
Determine if the item is public. @return true if the item is public
prj/coherence-core/src/main/java/com/tangosol/dev/compiler/Info.java:44
↓ 24 callers
Method
isSuspended
Returns {@code true} if this service is currently suspended. @return {@code true} if this service is currently suspended @see com.tangosol.net.Cluste
prj/coherence-core/src/main/java/com/tangosol/net/Service.java:143
↓ 24 callers
Method
isWriteLockedByCurrentThread
Queries if the write lock is held by the current thread. @return {@code true} if the current thread holds the write lock and {@code false} otherwise
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/locks/RemoteReadWriteLock.java:1161
↓ 24 callers
Method
newJournal
(long cbMaxFile)
prj/test/unit/coherence-core-tests/src/test/java/com/tangosol/io/journal2/PartitionJournalTest.java:634
↓ 24 callers
Method
newSpan
Constructs a new {@link Span.Builder} for use with the various converter collection types. @param sName the parent span name @param spanParent
prj/coherence-core/src/main/java/com/tangosol/util/ConverterCollections.java:694
↓ 24 callers
Method
nextIndex
Determine the next property index to read from. @return the next property index to read from
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofInputStream.java:578
↓ 24 callers
Method
provider
Extracts the provider component from the model name. <p/> This method returns the part of the model name before the "/" separator, which identifies th
prj/coherence-rag-parent/coherence-rag/src/main/java/com/oracle/coherence/rag/model/ModelName.java:60
↓ 24 callers
Method
readCollection
Read collection content from a DataInput stream and update the specified collection. <p> This method reads elements from the stream and adds them into
prj/coherence-core/src/main/java/com/tangosol/util/ExternalizableHelper.java:2355
↓ 24 callers
Method
realize
(String sName, Session session)
prj/coherence-core/src/main/java/com/tangosol/coherence/config/scheme/NamedQueueScheme.java:33
↓ 24 callers
Method
register
Register a channel with the service. <p> If called for the same channel multiple times, the prior handler will be unregistered and the new handler wil
prj/coherence-core/src/main/java/com/oracle/coherence/common/net/SelectionService.java:45
↓ 24 callers
Method
registerPuts
add Cache Puts of <tt>count</tt> and compute time in cache puts @param count number of cache entry puts @param lStartMillis start time in millisecond
prj/coherence-jcache/src/main/java/com/tangosol/coherence/jcache/common/JCacheStatistics.java:50
↓ 24 callers
Method
registerResource
Registers the resource for later retrieval with {@link #getResource(Class)}. <p> Notes: <ol> <li>Multiple resources for the same class can be registe
prj/coherence-core/src/main/java/com/tangosol/util/ResourceRegistry.java:51
↓ 24 callers
Method
remove
Remove the specified index from the LongArray, returning its associated value. @param lIndex the index into the LongArray @return the associated va
prj/coherence-core/src/main/java/com/tangosol/util/LongArray.java:122
↓ 24 callers
Method
remove
(int nId)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/MemberSet.java:1569
↓ 24 callers
Method
send
(com.tangosol.net.messaging.Message message)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/Channel.java:1823
↓ 24 callers
Method
shutdownNow
Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution. <
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/RemoteExecutor.java:699
↓ 24 callers
Method
startCacheApplication
Start a cache application using the "start.test.application" target in the specified test project's Ant build file. The cache application will use the
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/AbstractTestInfrastructure.java:432
↓ 24 callers
Method
startCluster
()
prj/test/functional/topics/src/main/java/topics/AbstractTopicChannelCountTests.java:84
↓ 24 callers
Method
unregisterEventInterceptor
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/net/events/internal/Registry.java:83
↓ 24 callers
Method
withListener
Create a {@link ChannelOwnershipListeners} option with one or more {@link ChannelOwnershipListener listeners}. @param aListener the {@link ChannelOwn
prj/coherence-core/src/main/java/com/tangosol/net/topic/Subscriber.java:926
↓ 24 callers
Method
withMetricLabels
Set the attribute metric labels. @param asLabel the attribute metric labels @return this builder
prj/coherence-core/src/main/java/com/tangosol/internal/net/management/model/SimpleModelAttribute.java:334
↓ 24 callers
Method
writeCollection
Write collection content to a DataOutput stream. @param out a DataOutput stream to write to @param collection the collection to write @thro
prj/coherence-core/src/main/java/com/tangosol/util/ExternalizableHelper.java:2386
↓ 24 callers
Method
writeObject
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofBufferWriter.java:1739
↓ 23 callers
Method
addFirst
Inserts the specified element at the front of this deque if it is possible to do so immediately without violating capacity restrictions, throwing an {
prj/coherence-core/src/main/java/com/tangosol/net/NamedDeque.java:77
↓ 23 callers
Method
allocate
Allocate and return buffer of the specified size. @param cb the required buffer size @return the buffer @throws OutOfMemoryError if the request ca
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/io/SegmentedBufferManager.java:1090
↓ 23 callers
Method
assertState
Final check to ensure that all expected events have been received.
prj/test/unit/coherence-tests/src/test/java/com/tangosol/util/MapEventFilterTest.java:160
↓ 23 callers
Method
autoDetect
Obtains a {@link WithClassLoader} that auto-detects the {@link ClassLoader} based on the calling context. @return a {@link WithClassLoader}
prj/coherence-core/src/main/java/com/tangosol/net/options/WithClassLoader.java:47
↓ 23 callers
Method
checkEvents
Assert listener events. @param fClient true if ClientListener event should assert true @param fBackingMap true if BackingMapListener event shou
prj/test/functional/cache/src/main/java/cache/MapListenerTests.java:339
↓ 23 callers
Method
checkTracingJMXAttribute
Verify the tracing ratio configuration for the provided cluster member matches the expected value. @param server the {@link MBeanServer} to
prj/test/functional/tracing/common/src/main/java/tracing/AbstractJmxConfigurationIT.java:270
↓ 23 callers
Method
checkTracingStatusOnMember
Verify the result of invoking {@link TracingHelper#isEnabled()} on the specified member returns the expected result. @param member the targe
prj/test/functional/tracing/common/src/main/java/tracing/AbstractJmxConfigurationIT.java:256
↓ 23 callers
Method
clearStatus
Clear any state associated with the specified request status.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/BinaryMap.java:753
↓ 23 callers
Method
create
Create an {@link AnnotationInstance} from an {@link java.lang.annotation.Annotation}. @param instance the {@link java.lang.annotation.Annotation} to
prj/coherence-cdi/src/main/java/com/oracle/coherence/cdi/AnnotationInstance.java:63
↓ 23 callers
Method
createMockContext
()
prj/test/unit/coherence-tests/src/test/java/com/tangosol/net/events/internal/StorageDispatcherTest.java:620
↓ 23 callers
Method
ensureBinaryMap
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/ViewMap.java:804
↓ 23 callers
Method
ensureTypedCache
Ensure a cache for the given name satisfying the specified type assertion. @param sCacheName the cache name @param loader the {@link ClassLoade
prj/coherence-core/src/main/java/com/tangosol/net/CacheProvider.java:58
↓ 23 callers
Method
fireEvent
Fire the specified map event. @param event the map event @param fStrict if true then any RuntimeException thrown by event handler
prj/coherence-core/src/main/java/com/tangosol/util/MapListenerSupport.java:769
↓ 23 callers
Method
fromString
Convert a string representation of a key into its object form. @param sKey key as a string @return key in its object form
prj/coherence-rest/src/main/java/com/tangosol/coherence/rest/KeyConverter.java:27
↓ 23 callers
Method
getAcceptor
Getter for property Acceptor.<p> ConnectionAcceptor used by the ProxyService to accept connections from non-clustered Service clients (Stubs).
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ProxyService.java:601
← previous
next →
1,601–1,700 of 78,752, ranked by callers