Functions — github.com/Splitet/SplitetFramework

hub / github.com/Splitet/SplitetFramework / functions

Functions386 in github.com/Splitet/SplitetFramework

⨍ Functions 386◇ Types & classes 134

Methodcommit

(TransactionStatus status)

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

MethodcompareTo

(@NotNull SpanningService spanningService)

emon-lib/src/main/java/io/splitet/core/api/emon/domain/SpanningService.java:20

Methodconfig

()

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/InMemoryComponents.java:49

Methodconfigure

(Config config)

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/HazelcastOperationMapsConfig.java:30

Methodconfigure

(Config config)

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/MulticastConfig.java:17

Methodconfigure

(Config config)

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

Methodconfigure

(Config config)

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/UserCodeDeploymentConfig.java:16

Methodconfigure

(Config config)

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/hazelcast/NetworkInterfacesConfig.java:17

Methodconfigure

(Map<String, ?> configs, boolean isKey)

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

Methodconfigure

(Map<String, ?> configs, boolean isKey)

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

MethodconsumerGroupRegex

()

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/EventListenConfiguration.java:47

MethodconsumerOffsetListenerContainer

()

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/ConsumerOffsetListenerConfiguration.java:30

MethodcreateCommandExecutionInterceptor

(@Autowired KafkaOperationRepository kafkaOperationRepository,

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

MethodcreateEventExecutionInterceptor

(@Autowired KafkaOperationRepository kafkaOperationRepository,

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

MethodcreateOpContextFilter

(@Autowired OperationContext operationContext)

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

MethodcreateOperationContext

()

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

Methoddeserialize

(String topic, byte[] data)

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

Methoddestroy

()

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/InMemoryComponents.java:84

Methoddestroy

()

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

Methoddestroy

()

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

MethoddoFilterInternal

(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, FilterChain filterChain)

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

MethodentryExpired

(EntryEvent<String, Topology> event)

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

MethodeventMessageConverter

(OperationContext operationContext, IUserContext userContext, KafkaOperationRepository kafkaOperationRepositor

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

MethodeventTopicRegex

()

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/EventListenConfiguration.java:42

MethodeventsKafkaListenerContainerFactory

( EventMessageConverter eventMessageConverter, ConsumerFactory<String, PublishedEventWrapper> cons

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

MethodeventsOperationsMap

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

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/HazelcastOperationMapsConfig.java:47

Methodexecute

(Statement st, ThrowingFunction<ResultSet, R, E> tf)

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

MethodextractAndConvertValue

(ConsumerRecord<?, ?> record, Type type)

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

MethodextractUserContext

(Map<String, String> userContext)

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

MethodfailOperation

(String eventId, SerializableConsumer<Event> action)

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

MethodfeignBuilder

(@Autowired List<RequestInterceptor> interceptors, @Autowired ErrorDecoder errorDecoder)

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

MethodgetAuditInfo

()

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

MethodgetBackupProcessor

()

emon-lib/src/test/java/io/splitet/core/pojos/OperationTest.java:28

MethodgetCommandExecutionTime

()

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

MethodgetContextParentOpId

()

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

MethodgetEventKey

()

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

MethodgetEventKey

()

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

MethodgetEventRecorder

()

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

MethodgetEventType

()

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

MethodgetEventType

()

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

MethodgetEventType

()

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

MethodgetEventType

()

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

MethodgetEvents

()

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

MethodgetLaggedTopics

()

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

MethodgetNameAndClass

()

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

MethodgetOperations

(@PageableDefault Pageable pageable)

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

MethodgetService

(@PathVariable("serviceName") String serviceName)

emon/src/main/java/io/splitet/core/api/emon/controller/ServiceController.java:67

MethodgetServiceData

()

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

MethodgetServices

()

emon/src/main/java/io/splitet/core/api/emon/controller/ServiceController.java:41

MethodgetTableName

()

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

MethodgetTableNameForEvents

(String eventName)

spring-integration/src/main/java/io/splitet/core/spring/configuration/EventApisConfiguration.java:22

MethodgetTopics

()

emon/src/main/java/io/splitet/core/api/emon/controller/CommandController.java:32

MethodgetTopicsHistory

(@PageableDefault Pageable pageable)

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

MethodgetTransaction

(TransactionDefinition definition)

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

MethodgetUserContext

()

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

MethodgetUserContext

()

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

MethodhazelcastInstance

(Config config, SpringManagedContext springManagedContext)

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/InMemoryComponents.java:69

MethodincrementNumberOfVisit

()

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

Methodinit

()

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

Methodinit

()

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

MethodisFinished

()

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

MethodisFinished

()

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

MethodisFinished

()

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

MethodisFinished

()

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

MethodisFinished

()

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

MethodisTimedOut

()

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

MethodkafkaAdminProperties

()

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

MethodkafkaConsumer

()

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

MethodkafkaConsumerFactory

()

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

MethodkafkaOperationRepository

(KafkaOperationRepositoryFactory kafkaOperationRepositoryFactory)

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

MethodkafkaOperationRepositoryFactory

(@Autowired OperationContext operationContext,

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

MethodkafkaOperationsFactory

()

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

MethodlistenOperations

If operation Fails:. <ul> <li>Mark Events Fail</li> <li>Run Manual Rollback For These Events</li> <li>And Recalculate snapshot if it's necessary for F

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

MethodlistenOperations

(ConsumerRecord<String, Operation> data)

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

MethodlistenOperations

(ConsumerRecord<String, Operation> record)

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

MethodlistenOperations

(ConsumerRecord<String, Operation> record)

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

MethodlistenOperations

()

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

emon/src/main/java/io/splitet/core/api/emon/EmonApplication.java:16

MethodmanagedContext

()

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/InMemoryComponents.java:64

MethodmarkFail

(String opId)

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

MethodmarkFail

(String opId)

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

MethodmarkFail

(String key)

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

MethodmessageListenerContainer

()

emon-lib/src/main/java/io/splitet/core/api/emon/configuration/EventListenConfiguration.java:69

MethodnextId

()

java-api/src/main/java/io/splitet/core/api/impl/UUIDCreationStrategy.java:11

MethodonApplicationEvent

(ApplicationReadyEvent applicationReadyEvent)

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

MethodonApplicationEvent

(ApplicationReadyEvent applicationReadyEvent)

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

MethodonChange

(QuorumEvent quorumEvent)

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

MethodonEventMessage

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

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

MethodonEventMessage

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

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

MethodonEventMessage

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

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

MethodonIdleContainer

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

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

MethodonIdleContainer

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

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

MethodonMessage

(ConsumerRecord<String, Serializable> data)

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

MethodonMessage

(ConsumerRecord<byte[], byte[]> data)

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

MethodonMessage

(Message<Topology> message)

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

MethodonOperationMessage

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

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

MethodonOperationMessage

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

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

MethodonOperationMessage

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

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

MethodonPartitionsAssigned

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

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

← previous next →201–300 of 386, ranked by callers