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
↓ 6 callers
Method
activate
()
prj/coherence-core/src/main/java/com/tangosol/internal/net/ConfigurableCacheFactorySession.java:265
↓ 6 callers
Method
add
(Object o)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/memberSet/actualMemberSet/serviceMemberSet/MasterMemberSet.java:222
↓ 6 callers
Method
addAll
(Collection c)
prj/coherence-core/src/main/java/com/tangosol/net/internal/SessionLocalBackingMap.java:175
↓ 6 callers
Method
addAnnotation
Add an annotation to this attribute. @param annotation the annotation
prj/coherence-core/src/main/java/com/tangosol/dev/assembler/AbstractAnnotationsAttribute.java:184
↓ 6 callers
Method
addAttribute
Add an {@link AttributeMetadata} instance that is a child of the {@link ClassMetadata} instance. @see ClassMetadata#addAttribute(AttributeMetadata)
prj/coherence-core/src/main/java/com/tangosol/io/pof/reflect/internal/ClassMetadataBuilder.java:79
↓ 6 callers
Method
addAuthorizedHostsToFilter
Add an authorized host range to the filter. @param sAddrFrom from address @param sAddrTo to address
prj/coherence-core/src/main/java/com/tangosol/coherence/config/builder/InetAddressRangeFilterBuilder.java:67
↓ 6 callers
Method
addChild
Add a child Node. <p> Note that this operation may cause this Node to be replaced with another Node instance. @param node the child Node to add @re
prj/coherence-core/src/main/java/com/tangosol/util/BinaryRadixTree.java:954
↓ 6 callers
Method
addDefaultResponseHeader
Add a default response headers to send for all responses. @param sKey the name of the header @param sValue the value for the header
prj/coherence-core/src/main/java/com/tangosol/internal/http/RequestRouter.java:90
↓ 6 callers
Method
addIndex
Add an index to a cache. @param request the {@link AddIndexRequest} containing the name of the cache to add the index to, the seri
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/NamedCacheService.java:89
↓ 6 callers
Method
addMapListener
(MapListener<? super K, ? super V> mapListener)
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/NamedCacheClient.java:97
↓ 6 callers
Method
addProvider
Add an AddressProvider. @param provider the AddressProvider to add
prj/coherence-core/src/main/java/com/tangosol/net/CompositeAddressProvider.java:71
↓ 6 callers
Method
addPut
Add a PUT endpoint. @param sPath the request path @param handler the PUT request handler @return the added {@link Endpoint}
prj/coherence-core/src/main/java/com/tangosol/internal/http/RequestRouter.java:166
↓ 6 callers
Method
addStateListener
Add a {@link StateListener state change listener}. @param listener the {@link StateListener listener} to add
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/NamedTopicSubscriber.java:1800
↓ 6 callers
Method
adjustBacklog
Adjust the backlog by the specified amount and evaluate the backlog. @param c the amount to adjust by @return this object
prj/coherence-core/src/main/java/com/tangosol/internal/net/DebouncedFlowControl.java:69
↓ 6 callers
Method
adjustWaitTime
Adjust the wait interval/time according to the original wait interval and the time adjustment value. @param cWaitMillis the wait interval; zero means
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/Grid.java:689
↓ 6 callers
Method
advance
Advance past the end of the current underlying BufferOutput by switching to the BufferOutput of the next underlying WriteBuffer, creating one if neces
prj/coherence-core/src/main/java/com/tangosol/io/MultiBufferWriteBuffer.java:884
↓ 6 callers
Method
advance
Once the current buffer is full, allocate a new one and make it the current buffer. @return the new WriteBuffer object
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/OldMultiBufferWriteBuffer.java:885
↓ 6 callers
Method
aggregate
(Collection<? extends K> keys, EntryAggregator<? super K, ? super V, R> aggregator)
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/NamedCacheClient.java:119
↓ 6 callers
Method
aliasFor
Searches if an alias has been registered for clazz or package. If not, it will take the class full name and use it as alias. This method never returns
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/Genson.java:556
↓ 6 callers
Method
alter
()
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/pof/PofDeltaCompressorTest.java:1139
↓ 6 callers
Method
analyzer
Sets the supplier of Lucene Analyzer to use for this index. The supplier must be serializable and will be used to create Analyzer instances on each st
prj/coherence-lucene/src/main/java/com/oracle/coherence/lucene/LuceneIndex.java:149
↓ 6 callers
Method
appendTag
Append specified tag to the buffer. @param sb the buffer to append tag to @param tagName the name of the tag to append @param tagValue the
prj/coherence-mp/metrics/src/main/java/com/oracle/coherence/mp/metrics/CoherenceTagsConfigSource.java:124
↓ 6 callers
Method
asStream
(String sValue)
prj/test/functional/core/src/main/java/com/tangosol/net/URLMemberIdentityProviderTests.java:383
↓ 6 callers
Method
assertActive
Assert that this {@link AsyncNamedCacheClient} is active. @throws IllegalStateException if this {@link AsyncNamedCacheClient}
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/AsyncNamedCacheClient.java:1052
↓ 6 callers
Method
assertCanCreateKeys
Assert that openssl and Java keytool can be used to create test keys and certs. @throws org.opentest4j.TestAbortedException if the check fails
prj/examples/guides/210-ssl/src/test/java/com/oracle/coherence/guides/ssl/KeyTool.java:47
↓ 6 callers
Method
assertComparePrimitives
(Primitives p1, Primitives p2)
prj/coherence-json/src/test/java/com/oracle/coherence/io/json/genson/bean/Primitives.java:43
↓ 6 callers
Method
assertConfig
Assert that the given service uses the specified environment implementation, persistence mode, active failure mode, and optional archiver implementati
prj/test/functional/persistence/src/main/java/persistence/AbstractConfigurationPersistenceTests.java:375
↓ 6 callers
Method
assertEqual
Assert that a class is equal to another class. @param clz the expected class; must not be null @param clzTest the class to test for equality; m
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofBufferWriter.java:2716
↓ 6 callers
Method
assertGetAll
(NamedCache<K, String> cache, String sSerializerName, Serializer serializer, Collection<K> keys)
prj/test/functional/grpc-client-tck/src/main/java/grpc/client/AbstractGrpcClientIT.java:532
↓ 6 callers
Method
atomics
Return Coherence {@link Session} for the atomics module. @return Coherence {@link Session} for the atomics module
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/atomic/Atomics.java:551
↓ 6 callers
Method
beginCollection
Report that a collection of values has been encountered in the POF stream. <p> This method call will be followed by a separate call to an "on" or "beg
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofHandler.java:429
↓ 6 callers
Method
beginKeyProcess
Block until a key is available for processing, and return the Status object for that key. The caller is then expected to perform its processing, durin
prj/coherence-core/src/main/java/com/tangosol/net/cache/SimpleOverflowMap.java:1204
↓ 6 callers
Method
beginUserType
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/pof/DuplexingPofHandler.java:382
↓ 6 callers
Method
bindTo
(@NonNull MeterRegistry registry)
prj/coherence-micrometer/src/main/java/com/oracle/coherence/micrometer/CoherenceMicrometerMetrics.java:62
↓ 6 callers
Method
buildExtractors
()
prj/coherence-core/src/main/java/com/tangosol/coherence/reporter/locator/DeltaLocator.java:127
↓ 6 callers
Method
builder
Create a {@link SimpleModelAttribute} {@link Builder}. @param sName the attribute name @param type the attribute type @param <M> the model type
prj/coherence-core/src/main/java/com/tangosol/internal/net/management/model/SimpleModelAttribute.java:168
↓ 6 callers
Method
calcUnitFairShare
Return the fair share of units for each child maps. The units provided would typically be either the high or low units allowed for all maps under this
prj/coherence-core/src/main/java/com/tangosol/net/partition/ObservableSplittingBackingCache.java:870
↓ 6 callers
Method
calculateExpiry
Utility method to calculate expiry value. As per the spec: <p> The actual value sent may either be Unix time (number of seconds since January 1, 1970,
prj/coherence-core/src/main/java/com/tangosol/coherence/memcached/server/MemcachedHelper.java:50
↓ 6 callers
Method
calculateOwnership
Calculate the partition ownership distribution for the specified MemberSet. @param setOwners the set of ownership-enabled service members @param fPr
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:1225
↓ 6 callers
Method
calculateUnits
Calculate a cache cost for the specified cache entry key and value. @param oKey the cache key to evaluate for unit cost @param oValue the cache v
prj/test/unit/coherence-tests/src/test/java/com/tangosol/net/cache/OldOldCache.java:2199
↓ 6 callers
Method
cancel
Attempts to cancel execution of the {@link Task}. This attempt will fail if the task has already completed, has already been cancelled, or could not b
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/Task.java:357
↓ 6 callers
Method
castProcessor
Cast an {@link EntryProcessor} to an {@link EntryProcessor} that returns a {@link Binary} result. @param ep the {@link EntryProcessor} to cast @ret
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/BaseNamedCacheServiceImpl.java:581
↓ 6 callers
Method
check
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/util/NullImplementation.java:1051
↓ 6 callers
Method
checkCacheStatusHA
Helper function to check if the statusHA is the same as the expected status @param sService the service name that is tried to get the statusHA fr
prj/test/functional/jmx/src/main/java/jmx/JmxTests.java:1489
↓ 6 callers
Method
checkEvict
(Object oKey, boolean fBefore)
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/rwbm/EvictingRWBM.java:107
↓ 6 callers
Method
checkFlush
Check if the cache is timed out, and clear if it is.
prj/test/unit/coherence-tests/src/test/java/com/tangosol/net/cache/OldOldCache.java:1608
↓ 6 callers
Method
checkMutable
Verify that this entry is mutable.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java:12773
↓ 6 callers
Method
checkNodeGuardTimeout
Check the whether the timeout number in JMX is correct. @param cluster the current cluster @param server the MBean server @param sType
prj/test/functional/guardian/src/main/java/guardian/GuardianTests.java:955
↓ 6 callers
Method
checkTimeZone
Check the specified timezone offset. @param nHourOffset the hour offset @param nMinuteOffset the minute offset
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofHelper.java:1833
↓ 6 callers
Method
cleanup
()
prj/test/functional/cache/src/main/java/cache/EvictionTests.java:84
↓ 6 callers
Method
clear
()
prj/test/functional/grpc-proxy-tck/src/main/java/grpc/proxy/TestCacheStore.java:43
↓ 6 callers
Method
clearAndPopulateAssociated
Clear the specified cache and populate it with entries. @param cache the cache to clear and populate @param sAssociated the associated key @p
prj/test/functional/grpc-client-tck/src/main/java/grpc/client/AbstractGrpcClientIT.java:2518
↓ 6 callers
Method
clearAndPopulatePartition
Clear the specified cache and populate it with entries. @param cache the cache to clear and populate @param nPart the partition id @param count th
prj/test/functional/grpc-client-tck/src/main/java/grpc/client/AbstractGrpcClientIT.java:2536
↓ 6 callers
Method
clearMap
Clear the named static map field. @param clz the type declaring the field @param sFieldName the field name @throws Exception if the map can
prj/test/functional/concurrent/src/main/java/concurrent/ConcurrentHelper.java:117
↓ 6 callers
Method
clone
Make a new string table with a copy of the tree and a copy of the collator.
prj/coherence-core/src/main/java/com/tangosol/util/StringTable.java:490
↓ 6 callers
Method
cloneValue
Clone the TestValue. @return a new TestValue
prj/test/functional/processor/src/main/java/processor/AbstractEntryProcessorTests.java:3118
↓ 6 callers
Method
close
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/persistence/AbstractPersistenceManager.java:170
↓ 6 callers
Method
closeChannel
Close the specified channel @param chan the channel to close
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/socketbus/AbstractSocketBus.java:626
↓ 6 callers
Method
closeEntry
Close the current application entry. @exception IOException if an I/O error has occurred
prj/coherence-core/src/main/java/com/tangosol/engarde/ApplicationWriter.java:72
↓ 6 callers
Method
closeInbound
Close the inbound {@link SocketChannel channel}. @param status the {@link TcpDatagramSocket.Impl.ConnectionStatus ConnectionStatus} c
prj/coherence-core/src/main/java/com/tangosol/net/TcpDatagramSocket.java:1337
↓ 6 callers
Method
closeQuietly
(Object o)
prj/examples/tutorials/210-archiver/src/main/java/com/oracle/coherence/tutorials/archiver/SFTPSnapshotArchiver.java:551
↓ 6 callers
Method
collectContaining
Returns a list of log messages collected containing string. @return a list of log messages collected
prj/test/functional/logging/src/main/java/logging/UnavailableTimeTests.java:258
↓ 6 callers
Method
collectToBag
(RemotePipeline<IntStream> pipeline)
prj/coherence-core/src/main/java/com/tangosol/internal/util/stream/IntPipeline.java:315
↓ 6 callers
Method
collectToBag
(RemotePipeline<DoubleStream> pipeline)
prj/coherence-core/src/main/java/com/tangosol/internal/util/stream/DoublePipeline.java:305
↓ 6 callers
Method
collectToBag
(RemotePipeline<LongStream> pipeline)
prj/coherence-core/src/main/java/com/tangosol/internal/util/stream/LongPipeline.java:312
↓ 6 callers
Method
complete
Complete the future with a value. @param future the {@link CompletableFuture} to complete @param oValue the value to use to complete the fu
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/BatchingOperationsQueue.java:1111
↓ 6 callers
Method
completeElements
Complete the first n {@link Element Elements} in the current batch. @param cComplete the number of {@link Element}s to complete @param aValues
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/BatchingOperationsQueue.java:568
↓ 6 callers
Method
computeValueExtractorCanonicalName
Compute the canonical name for a ValueExtractor. <p> Canonical name is null when one or more optional method parameters are provided. If <code>sName</
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/util/CanonicalNames.java:37
↓ 6 callers
Method
configureRun
(DaemonPool.ResizeTask resizeTask, ResizeTaskDaemonPoolStub pool, int cThreads, long cTasksLast, l
prj/test/functional/core/src/main/java/com/tangosol/coherence/component/util/DaemonPoolIT.java:720
↓ 6 callers
Method
connect
Connect a socket while still respecting the calling thread's {@link Timeout timeout}. @param socket the socket to connect @param addr the address
prj/coherence-core/src/main/java/com/oracle/coherence/common/base/Blocking.java:299
↓ 6 callers
Method
connect
Create a connection to the server.
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/GrpcConnection.java:37
↓ 6 callers
Method
consumeStore
Load the given keys from the given store. @param store the store to load from @param abKeys the keys to load
prj/test/unit/coherence-core-tests/src/test/java/com/tangosol/persistence/AbstractPersistencePerformanceTest.java:481
↓ 6 callers
Method
containsKey
(Object oKey)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/CacheHandler.java:496
↓ 6 callers
Method
convertArgument
(String sParam)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/application/console/Coherence.java:814
↓ 6 callers
Method
convertToDataHolder
Utility method to extract value and decorations from a decorated binary. @param bin the decorated binary @param mgrCtx the bac
prj/coherence-core/src/main/java/com/tangosol/coherence/memcached/server/MemcachedHelper.java:91
↓ 6 callers
Method
copyArray
Return a shallow copy of the specified LongArray. @param array the array to be copied @return a shallow copy of the specified LongArray
prj/coherence-core/src/main/java/com/tangosol/util/CopyOnWriteLongArray.java:120
↓ 6 callers
Method
copyFrom
Copy this Entry's information from another Entry. Sub-classes must implement this method if they add any additional fields. @param entry the entry t
prj/coherence-core/src/main/java/com/tangosol/util/SafeHashMap.java:1194
↓ 6 callers
Method
couldNotInstantiateBeanView
(Class<?> beanViewClass, Exception e)
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/reflect/BeanViewDescriptorProvider.java:104
↓ 6 callers
Method
count
Return the count of the results. @return the count of the results
prj/coherence-hnsw/src/main/java/com/oracle/coherence/hnswlib/QueryTuple.java:97
↓ 6 callers
Function
cpuid
prj/coherence-hnsw/src/main/cpp/hnswlib/hnswlib.h:46
↓ 6 callers
Method
create
Return the default {@link Coherence} instance, creating it if it does not already exist. @return a default {@link Coherence} instance
prj/coherence-core/src/main/java/com/tangosol/net/Coherence.java:157
↓ 6 callers
Method
create
Creates a populated instance of a TestValue class to be used in tests. @param fRefEnabled a flag to indicate if POF references are enabled @return
prj/coherence-testing-data/src/main/java/data/pof/TestValue.java:92
↓ 6 callers
Method
create
Creates an embedding model with automatic download if needed. @param name the model name to create @return the configured embedding model
prj/coherence-rag-parent/coherence-rag/src/main/java/com/oracle/coherence/rag/model/LocalOnnxEmbeddingModel.java:133
↓ 6 callers
Method
createChannel
Create a new instance of a {@link Channel}. @return a new instance of a {@link Channel}
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/Connection.java:315
↓ 6 callers
Method
createDefault
Creates a default embedding model from the classpath. @param name the model name to create @return the configured embedding model
prj/coherence-rag-parent/coherence-rag/src/main/java/com/oracle/coherence/rag/model/LocalOnnxEmbeddingModel.java:116
↓ 6 callers
Method
createKey
Create a key for the specified string. @param sKey the string to create a key for @return an orderable key
prj/coherence-core/src/main/java/com/tangosol/util/StringTable.java:301
↓ 6 callers
Method
createKeyCertPair
Create a self-signed private key and cert. @param fileParent the build target directory below which the key and cert directory will be created @p
prj/examples/guides/810-custom-access-controller/src/test/java/com/oracle/coherence/guides/security/KeyTool.java:203
↓ 6 callers
Method
createNull
Create new AtomicTerm representing a null with given value @param value the text of the literal @return a AtomicTerm for a null
prj/coherence-core/src/main/java/com/tangosol/coherence/dsltools/termtrees/AtomicTerm.java:436
↓ 6 callers
Method
createSnapshotArchiver
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/persistence/ConfigurableSnapshotArchiverFactory.java:35
↓ 6 callers
Method
createSubscriber
(NamedTopic<V> topic, Subscriber.Option... options)
prj/test/functional/grpc-client-netty/src/main/java/netty/grpc/client/topics/SimpleSubscriber.java:117
↓ 6 callers
Method
currentNode
Returns the current Node in the iteration. @return the current Node in the iteration @exception IllegalStateException if the <tt>next</tt> method ha
prj/coherence-core/src/main/java/com/tangosol/util/AbstractSparseArray.java:1582
↓ 6 callers
Method
deactivate
Shut down the Iterator. This is done on exhaustion of the contents of the Iterator, or on finalization of the Iterator.
prj/coherence-core/src/main/java/com/tangosol/util/SafeHashMap.java:1624
↓ 6 callers
Method
decodeCookie
Decode the binary cookie used in a paged request. @param service the cache {@link Service} to use to deserialize the cookie @param cookie the cook
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/PagedQueryHelper.java:371
↓ 6 callers
Method
decrypt
Decrypt the specified SignedObject using the public credentials for a given encryptor Subject in a context represented by the decryptor Subject which
prj/coherence-core/src/main/java/com/tangosol/net/security/AccessController.java:98
↓ 6 callers
Method
define
Defines the {@link Properties} for the {@link Task}. @param sName the name of the property @param value the value of the property @param <V> the
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/Task.java:532
↓ 6 callers
Method
deleteSnapshot
Delete the given snapshot. @param sSnapshotName snapshot to delete
prj/test/functional/management/src/main/java/management/BaseManagementInfoResourceTests.java:4286
↓ 6 callers
Method
deniedModel
Return the denied model selector, when applicable. @return the bounded model selector, or {@code null}
prj/coherence-rag-parent/coherence-rag/src/main/java/com/oracle/coherence/rag/api/RagSecurity.java:979
↓ 6 callers
Method
deque
Return a {@link NamedBlockingDeque}. <p/> The queue implementation returned by this method has a maximum size of 2GB. If the queue reaches capacity it
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/Queues.java:67
↓ 6 callers
Method
deserialize
(ReadBuffer.BufferInput in, Class<? extends T> clazz)
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/JsonSerializer.java:279
↓ 6 callers
Method
destroy
Destroy a cache. @param request the {@link DestroyRequest} containing the name of the cache to destroy @param observer the {@link StreamObserver} t
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/NamedCacheService.java:148
← previous
next →
5,701–5,800 of 78,752, ranked by callers