Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Splitet/SplitetFramework
/ functions
Functions
386 in github.com/Splitet/SplitetFramework
⨍
Functions
386
◇
Types & classes
134
Method
onPartitionsAssigned
(Map<TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback)
emon-lib/src/main/java/io/splitet/core/api/emon/service/EventListener.java:46
Method
onPartitionsAssigned
(Collection<TopicPartition> partitions)
emon-lib/src/main/java/io/splitet/core/api/emon/service/MultipleEventMessageListener.java:48
Method
onPartitionsRevoked
(Collection<TopicPartition> partitions)
emon-lib/src/main/java/io/splitet/core/api/emon/service/MultipleEventMessageListener.java:43
Method
opIdInterceptor
(@Autowired OperationContext operationContext)
spring-integration/src/main/java/io/splitet/core/spring/configuration/EventApisFactory.java:82
Method
operationExpirationListener
(@Autowired @Qualifier("operationsHistoryMap") IMap<String, Topology> operationsHistoryMap,
emon-lib/src/main/java/io/splitet/core/api/emon/configuration/InMemoryComponents.java:77
Method
operationListenerContainer
()
emon-lib/src/main/java/io/splitet/core/api/emon/configuration/EventListenConfiguration.java:52
Method
operationsHistoryMap
(@Autowired @Qualifier("hazelcastInstance") HazelcastInstance hazelcastInstance)
emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/MapsConfig.java:71
Method
operationsKafkaListenerContainerFactory
( ConsumerFactory<String, Operation> consumerFactory)
spring-integration/src/main/java/io/splitet/core/spring/configuration/EventApisFactory.java:159
Method
operationsMap
(@Autowired @Qualifier("hazelcastInstance") HazelcastInstance hazelcastInstance, OperationExpirationListener o
emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/MapsConfig.java:63
Method
operationsTopic
(@Autowired @Qualifier("hazelcastInstance") HazelcastInstance hazelcastInstance)
emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/MapsConfig.java:89
Method
postConstruct
()
emon/src/main/java/io/splitet/core/api/emon/service/OperationsBroadcaster.java:26
Method
prepare
(String statement)
java-api/src/main/java/io/splitet/core/cassandra/CassandraSession.java:147
Method
process
(Map.Entry entry)
emon-lib/src/test/java/io/splitet/core/pojos/OperationTest.java:22
Method
process
(Map.Entry<String, Topology> entry)
emon-lib/src/main/java/io/splitet/core/api/emon/service/TopologyService.java:122
Method
process
(Map.Entry<String, Topology> entry)
emon-lib/src/main/java/io/splitet/core/api/emon/service/TopologyService.java:159
Method
process
(Map.Entry<String, Topic> entry)
emon-lib/src/main/java/io/splitet/core/api/emon/service/processor/ConsumerOffsetChangeEntryProcessor.java:25
Method
process
(Map.Entry<String, Topic> entry)
emon-lib/src/main/java/io/splitet/core/api/emon/service/processor/EndOffsetSetter.java:23
Method
publishEvent
(String topic, String event, long opDate)
java-api/src/main/java/io/splitet/core/kafka/KafkaOperationRepository.java:70
Method
queryByOpId
(String opId)
java-api/src/main/java/io/splitet/core/cassandra/OptimizedCassandraViewQuery.java:53
Method
queryByOpId
(String opId)
java-api/src/main/java/io/splitet/core/cassandra/BaseCassandraViewQuery.java:160
Method
queryEvent
(String entityId, int version)
java-api/src/main/java/io/splitet/core/api/ViewQuery.java:32
Method
queryEventData
(String entityId, int version)
java-api/src/main/java/io/splitet/core/api/ViewQuery.java:34
Method
queryEventData
(String entityId, int version)
java-api/src/main/java/io/splitet/core/cassandra/BaseCassandraViewQuery.java:214
Method
queryEventKeysByOpId
(String opId)
java-api/src/main/java/io/splitet/core/cassandra/OptimizedCassandraViewQuery.java:68
Method
queryEventKeysByOpId
(String opId)
java-api/src/main/java/io/splitet/core/cassandra/BaseCassandraViewQuery.java:221
Method
queryHistory
(String entityId)
java-api/src/main/java/io/splitet/core/api/ViewQuery.java:30
Method
queryHistory
(String entityId)
java-api/src/main/java/io/splitet/core/cassandra/BaseCassandraViewQuery.java:151
Method
readExternal
(ObjectInput in)
java-api/src/main/java/io/splitet/core/pojos/Event.java:30
Method
recordAndPublish
(P publishedEvent)
java-api/src/main/java/io/splitet/core/core/CompositeRepositoryImpl.java:49
Method
recordEntityEvent
( R event, long opDate, Optional<EventKey> previousEventKey, S
java-api/src/main/java/io/splitet/core/cassandra/CassandraEventRecorder.java:132
Method
recover
(Exception exception)
spring-integration/src/main/java/io/splitet/core/spring/configuration/SpringKafkaOpListener.java:30
Method
regexpTest
()
emon-lib/src/test/java/io/splitet/core/pojos/OperationTest.java:39
Method
regexpTest2
()
emon-lib/src/test/java/io/splitet/core/pojos/OperationTest.java:51
Method
registerSeekCallback
(ConsumerSeekAware.ConsumerSeekCallback callback)
emon-lib/src/main/java/io/splitet/core/api/emon/service/ConsumerOffsetListener.java:83
Method
registerSeekCallback
(ConsumerSeekCallback callback)
emon-lib/src/main/java/io/splitet/core/api/emon/service/MultipleEventMessageListener.java:53
Method
rollback
(CommandRecord record)
java-api/src/main/java/io/splitet/core/api/RollbackCommandSpec.java:33
Method
rollback
(TransactionStatus status)
spring-integration/src/main/java/io/splitet/core/spring/configuration/EventApisFactory.java:211
Method
serialize
(String topic, T data)
java-api/src/main/java/io/splitet/core/kafka/JsonSerializer.java:47
Method
setConsumerGroupRegex
(Pattern consumerGroupRegex)
emon-lib/src/main/java/io/splitet/core/api/emon/service/ConsumerOffsetListener.java:70
Method
setEvent
(ObjectNode event)
java-api/src/main/java/io/splitet/core/kafka/PublishedEventWrapper.java:46
Method
setEventTopicRegex
(Pattern eventTopicRegex)
emon-lib/src/main/java/io/splitet/core/api/emon/service/ConsumerOffsetListener.java:65
Method
setKeyPassword
(String keyPassword)
java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:381
Method
setKeystoreLocation
(String keystoreLocation)
java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:389
Method
setKeystorePassword
(String keystorePassword)
java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:397
Method
setLeafs
(ProducedEvent producedEvent)
emon-lib/src/main/java/io/splitet/core/api/emon/service/OperationExpirationListener.java:52
Method
setOperation
(OperationEvent operation)
emon-lib/src/main/java/io/splitet/core/api/emon/domain/ProducedEvent.java:118
Method
setOperation
(OperationEvent operation)
emon-lib/src/main/java/io/splitet/core/api/emon/domain/NoneHandled.java:31
Method
setOperation
(OperationEvent operation)
emon-lib/src/main/java/io/splitet/core/api/emon/domain/IProducedEvent.java:24
Method
setParameters
(Map<Integer, JsonNode> parameters)
java-api/src/main/java/io/splitet/core/pojos/CommandRecord.java:22
Method
setPartitions
(List<Partition> value)
emon-lib/src/main/java/io/splitet/core/api/emon/domain/Topic.java:56
Method
setTruststoreLocation
(String truststoreLocation)
java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:405
Method
setTruststorePassword
(String truststorePassword)
java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:413
Method
setUp
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:87
Method
shouldClearCommandContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:74
Method
shouldClearContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:63
Method
shouldClearUserContext
()
java-api/src/test/java/io/splitet/core/api/impl/EmptyUserContextTest.java:44
Method
shouldExtractUserContext
()
java-api/src/test/java/io/splitet/core/api/impl/EmptyUserContextTest.java:32
Method
shouldFailOperationWithFailEvent
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:226
Method
shouldGenerateContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:85
Method
shouldGetAuditInfo
()
java-api/src/test/java/io/splitet/core/api/impl/EmptyUserContextTest.java:55
Method
shouldGetCommandContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:43
Method
shouldGetContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:33
Method
shouldGetNextId
()
java-api/src/test/java/io/splitet/core/api/impl/UUIDCreationStrategyTest.java:19
Method
shouldGetUserContext
()
java-api/src/test/java/io/splitet/core/api/impl/EmptyUserContextTest.java:21
Method
shouldMarkFail
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:106
Method
shouldRecordAndPublishWithPreviousEventAndPublishedEvent
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:139
Method
shouldRecordAndPublishWithPreviousEventAndPublishedEventAndConcurrencyResolverFactory
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:173
Method
shouldRecordAndPublishWithPreviousEventKeyAndPublishedEvent
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:157
Method
shouldRecordAndPublishWithPreviousEventKeyAndPublishedEventAndConcurrencyResolverFactory
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:193
Method
shouldRecordAndPublishWithPublishedEvent
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:126
Method
shouldSetCommandContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:53
Method
shouldSuccessOperationWithSuccessEvent
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:211
Method
shouldSwitchContext
()
java-api/src/test/java/io/splitet/core/common/OperationContextTest.java:23
Method
shouldThrowExceptionWhenObjectWriterThrowsException
()
java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:241
Method
snapshotOnly
(String entityId)
spring-integration/src/main/java/io/splitet/core/spring/configuration/DataMigrationService.java:39
Method
successOperation
(String eventId, SerializableConsumer<Event> action)
java-api/src/main/java/io/splitet/core/kafka/KafkaOperationRepository.java:57
Method
testCalculateNext
()
java-api/src/test/java/io/splitet/core/cassandra/DefaultConcurrencyResolverTest.java:29
Method
testReadWriteExternal
()
emon-lib/src/test/java/io/splitet/core/pojos/OperationTest.java:17
Method
testReadWriteExternal
()
emon/src/test/java/io/splitet/core/pojos/OperationTest.java:9
Method
testTryMore
()
java-api/src/test/java/io/splitet/core/cassandra/DefaultConcurrencyResolverTest.java:19
Method
topicsMap
(@Autowired @Qualifier("hazelcastInstance") HazelcastInstance hazelcastInstance)
emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/MapsConfig.java:77
Method
tryMore
()
java-api/src/main/java/io/splitet/core/cassandra/ConcurrentEventResolver.java:10
Method
tryMore
()
java-api/src/main/java/io/splitet/core/cassandra/DefaultConcurrencyResolver.java:7
Method
updateEvent
(EventKey eventKey, @Nullable RecordedEvent newEventData, @Nullable EventState newEventState, @Nullable String
java-api/src/main/java/io/splitet/core/cassandra/CassandraEventRecorder.java:190
Method
updateEvent
(EventKey eventKey, boolean snapshot, @Nullable RecordedEvent newEventData, @Nullable EventState newEventState
spring-integration/src/main/java/io/splitet/core/spring/configuration/DataMigrationService.java:27
Method
writeExternal
(ObjectOutput out)
java-api/src/main/java/io/splitet/core/pojos/Event.java:25
← previous
301–386 of 386, ranked by callers