Functions — github.com/Splitet/SplitetFramework

hub / github.com/Splitet/SplitetFramework / functions

Functions386 in github.com/Splitet/SplitetFramework

⨍ Functions 386◇ Types & classes 134

↓ 23 callersMethodgetContext

()

java-api/src/main/java/io/splitet/core/common/OperationContext.java:54

↓ 16 callersMethodgetVersion

()

java-api/src/main/java/io/splitet/core/view/Entity.java:18

↓ 15 callersMethodgetEventKey

()

java-api/src/main/java/io/splitet/core/view/Entity.java:12

↓ 14 callersMethodgetEventType

()

java-api/src/main/java/io/splitet/core/common/ReceivedEvent.java:20

↓ 13 callersMethodexecute

(D event)

java-api/src/main/java/io/splitet/core/api/EventHandler.java:9

↓ 12 callersMethodgetPartitions

()

emon/src/main/java/io/splitet/core/api/emon/dto/TopicResponseDto.java:42

↓ 11 callersMethodgetCommandContext

()

java-api/src/main/java/io/splitet/core/common/OperationContext.java:58

↓ 10 callersMethodapply

(E previous, EntityEventWrapper<W> event)

java-api/src/main/java/io/splitet/core/view/EntityFunction.java:10

↓ 10 callersMethodgetServiceDataHashMap

()

emon-lib/src/main/java/io/splitet/core/api/emon/domain/Topic.java:39

↓ 10 callersMethodqueryEntity

(String entityId)

java-api/src/main/java/io/splitet/core/api/ViewQuery.java:18

↓ 8 callersMethodrecordAndPublish

(P publishedEvent)

java-api/src/main/java/io/splitet/core/api/EventRepository.java:24

↓ 7 callersMethodapplyForEach

(Consumer<EventMessageListener> listenerConsumer)

emon-lib/src/main/java/io/splitet/core/api/emon/service/MultipleEventMessageListener.java:23

↓ 7 callersMethodgenerateContext

()

java-api/src/main/java/io/splitet/core/common/OperationContext.java:94

↓ 7 callersMethodrecordAndPublishInternal

( P publishedEvent, Optional<EventKey> previousEventKey, Function<EntityEvent, ConcurrencyResolver

java-api/src/main/java/io/splitet/core/core/CompositeRepositoryImpl.java:99

↓ 7 callersMethodsetCommandContext

(String eventId)

java-api/src/main/java/io/splitet/core/common/OperationContext.java:63

↓ 6 callersMethodbuildConsumerProperties

Create an initial map of consumer properties from the state of this instance. <p>This allows you to add additional properties, if necessary, and over

java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:116

↓ 6 callersMethodgetContextOpId

()

java-api/src/main/java/io/splitet/core/common/OperationContext.java:46

↓ 6 callersMethodgetUserContext

()

java-api/src/main/java/io/splitet/core/api/IUserContext.java:6

↓ 6 callersMethodisRunning

()

emon-lib/src/main/java/io/splitet/core/api/emon/service/EventListenContainerService.java:54

↓ 6 callersMethodrecordEntityEvent

( RecordedEvent event, long date, Optional<EventKey> previousEventKey, Fun

java-api/src/main/java/io/splitet/core/common/EventRecorder.java:20

↓ 5 callersMethodassertCommon

(PublishedEvent event)

java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:118

↓ 5 callersMethodclearCommandContext

()

java-api/src/main/java/io/splitet/core/common/OperationContext.java:78

↓ 5 callersMethodfailOperation

(String eventId, SerializableConsumer<Event> action)

java-api/src/main/java/io/splitet/core/kafka/IOperationRepository.java:10

↓ 5 callersMethodgetSession

()

java-api/src/main/java/io/splitet/core/cassandra/CassandraSession.java:121

↓ 5 callersMethodmarkFail

(String key)

java-api/src/main/java/io/splitet/core/common/EventRecorder.java:33

↓ 5 callersMethodmockCommon

(PublishedEvent event)

java-api/src/test/java/io/splitet/core/core/CompositeRepositoryImplTest.java:113

↓ 4 callersMethodbuildCommonProperties

()

java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:64

↓ 4 callersMethodgetQueryType

()

java-api/src/main/java/io/splitet/core/view/EntityFunctionSpec.java:21

↓ 4 callersMethodgetTopic

(@PathVariable("topic") String topic)

emon/src/main/java/io/splitet/core/api/emon/controller/EventController.java:88

↓ 4 callersMethodpublishEvent

(String topic, String event, long opDate)

java-api/src/main/java/io/splitet/core/kafka/IOperationRepository.java:14

↓ 4 callersMethodqueryEntityInternal

(String entityId, Select select)

java-api/src/main/java/io/splitet/core/cassandra/BaseCassandraViewQuery.java:96

↓ 4 callersMethodsaveAll

(Iterable<S> entities)

java-api/src/main/java/io/splitet/core/view/SnapshotRepository.java:9

↓ 3 callersMethodattachHandler

(ProducedEvent eventHandler)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/IProducedEvent.java:16

↓ 3 callersMethodattachOperation

(OperationEvent operationToAttach)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/IHandledEvent.java:21

↓ 3 callersMethodbuildSslOptions

(Ssl ssl, Map<String, Object> properties)

java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:83

↓ 3 callersMethodcalculateTimeout

(Context context)

emon-lib/src/main/java/io/splitet/core/api/emon/service/TopologyService.java:52

↓ 3 callersMethodclearUserContext

()

java-api/src/main/java/io/splitet/core/api/IUserContext.java:10

↓ 3 callersMethodclose

()

java-api/src/main/java/io/splitet/core/kafka/JsonSerializer.java:59

↓ 3 callersMethodconfigure

(Config existingConfig)

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/HazelcastConfigurer.java:7

↓ 3 callersMethodconvertToEntityEvent

(Row entityEventData)

java-api/src/main/java/io/splitet/core/cassandra/BaseCassandraViewQuery.java:48

↓ 3 callersMethodcreateEventStr

(RecordedEvent newEventData)

java-api/src/main/java/io/splitet/core/cassandra/CassandraEventRecorder.java:218

↓ 3 callersMethodderegisterEmitter

(SseEmitter sseEmitter)

emon/src/main/java/io/splitet/core/api/emon/service/OperationsBroadcaster.java:36

↓ 3 callersMethodextractUserContext

(Map<String, String> userContext)

java-api/src/main/java/io/splitet/core/api/IUserContext.java:8

↓ 3 callersMethodgenerateOpId

()

java-api/src/main/java/io/splitet/core/common/OperationContext.java:110

↓ 3 callersMethodgetAuditInfo

()

java-api/src/main/java/io/splitet/core/api/IUserContext.java:12

↓ 3 callersMethodgetEventData

()

java-api/src/main/java/io/splitet/core/view/EntityEventWrapper.java:24

↓ 3 callersMethodinstantiate

(Class<T> type)

java-api/src/main/java/io/splitet/core/cassandra/CassandraSession.java:36

↓ 3 callersMethodqueryEntity

(String entityId)

java-api/src/main/java/io/splitet/core/cassandra/BaseCassandraViewQuery.java:60

↓ 3 callersMethodqueryEventKeysByOpId

(String opId)

java-api/src/main/java/io/splitet/core/api/ViewQuery.java:36

↓ 3 callersMethodswitchContext

(String opId)

java-api/src/main/java/io/splitet/core/common/OperationContext.java:28

↓ 2 callersMethodaddTopicPartitions

(String topic, Map<Integer, Partition> partitionMap)

emon/src/main/java/io/splitet/core/api/emon/dto/ServiceResponseDto.java:21

↓ 2 callersMethodbuildProducerProperties

Create an initial map of producer properties from the state of this instance. <p>This allows you to add additional properties, if necessary, and over

java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:131

↓ 2 callersMethodbuildProperties

()

java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:219

↓ 2 callersMethodcalculateNext

(EventKey failedEventKey, int lastVersion)

java-api/src/main/java/io/splitet/core/cassandra/ConcurrencyResolver.java:13

↓ 2 callersMethodclearContext

()

java-api/src/main/java/io/splitet/core/common/OperationContext.java:72

↓ 2 callersMethodclone

()

java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:137

↓ 2 callersMethodclone

()

java-api/src/main/java/io/splitet/core/pojos/Event.java:36

↓ 2 callersMethodcreateOpDate

()

java-api/src/main/java/io/splitet/core/core/CompositeRepositoryImpl.java:115

↓ 2 callersMethodfindById

(ID id)

java-api/src/main/java/io/splitet/core/view/SnapshotRepository.java:15

↓ 2 callersMethodflush

()

java-api/src/main/java/io/splitet/core/view/SnapshotRepository.java:13

↓ 2 callersMethodgetEvent

()

java-api/src/main/java/io/splitet/core/kafka/PublishedEventWrapper.java:40

↓ 2 callersMethodgetId

()

java-api/src/main/java/io/splitet/core/view/Entity.java:14

↓ 2 callersMethodgetKeyPassword

()

java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:377

↓ 2 callersMethodgetKeystoreLocation

()

java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:385

↓ 2 callersMethodgetKeystorePassword

()

java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:393

↓ 2 callersMethodgetMinMax

(List<EventKey> entityEvents)

java-api/src/main/java/io/splitet/core/view/SnapshotOptimizedAggregateListener.java:147

↓ 2 callersMethodgetOrCreateContext

()

java-api/src/main/java/io/splitet/core/common/OperationContext.java:21

↓ 2 callersMethodgetParentId

Backward compatible. @return

java-api/src/main/java/io/splitet/core/pojos/Operation.java:36

↓ 2 callersMethodgetPartition

(int number)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/ServiceData.java:36

↓ 2 callersMethodgetTruststoreLocation

()

java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:401

↓ 2 callersMethodgetTruststorePassword

()

java-api/src/main/java/io/splitet/core/kafka/KafkaProperties.java:409

↓ 2 callersMethodnextId

()

java-api/src/main/java/io/splitet/core/api/IdCreationStrategy.java:7

↓ 2 callersMethodonPartitionsAssigned

(Collection<TopicPartition> partitions)

emon-lib/src/main/java/io/splitet/core/api/emon/service/EventMessageListener.java:32

↓ 2 callersMethodpublishInternal

(P publishedEvent, long opDate, EventKey eventKey)

java-api/src/main/java/io/splitet/core/core/CompositeRepositoryImpl.java:119

↓ 2 callersMethodpushContext

(String opId)

java-api/src/main/java/io/splitet/core/common/OperationContext.java:142

↓ 2 callersMethodqueryByOpId

(String opId)

java-api/src/main/java/io/splitet/core/api/ViewQuery.java:26

↓ 2 callersMethodrecordEntityEventInternal

( R event, long opDate, Optional<EventKey> previousEventKey, F

java-api/src/main/java/io/splitet/core/cassandra/CassandraEventRecorder.java:83

↓ 2 callersMethodrunRollbacks

(List<EntityEvent> entityEvents)

java-api/src/main/java/io/splitet/core/view/AggregateListener.java:60

↓ 2 callersMethodsave

(S entity)

java-api/src/main/java/io/splitet/core/view/SnapshotRepository.java:11

↓ 2 callersMethodsetId

(String id)

java-api/src/main/java/io/splitet/core/view/Entity.java:16

↓ 2 callersMethodsetOperation

(OperationEvent operation)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/IHandledEvent.java:19

↓ 2 callersMethodsetPartition

(Partition partition)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/ServiceData.java:43

↓ 2 callersMethodsetVersion

(int version)

java-api/src/main/java/io/splitet/core/view/Entity.java:20

↓ 2 callersMethodstartListen

()

emon-lib/src/main/java/io/splitet/core/api/emon/service/EventListenContainerService.java:59

↓ 2 callersMethodstartListen

()

emon-lib/src/main/java/io/splitet/core/api/emon/service/ConsumerOffsetListenerContainerService.java:48

↓ 2 callersMethodsuccessOperation

(String eventId, SerializableConsumer<Event> action)

java-api/src/main/java/io/splitet/core/kafka/IOperationRepository.java:12

↓ 2 callersMethodtryMore

()

java-api/src/main/java/io/splitet/core/cassandra/ConcurrencyResolver.java:11

↓ 1 callersMethodaddCommand

(String value)

emon/src/main/java/io/splitet/core/api/emon/dto/ServiceResponseDto.java:25

↓ 1 callersMethodaddCommandSpecs

(List<EntityFunctionSpec<E, ?>> commandSpec)

java-api/src/main/java/io/splitet/core/cassandra/BaseCassandraViewQuery.java:236

↓ 1 callersMethodadminClient

()

spring-integration/src/main/java/io/splitet/core/spring/configuration/AutomaticTopicConfiguration.java:30

↓ 1 callersMethodattachOperation

(OperationEvent operation)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/Topology.java:90

↓ 1 callersMethodattachProducedEvent

(ProducedEvent producedEvent)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/HandledEvent.java:32

↓ 1 callersMethodattachProducedEvent

(ProducedEvent producedEvent)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/Topology.java:51

↓ 1 callersMethodcalculateLag

(long endOffset)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/Partition.java:30

↓ 1 callersMethodcheckOperationFinalStates

(P publishedEvent)

java-api/src/main/java/io/splitet/core/core/CompositeRepositoryImpl.java:133

↓ 1 callersMethodcluster

()

java-api/src/main/java/io/splitet/core/cassandra/CassandraSession.java:56

↓ 1 callersMethodconsumeStaleEvents

()

emon-lib/src/main/java/io/splitet/core/api/emon/domain/Topology.java:64

↓ 1 callersMethodconsumeStaleOperations

()

emon-lib/src/main/java/io/splitet/core/api/emon/domain/Topology.java:69

↓ 1 callersMethodcreateInsertQuery

(EntityEvent entityEvent)

java-api/src/main/java/io/splitet/core/cassandra/CassandraEventRecorder.java:148

↓ 1 callersMethodcreateKafkaOperationRepository

(ObjectMapper objectMapper)

java-api/src/main/java/io/splitet/core/kafka/KafkaOperationRepositoryFactory.java:21

next →1–100 of 386, ranked by callers