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 callersMethod__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:20905
↓ 3 callersMethod__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/replicatedCache/Optimistic.java:153
↓ 3 callersMethod__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/PagedTopic.java:5500
↓ 3 callersMethod__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/PagedTopic.java:6862
↓ 3 callersMethod__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/packetProcessor/PacketSpeaker.java:1639
↓ 3 callersMethod__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/packetProcessor/PacketPublisher.java:4176
↓ 3 callersMethod_addNotificationListener
Add the Notification listener to the model. @return the LocalHolder representing the listener/filter/handback tuple or null if such a registration al
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/management/model/RemoteModel.java:353
↓ 3 callersMethod_handleNotification
Process the Notification for this model.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/management/model/LocalModel.java:192
↓ 3 callersMethod_makeArray
Make an array of a given number of Long elements @param c the number of elements @return the list
prj/test/unit/coherence-tests/src/test/java/com/tangosol/util/ImmutableArrayListTest.java:82
↓ 3 callersMethod_makeList
(Long[] aL)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/util/ImmutableArrayListTest.java:70
↓ 3 callersMethod_shutdown
()
prj/test/functional/partition/src/main/java/partition/DeltaCompressorTests.java:65
↓ 3 callersMethod_startup
Startup the test specifying a cache name. @param cache cache name @throws SQLException if any SQL errors
prj/examples/guides/190-cache-stores/src/test/java/com/oracle/coherence/guides/cachestores/AbstractHSqlDbCacheStoreTest.java:57
↓ 3 callersMethod_test
Run a variety of tests of the following methods on a new ImmutableArrayList of the specified size: <ul> <li>{@link ImmutableArrayList#size}</li> <
prj/test/unit/coherence-tests/src/test/java/com/tangosol/util/ImmutableArrayListTest.java:110
↓ 3 callersMethodaccept
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/net/ConfigurableAddressProvider.java:190
↓ 3 callersMethodaccept
Accept the chanel and queue it to the appropriate MultiplexedServerSocketChannel @throws IOException if an I/O error occurs
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/MultiplexedSocketProvider.java:2644
↓ 3 callersMethodaccept
Performs this operation on the given arguments. @param t the first input argument @param u the second input argument
prj/coherence-discovery/src/main/java/com/tangosol/discovery/NSLookup.java:1259
↓ 3 callersMethodacceptBinaryOperator
(String sOperator, Term termLeft, Term termRight)
prj/coherence-core/src/main/java/com/tangosol/coherence/dslquery/internal/UpdateSetListMaker.java:370
↓ 3 callersMethodacceptIdentifier
The receiver has classified an identifier node. @param sIdentifier the String representing the identifier
prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/dslquery/internal/AbstractCoherenceQueryWalkerTest.java:465
↓ 3 callersMethodaccessInternalValue
Access value @param ldtAccess the time when the value was accessed @param policy the expiry policy
prj/coherence-jcache/src/main/java/com/tangosol/coherence/jcache/localcache/LocalCacheValue.java:222
↓ 3 callersMethodactivate
Activate prepares the factory to be used within a container and should be called before any other factory method. @since Coherence 12.1.2
prj/coherence-core/src/main/java/com/tangosol/net/ConfigurableCacheFactory.java:36
↓ 3 callersMethodadapt
(String str)
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/convert/DefaultConverters.java:742
↓ 3 callersMethodadd
(Internal) Add a constant to the constant pool. @param constant the constant to add top the pool
prj/coherence-core/src/main/java/com/tangosol/dev/assembler/ConstantPool.java:373
↓ 3 callersMethodadd
Add an Object to the WindowedArray and return the index of the new element. @param o the Object to add to the end of the WindowedArray @return the
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/WindowedArray.java:240
↓ 3 callersMethodaddAddress
Add an address. @param address the address to add
prj/coherence-core/src/main/java/com/tangosol/net/CompositeAddressProvider.java:81
↓ 3 callersMethodaddAll
Adds all of the elements in the specified Collection to this Set if they are not already present. If the specified Collection is also a Set, the <tt>a
prj/coherence-core/src/main/java/com/tangosol/util/LiteSet.java:562
↓ 3 callersMethodaddAll
(java.util.Collection collection)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/memberSet/EmptyMemberSet.java:153
↓ 3 callersMethodaddArgToResultsMap
Add the provided argument and its value to the results map inflating the value to be a List of values if the map already contains the argument. @para
prj/coherence-core/src/main/java/com/tangosol/dev/tools/CommandLineTool.java:232
↓ 3 callersMethodaddAttribute
Add a Java .class attribute structure. @param sName the attribute name @return the new attribute
prj/coherence-core/src/main/java/com/tangosol/dev/assembler/ClassFile.java:1621
↓ 3 callersMethodaddAttribute
Add a Java .class attribute structure. @param sName the attribute name @return the new attribute
prj/coherence-core/src/main/java/com/tangosol/dev/assembler/Field.java:727
↓ 3 callersMethodaddAuthorizedHostsToFilter
Add an authorized host range to the filter. @param sAddrFrom from address @param sAddrTo to address @return true if filter added
prj/coherence-core/src/main/java/com/tangosol/internal/net/cluster/LegacyXmlClusterDependencies.java:896
↓ 3 callersMethodaddBuffer
Once the current buffer is full, allocate a new one and make it the current buffer. @return the new WriteBuffer object
prj/coherence-core/src/main/java/com/tangosol/io/MultiBufferWriteBuffer.java:1117
↓ 3 callersMethodaddConfig
Add the BundleConfig to the list of bundle configurations. @param config the BundleConfig
prj/coherence-core/src/main/java/com/tangosol/coherence/config/scheme/BundleManager.java:42
↓ 3 callersMethodaddConnectionListener
Register a ConnectionListener that will receive events pertaining to the Connection objects managed by this ConnectionManager. @param listener the n
prj/coherence-core/src/main/java/com/tangosol/net/messaging/ConnectionManager.java:177
↓ 3 callersMethodaddConnectionListener
Add a {@link ConnectionListener}. @param listener the {@link ConnectionListener} to add
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/GrpcConnection.java:152
↓ 3 callersMethodaddHead
Schedules a packet for early departure by placeing it in the queue based on its pre-configured send time. The added packet will not be allowed to cut
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/packetProcessor/PacketPublisher.java:3779
↓ 3 callersMethodaddHeaders
Add headers to the response. @param headers the map of headers to add
prj/coherence-core/src/main/java/com/tangosol/internal/http/HttpResponse.java:163
↓ 3 callersMethodaddIndex
Add an index to the given map of indexes, keyed by the given extractor. Also add the index as a listener to the given ObservableMap. @param extractor
prj/coherence-core/src/main/java/com/tangosol/util/InvocableMapHelper.java:806
↓ 3 callersMethodaddLifecycleListener
Add a {@link LifecycleListener} that will be notified of lifecycle events for this {@link DefaultCacheServer}. @param listener the listener to add
prj/coherence-core/src/main/java/com/tangosol/net/DefaultCacheServer.java:78
↓ 3 callersMethodaddMapListener
(com.tangosol.util.MapListener listener)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/ConcurrentMap.java:165
↓ 3 callersMethodaddParentResourceLink
Add the URI as the parent link of the resource. @param uri the URI of the parent resource
prj/coherence-core/src/main/java/com/tangosol/internal/management/MBeanResponse.java:147
↓ 3 callersMethodaddPartitionListener
Add a PartitionListener to this service. @param listener the listener to add @since Coherence 3.7
prj/coherence-core/src/main/java/com/tangosol/net/PartitionedService.java:231
↓ 3 callersMethodaddPropertyToItem
(Map<String, Object> map, Filter<String> filter,
prj/coherence-core/src/main/java/com/tangosol/internal/management/VersionUtils.java:75
↓ 3 callersMethodaddQueuedElements
Offer the batched elements from this channel. @param cbMaxElements the maximum number of bytes to offer
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/NamedTopicPublisherChannel.java:283
↓ 3 callersMethodaddServiceListener
(com.tangosol.util.ServiceListener l)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/Service.java:350
↓ 3 callersMethodaddSessionIfAbsent
Add a {@link SessionConfiguration session} to this {@link Coherence} instance, iff a session configuration is not already present in this {@link Coher
prj/coherence-core/src/main/java/com/tangosol/net/Coherence.java:953
↓ 3 callersMethodaddType
Add specified event type to a set of types this interceptor should handle. @param type the event type to add
prj/coherence-cdi/src/main/java/com/oracle/coherence/cdi/events/AnnotatedMapListener.java:323
↓ 3 callersMethodaddUnlockAction
Add a continuation action to be run immediately prior to unlocking this partition. The action will be run by the thread that holds the partition lock
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:21667
↓ 3 callersMethodadjustIndirectStorageSize
Adjust the non-PartitionAwareBackingMap storage size of the partition by the specified amount. @param cbDelta the amount to adjust the size (could b
prj/coherence-core/src/main/java/com/tangosol/net/partition/PartitionStatistics.java:99
↓ 3 callersMethodadjustReferenceCount
Adjust the pages reference count @param c the amount to adjust by @return the new count
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/model/Page.java:324
↓ 3 callersMethodadjustUnits
Adjust the number of units for each map with the pool of units provided. The units provided is a total across all maps with the adjustment per map bei
prj/coherence-core/src/main/java/com/tangosol/net/partition/ObservableSplittingBackingCache.java:663
↓ 3 callersMethodadjustWaitTime
Calculate the time remaining from the total time allotted for an operation. @param cMillis the total time allotted for an operation @param ldtStart
prj/coherence-core/src/main/java/com/tangosol/util/ThreadGateLite.java:345
↓ 3 callersMethodadults
()
prj/test/unit/coherence-core-tests/src/test/java/com/tangosol/internal/util/PartitionedIndexMapTest.java:510
↓ 3 callersMethodafterAll
(ExtensionContext context)
prj/test/functional/grpc-client-tck/src/main/java/grpc/client/ServerHelper.java:92
↓ 3 callersMethodaggregate
(com.tangosol.util.Filter filter, com.tangosol.util.Binary binAgent, com.tangosol.net.partition.PartitionSet p
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/BinaryMap.java:463
↓ 3 callersMethodaliases
()
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/reflect/BeanProperty.java:87
↓ 3 callersMethodalign16
Return the supplied offset rounded up to 16-byte alignment. @param lOffset offset to align @return aligned offset
prj/coherence-core/src/main/java/com/tangosol/io/journal2/PartitionJournal.java:1239
↓ 3 callersMethodallocate
Allocate this free block (or at least a specified number of bytes of this block) as an Entry block. Note that the block is an Entry in an unlinked sta
prj/coherence-core/src/main/java/com/tangosol/io/nio/BinaryMap.java:4612
↓ 3 callersMethodalways
Obtains a {@link Predicate} that always succeeds. @param <T> the type of value @return a {@link Predicate}
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/function/Predicates.java:47
↓ 3 callersMethodanthropicBaseUrl
Returns the Anthropic base URL from configuration. @return the base URL for Anthropic service, defaults to https://api.anthropic.com/v1/
prj/coherence-rag-parent/models/coherence-rag-anthropic/src/main/java/com/oracle/coherence/rag/model/anthropic/AnthropicModelProvider.java:155
↓ 3 callersMethodappendInternal
Shared append implementation used by both append paths. Keeps the MPSC appendPrepared path aligned with the legacy append path for receipts, markers,
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/socketbus/BufferedSocketBus.java:1947
↓ 3 callersMethodapply
(CoherenceClusterMember member, SubscriberId id, Remote.Function<Subscriber<V>, R> function)
prj/test/functional/topics/src/main/java/topics/callables/CreateSubscriber.java:59
↓ 3 callersMethodapplyBatch
Apply a sequence of queued extent operations while holding the extent write lock only once. @param listOps operations to apply @throws IOException
prj/coherence-core/src/main/java/com/tangosol/persistence/journal/JournalPersistenceManager.java:2155
↓ 3 callersMethodapplyIndex
(Map mapIndexes, Set setKeys, QueryContext ctx, QueryRecord.PartialResult.T
prj/coherence-core/src/main/java/com/tangosol/util/filter/AllFilter.java:137
↓ 3 callersMethodapplyIndex
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/util/filter/LessFilter.java:145
↓ 3 callersMethodapplyIndex
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/util/filter/AnyFilter.java:152
↓ 3 callersMethodapplyIndex
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/util/filter/GreaterFilter.java:144
↓ 3 callersMethodarchivedSnapshotExists
Validate that an archived snapshot exists for a given service. @param sServiceName the service name to check @param sSnapshotName the archived snaps
prj/coherence-core/src/main/java/com/tangosol/coherence/dslquery/internal/PersistenceToolsHelper.java:269
↓ 3 callersMethodarmDrainReconciliationBlock
()
prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/component/util/VirtualDaemonPoolComponentTest.java:1689
↓ 3 callersMethodarrayEquals
(Object ao1, Object ao2)
prj/test/functional/io/src/main/java/io/ObjectInputFilterTests.java:878
↓ 3 callersMethodasLongStream
Returns a {@code LongStream} consisting of the elements of this stream, converted to {@code long}. <p> This is an <em>intermediate operation</em>. @r
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteIntStream.java:833
↓ 3 callersMethodassertBackupMap
(Map mapSrc)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/util/MapBackupHelperTest.java:63
↓ 3 callersMethodassertCacheName
(String sName, ExecutionContext context)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/dslquery/statement/UpdateStatementBuilderTest.java:177
↓ 3 callersMethodassertCauseMessage
(Throwable throwable, Matcher<String> matcher)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/config/xml/processor/PasswordProviderProcessorTest.java:999
↓ 3 callersMethodassertCloneEquals
Assert that the two ServiceDependencies are equal. @param deps1 the first ServiceDependencies object @param deps2 the second ServiceDependencies ob
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/service/ServiceDependenciesTest.java:198
↓ 3 callersMethodassertCloneEquals
Assert that the two AbstractAcceptorDependencies are equal. @param deps1 the first AbstractAcceptorDependencies object @param deps2 the second Abst
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/service/peer/acceptor/AcceptorDependenciesTest.java:74
↓ 3 callersMethodassertCloneEquals
Assert that the two RemoteServiceDependencies are equal. @param deps1 the first RemoteServiceDependencies object @param deps2 the second RemoteServ
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/service/extend/remote/RemoteServiceDependenciesTest.java:82
↓ 3 callersMethodassertCloneEquals
Assert that the two ServiceProxyDependencies are equal. @param deps1 the first ServiceProxyDependencies object @param deps2 the second ServiceProxy
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/service/extend/proxy/ServiceProxyDependenciesTest.java:52
↓ 3 callersMethodassertCloneEquals
Assert that the two ClusterDependencies are equal. @param deps1 the first ClusterDependencies object @param deps2 the second ClusterDependencies ob
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/cluster/DefaultClusterDependenciesTest.java:291
↓ 3 callersMethodassertClusterSize
Assert that the cluster size metric is 2. @param cache the NamedCache to compare the size of
prj/test/functional/metrics/src/main/java/metrics/AbstractMetricsTests.java:125
↓ 3 callersMethodassertDeleteEvent
Assert that the client received the listener event @param fExpected true if client event expected
prj/test/functional/cache/src/main/java/cache/EvictionTests.java:338
↓ 3 callersMethodassertDeque
(int queueId)
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/concurrent/queue/NamedQueueProxyProtocol.java:481
↓ 3 callersMethodassertIdenticalIterations
Assert that the specified iterators produce identical iterations. @param iter1 the first Iterator to compare @param iter2 the second Iterator to co
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/util/BaseMapTest.java:1346
↓ 3 callersMethodassertIdentity
Asserts an identity based on a token-based identity assertion. @param oToken the token that asserts identity. @param service the Service asserting
prj/coherence-core/src/main/java/com/tangosol/net/security/IdentityAsserter.java:42
↓ 3 callersMethodassertLockEnabled
Assert that NamedCache lock and unlock operations are allowed. @throws SecurityException if lock and unlock operations are prohibited
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/proxy/NamedCacheProxy.java:537
↓ 3 callersMethodassertNoMessages
Assert that the response does not conain any "messages" elements, which would indicate errors. @param response Response
prj/test/functional/management/src/main/java/management/BaseManagementInfoResourceTests.java:4749
↓ 3 callersMethodassertPopulateAndConsumeInParallel
(TopicPublisher publisher, boolean fVerifyOrder)
prj/test/functional/topics/src/main/java/topics/AbstractNamedTopicTests.java:702
↓ 3 callersMethodassertPublishedOrder
(NamedTopic<String> topic, int cElements, String... asPrefix)
prj/test/functional/topics/src/main/java/topics/TopicAssertions.java:75
↓ 3 callersMethodassertRemainingMessagesMetric
(String sTopic, String sGroup, int cRemaining)
prj/test/functional/topics/src/main/java/topics/AbstractNamedTopicTests.java:4542
↓ 3 callersMethodassertRemainingMessagesPerChannelMetric
(String sTopic, String sGroup, Map<Integer, Integer> mapCount)
prj/test/functional/topics/src/main/java/topics/AbstractNamedTopicTests.java:4576
↓ 3 callersMethodassertResponse
(URI uri, String sName)
prj/test/functional/mp-health/src/main/java/coherence/mp/health/testing/CoherenceHealthIT.java:87
↓ 3 callersMethodassertSubscribeToEventsForSingleKey
(K key, Consumer<NamedCache<K, String>> generateEvents, String sSerializerName, Serializer seriali
prj/test/functional/grpc-client-tck/src/main/java/grpc/client/AbstractGrpcClientIT.java:1868
↓ 3 callersMethodassertUp
(HealthCheck healthCheck, String sExpectedName)
prj/test/functional/mp-health/src/main/java/coherence/mp/health/testing/CoherenceHealthChecksTest.java:275
↓ 3 callersMethodassertWaitsForCheckpointCompletion
Assert that the supplied action blocks while checkpoint completion is pending, and then completes once the checkpoint is released. @param state th
prj/test/unit/coherence-core-tests/src/test/java/com/tangosol/persistence/journal/JournalPersistentStoreTest.java:1499
↓ 3 callersMethodassign
Assign the ownership of this Lock to the calling thread. <p> Note: caller of this method is expected to hold a synchronization monitor for the Lock ob
prj/coherence-core/src/main/java/com/tangosol/util/WrapperConcurrentMap.java:542
↓ 3 callersMethodasync
()
prj/test/functional/grpc-proxy-netty/src/main/java/netty/grpc/proxy/NamedCacheServiceImplTest.java:1833
↓ 3 callersMethodatFinest
Obtains a {@link Logging} option to set logging to finest level. @return a {@link Logging} option to set logging to finest level
prj/coherence-bedrock/coherence-bedrock/src/main/java/com/oracle/bedrock/runtime/coherence/options/Logging.java:171
↓ 3 callersMethodattemptDisconnect
Attempt to disconnect the set of convicted members if the cluster quorum policy allows, returning true if members are disconnected or false otherwise.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:14928
↓ 3 callersMethodawaitConnected
(int nTimeout, TimeUnit units)
prj/test/functional/topics/src/main/java/topics/TopicSubscriberManagementTests.java:963
↓ 3 callersMethodawaitDisconnected
(int nTimeout, TimeUnit units)
prj/test/functional/topics/src/main/java/topics/TopicSubscriberManagementTests.java:968
↓ 3 callersMethodawaitDrainReconciliationEntered
()
prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/component/util/VirtualDaemonPoolComponentTest.java:1696
← previousnext →10,001–10,100 of 78,752, ranked by callers