Functions — github.com/Splitet/SplitetFramework

hub / github.com/Splitet/SplitetFramework / functions

Functions386 in github.com/Splitet/SplitetFramework

⨍ Functions 386◇ Types & classes 134

↓ 1 callersMethodcreateServiceData

(String consumer, List<Partition> value)

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

↓ 1 callersMethodcreateTopic

(String serviceName, int partitionNo, Long offset)

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

↓ 1 callersMethoderrorDecoder

()

spring-integration/src/main/java/io/splitet/core/spring/configuration/FeignHelper.java:25

↓ 1 callersMethodgetDefaultNumberOfPartitions

(AdminClient adminClient)

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

↓ 1 callersMethodgetEntityType

()

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

↓ 1 callersMethodgetEventName

()

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

↓ 1 callersMethodgetEventRecorder

()

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

↓ 1 callersMethodgetNameAndClass

()

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

↓ 1 callersMethodgetOperation

(@PathVariable(OperationContext.OP_ID) String opId)

emon/src/main/java/io/splitet/core/api/emon/controller/OperationController.java:47

↓ 1 callersMethodgetParameters

()

java-api/src/main/java/io/splitet/core/pojos/CommandRecord.java:17

↓ 1 callersMethodgetPartition

(int number)

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

↓ 1 callersMethodgetQueryOptions

()

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

↓ 1 callersMethodgetSocketOptions

()

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

↓ 1 callersMethodincrementNumberOfVisit

()

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

↓ 1 callersMethodisFinished

()

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

↓ 1 callersMethodonEventMessage

(ConsumerRecord<String, Serializable> record, PublishedEventWrapper eventWrapper)

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

↓ 1 callersMethodonIdleContainer

(Map<TopicPartition, Long> assignments, ConsumerSeekCallback callback)

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

↓ 1 callersMethodonOperationMessage

(ConsumerRecord<String, Serializable> record, Operation operation)

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

↓ 1 callersMethodonPartitionsRevoked

(Collection<TopicPartition> partitions)

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

↓ 1 callersMethodqueryEntity

(String entityId)

java-api/src/main/java/io/splitet/core/cassandra/OptimizedCassandraViewQuery.java:30

↓ 1 callersMethodqueryEvent

(String entityId, int version)

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

↓ 1 callersMethodrecordCommand

(JoinPoint jp, CommandHandler commandHandler, Command command)

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

↓ 1 callersMethodregisterEmitter

(SseEmitter sseEmitter)

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

↓ 1 callersMethodregisterSeekCallback

(ConsumerSeekCallback callback)

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

↓ 1 callersMethodrollback

(P event)

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

↓ 1 callersMethodsetEventData

(String eventData)

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

↓ 1 callersMethodsetGenerated

()

java-api/src/main/java/io/splitet/core/common/Context.java:35

↓ 1 callersMethodsetPartitions

(Collection<Partition> partitionList)

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

↓ 1 callersMethodshouldCollectConsumer

(String consumer)

emon-lib/src/main/java/io/splitet/core/api/emon/service/ConsumerOffsetListener.java:79

↓ 1 callersMethodshouldCollectEvent

(String topic)

emon-lib/src/main/java/io/splitet/core/api/emon/service/ConsumerOffsetListener.java:75

↓ 1 callersMethodsnapshotFails

Operation Failed:. <ul> <li>Query EntityId/Versions for effected Entity/Event Series</li> <li>Calculate Min/Max version for each Entity</li> <ul> <li>

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

↓ 1 callersMethodsnapshotSuccess

Operation Succeed:. <ul> <li>Query EntityId/Versions for effected Entity/Event Series</li> <li>Calculate Min/Max version for each Entity</li> <ul> <li

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

↓ 1 callersMethodstartNewContext

(long commandTimeout)

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

↓ 1 callersMethodstopListen

()

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

↓ 1 callersMethodstopListen

()

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

↓ 1 callersMethodupdateEvent

(EventKey eventKey, @Nullable RecordedEvent newEventData, @Nullable EventState newEventState, @Nullable String

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

MethodAggregateListener

(ViewQuery<T> viewQuery, EventRepository eventRepository,

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

MethodBaseCassandraViewQuery

(String tableName, CassandraSession cassandraSession, ObjectMapper objectMapper, List<EntityFunctionSpec<E, ?>

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

MethodBaseEntity

()

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

MethodCassandraEventRecorder

(String tableName, CassandraSession cassandraSession,

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

MethodCassandraSession

(EventStoreConfig eventStoreConfig)

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

MethodCassandraViewQuery

(String tableName, CassandraSession cassandraSession, ObjectMapper objectMapper, List<EntityFunctionSpec<E, ?>

java-api/src/main/java/io/splitet/core/cassandra/CassandraViewQuery.java:16

MethodCommandExecutionInterceptor

(KafkaOperationRepository kafkaOperationRepository, OperationContext operationContext)

java-api/src/main/java/io/splitet/core/common/CommandExecutionInterceptor.java:35

MethodCompositeRepositoryImpl

(EventRecorder eventRecorder, ObjectMapper objectMapper, IOperationReposito

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

MethodConcurrentEventException

()

java-api/src/main/java/io/splitet/core/cassandra/ConcurrentEventException.java:5

MethodConsumerOffsetChangeEntryProcessor

(String group, int partitionNo, long offset)

emon-lib/src/main/java/io/splitet/core/api/emon/service/processor/ConsumerOffsetChangeEntryProcessor.java:19

MethodContext

(String opId)

java-api/src/main/java/io/splitet/core/common/Context.java:31

MethodDataMigrationService

(EventRecorder eventRecorder, ViewQuery<T> viewQuery, SnapshotRepository<T, String> snapshotRepository)

spring-integration/src/main/java/io/splitet/core/spring/configuration/DataMigrationService.java:21

MethodEndOffsetSetter

(int partitionNo, long offset)

emon-lib/src/main/java/io/splitet/core/api/emon/service/processor/EndOffsetSetter.java:18

MethodEntityFunctionSpec

(@NonNull EntityFunction<EntityT, EventDataT> entityFunction)

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

MethodEventContextException

(String message)

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

MethodEventExecutionInterceptor

(KafkaOperationRepository kafkaOperationRepository, OperationContext operationContext, IUserContext userContex

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

MethodEventListenContainerService

()

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

MethodEventMessageConverter

(ObjectMapper objectMapper, OperationContext operationContext, IUserContext userContext, IOperationRepository

spring-integration/src/main/java/io/splitet/core/spring/configuration/EventMessageConverter.java:28

MethodEventPulisherException

()

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

MethodEventStoreException

()

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

MethodEventTopologyUpdater

(PublishedEventWrapper eventWrapper, EventType eventType,

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

MethodHandledEvent

(ProducedEvent producedEvent, String handlerService, String topic)

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

MethodInMemoryFailedEvent

Create a new ApplicationEvent. @param source the object on which the event initially occurred (never {@code null})

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/InMemoryFailedEvent.java:11

MethodInMemoryRestoredEvent

Create a new ApplicationEvent. @param source the object on which the event initially occurred (never {@code null})

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/InMemoryRestoredEvent.java:11

MethodJpaEntity

()

spring-jpa-view/src/main/java/io/splitet/core/spring/model/JpaEntity.java:18

MethodJsonDeserializer

(Class<T> targetType)

java-api/src/main/java/io/splitet/core/kafka/JsonDeserializer.java:46

MethodJsonSerializer

(@Nonnull ObjectMapper objectMapper)

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

MethodKafkaOperationRepository

(OperationContext operationContext, IUserContext userContext, KafkaProduce

java-api/src/main/java/io/splitet/core/kafka/KafkaOperationRepository.java:23

MethodKafkaOperationRepositoryFactory

(KafkaProperties kafkaProperties, IUserContext userContext, OperationContext operationContext)

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

MethodMultipleEventMessageListener

(List<EventMessageListener> eventMessageListeners)

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

MethodNoneHandled

()

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

MethodOpContextFilter

(OperationContext operationContext)

spring-integration/src/main/java/io/splitet/core/spring/filter/OpContextFilter.java:29

MethodOperationEvent

(Operation operation)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/OperationEvent.java:28

MethodOperationEvents

(Map<String, String> userContext)

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

MethodOperationExpirationListener

(IMap<String, Topology> operationsHistoryMap, IMap<String, Topic> topicsMap, ITopic<Topology> operationsTopic)

emon-lib/src/main/java/io/splitet/core/api/emon/service/OperationExpirationListener.java:24

MethodOperationTopologyUpdater

(Operation operation)

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

MethodOptimizedCassandraViewQuery

(String tableName, CassandraSession cassandraSession, ObjectMapper obje

java-api/src/main/java/io/splitet/core/cassandra/OptimizedCassandraViewQuery.java:22

MethodPartition

(int number)

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

MethodProducedEvent

(String topic, String sender, String aggregateId, EventType eventType, EventKey event

emon-lib/src/main/java/io/splitet/core/api/emon/domain/ProducedEvent.java:38

MethodPublishedEventWrapper

()

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

MethodQuorumListenerForApplicationEvents

(ApplicationEventPublisher publisher)

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/QuorumListenerForApplicationEvents.java:12

MethodServiceData

(String serviceName, List<Partition> partitionList)

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

MethodSnapshotOptimizedAggregateListener

(ViewQuery<T> viewQuery, EventRepository eventRepository,

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

MethodTopology

()

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

MethodadminClient

(@Autowired @Qualifier("kafkaAdminProperties") Properties kafkaAdminProperties)

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/TopologyConfiguration.java:41

MethodafterReturning

(Object retVal)

java-api/src/main/java/io/splitet/core/common/EventExecutionInterceptor.java:37

MethodafterReturning

(Command command, Object retVal)

java-api/src/main/java/io/splitet/core/common/CommandExecutionInterceptor.java:87

MethodafterThrowing

(Exception exception)

java-api/src/main/java/io/splitet/core/common/EventExecutionInterceptor.java:44

MethodafterThrowing

(Command command, Exception exception)

java-api/src/main/java/io/splitet/core/common/CommandExecutionInterceptor.java:93

MethodattachHandler

(ProducedEvent producedEvent)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/ProducedEvent.java:53

MethodattachOperation

(OperationEvent operationToAttach)

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

MethodattachOperation

(OperationEvent operation)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/ProducedEvent.java:85

MethodattachOperation

(OperationEvent operationToAttach)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/NoneHandled.java:26

MethodattachOperation

(OperationEvent operation)

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

Methodbefore

(JoinPoint jp, Command command)

java-api/src/main/java/io/splitet/core/common/CommandExecutionInterceptor.java:41

MethodbuildProperties

()

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

MethodcalculateNext

(R failedEvent, EventKey failedEventKey, int lastVersion)

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

MethodcalculateNext

(EventKey eventKey, int lastVersion)

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

MethodcassandraSession

()

spring-integration/src/main/java/io/splitet/core/spring/configuration/EventApisFactory.java:62

MethodclearUserContext

()

java-api/src/main/java/io/splitet/core/api/impl/EmptyUserContext.java:19

Methodclone

()

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

Methodclone

()

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

Methodclose

()

java-api/src/main/java/io/splitet/core/kafka/JsonDeserializer.java:77

MethodcommandsMap

(@Autowired @Qualifier("hazelcastInstance") HazelcastInstance hazelcastInstance)

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/MapsConfig.java:83

← previous next →101–200 of 386, ranked by callers