Functions — github.com/AleksK1NG/Java-Spring-CRQS-Eventsourcing-Microservice

hub / github.com/AleksK1NG/Java-Spring-CRQS-Eventsourcing-Microservice / functions

Functions101 in github.com/AleksK1NG/Java-Spring-CRQS-Eventsourcing-Microservice

⨍ Functions 101◇ Types & classes 58

↓ 9 callersMethoddeserializeFromJsonBytes

(final byte[] jsonBytes, final Class<T> valueType)

src/main/java/com/eventsourcing/es/SerializerUtils.java:34

↓ 9 callersMethodsave

(final T aggregate)

src/main/java/com/eventsourcing/es/EventStoreDB.java:11

↓ 6 callersMethodhandle

(GetBankAccountByIDQuery query)

src/main/java/com/eventsourcing/bankAccount/queries/BankAccountQueryService.java:7

↓ 6 callersMethodserializeToJsonBytes

(final Object object)

src/main/java/com/eventsourcing/es/SerializerUtils.java:26

↓ 5 callersMethodload

(final String aggregateId, final Class<T> aggregateType)

src/main/java/com/eventsourcing/es/EventStoreDB.java:13

↓ 4 callersMethodapply

(final Event event)

src/main/java/com/eventsourcing/es/AggregateRoot.java:37

↓ 4 callersMethodcreateEvent

(String eventType, byte[] data, byte[] metadata)

src/main/java/com/eventsourcing/es/AggregateRoot.java:70

↓ 4 callersMethodfindByAggregateId

(String aggregateId)

src/main/java/com/eventsourcing/bankAccount/repository/BankAccountMongoRepository.java:10

↓ 4 callersMethodhandle

(final BankAccountCreatedEvent event)

src/main/java/com/eventsourcing/bankAccount/domain/BankAccountAggregate.java:53

↓ 4 callersMethodhandle

(@SpanTag("event") BankAccountCreatedEvent event)

src/main/java/com/eventsourcing/bankAccount/projection/BankAccountMongoProjection.java:97

↓ 3 callersMethodvalidateEvent

(final Event event)

src/main/java/com/eventsourcing/es/AggregateRoot.java:65

↓ 2 callersMethodaggregateFromSnapshot

(final Snapshot snapshot, final Class<T> valueType)

src/main/java/com/eventsourcing/es/EventSourcingUtils.java:28

↓ 2 callersMethodbankAccountDocumentFromAggregate

(BankAccountAggregate bankAccountAggregate)

src/main/java/com/eventsourcing/mappers/BankAccountMapper.java:33

↓ 2 callersMethodraiseEvent

(final Event event)

src/main/java/com/eventsourcing/es/AggregateRoot.java:48

↓ 2 callersMethodsnapshotFromAggregate

(final T aggregate)

src/main/java/com/eventsourcing/es/EventSourcingUtils.java:16

↓ 2 callersMethodtoString

()

src/main/java/com/eventsourcing/bankAccount/domain/BankAccountAggregate.java:113

↓ 2 callersMethodwhen

(final Event event)

src/main/java/com/eventsourcing/es/AggregateRoot.java:27

↓ 1 callersMethodbankAccountResponseDTOFromAggregate

(BankAccountAggregate bankAccountAggregate)

src/main/java/com/eventsourcing/mappers/BankAccountMapper.java:13

↓ 1 callersMethodbankAccountResponseDTOFromDocument

(BankAccountDocument bankAccountDocument)

src/main/java/com/eventsourcing/mappers/BankAccountMapper.java:23

↓ 1 callersMethodchangeAddress

(String newAddress)

src/main/java/com/eventsourcing/bankAccount/domain/BankAccountAggregate.java:98

↓ 1 callersMethodchangeEmail

(String email)

src/main/java/com/eventsourcing/bankAccount/domain/BankAccountAggregate.java:90

↓ 1 callersMethodclearChanges

()

src/main/java/com/eventsourcing/es/AggregateRoot.java:57

↓ 1 callersMethodconsumerProps

()

src/main/java/com/eventsourcing/configuration/KafkaConsumerConfig.java:47

↓ 1 callersMethodcreateBankAccount

(String email, String address, String userName)

src/main/java/com/eventsourcing/bankAccount/domain/BankAccountAggregate.java:77

↓ 1 callersMethoddeleteByAggregateId

(String aggregateId)

src/main/java/com/eventsourcing/bankAccount/repository/BankAccountMongoRepository.java:12

↓ 1 callersMethoddepositBalance

(BigDecimal amount)

src/main/java/com/eventsourcing/bankAccount/domain/BankAccountAggregate.java:105

↓ 1 callersMethoddeserializeEventsFromJsonBytes

(final byte[] jsonBytes)

src/main/java/com/eventsourcing/es/SerializerUtils.java:42

↓ 1 callersMethodeventsBatchInsert

(@SpanTag("events") List<Event> events)

src/main/java/com/eventsourcing/es/EventStore.java:104

↓ 1 callersMethodgetAggregate

(@SpanTag("aggregateId") final String aggregateId, @SpanTag("aggregateType") final Class<T> aggregateType)

src/main/java/com/eventsourcing/es/EventStore.java:166

↓ 1 callersMethodgetSnapshotFromClass

(@SpanTag("snapshot") Optional<Snapshot> snapshot, @SpanTag("aggregateId") String aggregateId, @SpanTag("aggre

src/main/java/com/eventsourcing/es/EventStore.java:175

↓ 1 callersMethodhandleConcurrency

(@SpanTag("aggregateId") String aggregateId)

src/main/java/com/eventsourcing/es/EventStore.java:143

↓ 1 callersMethodloadEvents

(@SpanTag("aggregateId") String aggregateId, @SpanTag("version") long version)

src/main/java/com/eventsourcing/es/EventStore.java:112

↓ 1 callersMethodloadSnapshot

(@SpanTag("aggregateId") String aggregateId)

src/main/java/com/eventsourcing/es/EventStore.java:154

↓ 1 callersMethodmapFromEvent

(Event event)

src/main/java/com/eventsourcing/es/EventStore.java:93

↓ 1 callersMethodprocessEvents

(@SpanTag("events") List<Event> events)

src/main/java/com/eventsourcing/bankAccount/projection/BankAccountMongoProjection.java:60

↓ 1 callersMethodpublish

(List<Event> events)

src/main/java/com/eventsourcing/es/EventBus.java:6

↓ 1 callersMethodsaveEvents

(@SpanTag("events") List<Event> events)

src/main/java/com/eventsourcing/es/EventStore.java:77

↓ 1 callersMethodsaveSnapshot

(@SpanTag("aggregate") T aggregate)

src/main/java/com/eventsourcing/es/EventStore.java:127

↓ 1 callersMethodsenderProps

()

src/main/java/com/eventsourcing/configuration/KafkaProducerConfig.java:25

↓ 1 callersMethodtoSnapshot

()

src/main/java/com/eventsourcing/es/AggregateRoot.java:61

↓ 1 callersMethodtoString

()

src/main/java/com/eventsourcing/es/Event.java:34

↓ 1 callersMethodtoString

()

src/main/java/com/eventsourcing/es/AggregateRoot.java:83

MethodAddressUpdatedEvent

(String aggregateId, String newAddress)

src/main/java/com/eventsourcing/bankAccount/events/AddressUpdatedEvent.java:13

MethodAggregateNotFoundException

()

src/main/java/com/eventsourcing/es/exceptions/AggregateNotFoundException.java:4

MethodAggregateRoot

(final String id, final String aggregateType)

src/main/java/com/eventsourcing/es/AggregateRoot.java:21

MethodBalanceDepositedEvent

(String aggregateId, BigDecimal amount)

src/main/java/com/eventsourcing/bankAccount/events/BalanceDepositedEvent.java:17

MethodBankAccountAggregate

(String id)

src/main/java/com/eventsourcing/bankAccount/domain/BankAccountAggregate.java:28

MethodBankAccountCreatedEvent

(String aggregateId, String email, String userName, String address)

src/main/java/com/eventsourcing/bankAccount/events/BankAccountCreatedEvent.java:13

MethodBankAccountDocumentNotFoundException

()

src/main/java/com/eventsourcing/bankAccount/exceptions/BankAccountDocumentNotFoundException.java:4

MethodBankAccountMapper

()

src/main/java/com/eventsourcing/mappers/BankAccountMapper.java:9

MethodBankAccountNotFoundException

()

src/main/java/com/eventsourcing/bankAccount/exceptions/BankAccountNotFoundException.java:5

MethodBaseEvent

(String aggregateId)

src/main/java/com/eventsourcing/es/BaseEvent.java:13

MethodConstants

()

src/main/java/com/eventsourcing/es/Constants.java:5

MethodEmailChangedEvent

(String aggregateId, String newEmail)

src/main/java/com/eventsourcing/bankAccount/events/EmailChangedEvent.java:15

MethodEvent

(String eventType, String aggregateType)

src/main/java/com/eventsourcing/es/Event.java:26

MethodEventSourcingUtils

()

src/main/java/com/eventsourcing/es/EventSourcingUtils.java:9

MethodInternalServerErrorException

()

src/main/java/com/eventsourcing/exceptions/InternalServerErrorException.java:4

MethodInvalidAddressException

()

src/main/java/com/eventsourcing/bankAccount/exceptions/InvalidAddressException.java:4

MethodInvalidEmailException

()

src/main/java/com/eventsourcing/bankAccount/exceptions/InvalidEmailException.java:4

MethodInvalidEventException

()

src/main/java/com/eventsourcing/es/exceptions/InvalidEventException.java:4

MethodInvalidEventTypeException

()

src/main/java/com/eventsourcing/es/exceptions/InvalidEventTypeException.java:4

MethodSerializerUtils

()

src/main/java/com/eventsourcing/es/SerializerUtils.java:23

MethodUnknownEventTypeException

()

src/main/java/com/eventsourcing/exceptions/UnknownEventTypeException.java:4

MethodbankAccountEventStoreTopicInitializer

(KafkaAdmin kafkaAdmin)

src/main/java/com/eventsourcing/configuration/KafkaTopicConfiguration.java:34

MethodbankAccountMongoProjectionListener

(@Payload byte[] data, ConsumerRecordMetadata meta, Acknowledgment ack)

src/main/java/com/eventsourcing/bankAccount/projection/BankAccountMongoProjection.java:43

MethodchangeAddress

(@Valid @RequestBody ChangeAddressRequestDTO dto, @PathVariable String aggregateId)

src/main/java/com/eventsourcing/bankAccount/delivery/BankAccountController.java:55

MethodchangeEmail

(@Valid @RequestBody ChangeEmailRequestDTO dto, @PathVariable String aggregateId)

src/main/java/com/eventsourcing/bankAccount/delivery/BankAccountController.java:49

MethodconsumerFactory

()

src/main/java/com/eventsourcing/configuration/KafkaConsumerConfig.java:42

MethodcontextLoads

()

src/test/java/com/eventsourcing/SpringEventSourcingApplicationTests.java:9

MethodcreateBankAccount

(@Valid @RequestBody CreateBankAccountRequestDTO dto)

src/main/java/com/eventsourcing/bankAccount/delivery/BankAccountController.java:35

MethoddepositAmount

(@Valid @RequestBody DepositAmountRequestDTO dto, @PathVariable String aggregateId)

src/main/java/com/eventsourcing/bankAccount/delivery/BankAccountController.java:43

MethoddeserializeEventsMetadata

(final byte[] metaData)

src/main/java/com/eventsourcing/es/SerializerUtils.java:50

Methodexists

(final String aggregateId)

src/main/java/com/eventsourcing/es/EventStoreDB.java:15

Methodexists

(@SpanTag("aggregateId") String aggregateId)

src/main/java/com/eventsourcing/es/EventStore.java:185

MethodgetAggregateTypeTopic

(final String aggregateType)

src/main/java/com/eventsourcing/es/EventSourcingUtils.java:12

MethodgetAllOrderByBalance

(@RequestParam(name = "page", defaultValue = "0") Integer page,

src/main/java/com/eventsourcing/bankAccount/delivery/BankAccountController.java:61

MethodgetBankAccount

(@PathVariable String aggregateId)

src/main/java/com/eventsourcing/bankAccount/delivery/BankAccountController.java:28

Methodhandle

(CreateBankAccountCommand command)

src/main/java/com/eventsourcing/bankAccount/commands/BankAccountCommandService.java:4

Methodhandle

(@SpanTag("command") CreateBankAccountCommand command)

src/main/java/com/eventsourcing/bankAccount/commands/BankAccountCommandHandler.java:22

Methodhandle

(@SpanTag("query") GetBankAccountByIDQuery query)

src/main/java/com/eventsourcing/bankAccount/queries/BankAccountQueryHandler.java:32

MethodhandleAggregateNotFoundExceptions

(AggregateNotFoundException ex)

src/main/java/com/eventsourcing/filters/GlobalControllerAdvice.java:48

MethodhandleInvalidAggregateExceptions

(AggregateNotFoundException ex)

src/main/java/com/eventsourcing/filters/GlobalControllerAdvice.java:56

MethodhandleInvalidArgument

(MethodArgumentNotValidException ex)

src/main/java/com/eventsourcing/filters/GlobalControllerAdvice.java:40

MethodhandleRuntimeException

(RuntimeException ex, WebRequest request)

src/main/java/com/eventsourcing/filters/GlobalControllerAdvice.java:31

MethodkafkaAdmin

()

src/main/java/com/eventsourcing/configuration/KafkaTopicConfiguration.java:27

MethodkafkaListenerContainerFactory

(ConsumerFactory<String, byte[]> consumerFactory)

src/main/java/com/eventsourcing/configuration/KafkaConsumerConfig.java:31

MethodkafkaTemplate

(ProducerFactory<String, byte[]> producerFactory)

src/main/java/com/eventsourcing/configuration/KafkaProducerConfig.java:43

Methodload

(@SpanTag("aggregateId") String aggregateId, @SpanTag("aggregateType") Class<T> aggregateType)

src/main/java/com/eventsourcing/es/EventStore.java:56

Methodload

(final List<Event> events)

src/main/java/com/eventsourcing/es/AggregateRoot.java:29

MethodloadEvents

(final String aggregateId, long version)

src/main/java/com/eventsourcing/es/EventStoreDB.java:9

Methodmain

(String[] args)

src/main/java/com/eventsourcing/SpringEventSourcingApplication.java:9

MethodmongoInit

()

src/main/java/com/eventsourcing/configuration/MongoConfiguration.java:20

MethodproducerFactory

()

src/main/java/com/eventsourcing/configuration/KafkaProducerConfig.java:38

Methodpublish

(@SpanTag("events") List<Event> events)

src/main/java/com/eventsourcing/es/KafkaEventBus.java:27

Methodsave

(@SpanTag("aggregate") T aggregate)

src/main/java/com/eventsourcing/es/EventStore.java:36

MethodsaveEvents

(final List<Event> events)

src/main/java/com/eventsourcing/es/EventStoreDB.java:7

MethodserializeEventsMetadata

(final HashMap<String, byte[]> metaData)

src/main/java/com/eventsourcing/es/SerializerUtils.java:60

MethodtoString

()

src/main/java/com/eventsourcing/es/Snapshot.java:25

Methodwhen

(Event event)

src/main/java/com/eventsourcing/bankAccount/domain/BankAccountAggregate.java:38

Methodwhen

(@SpanTag("event") Event event)

src/main/java/com/eventsourcing/bankAccount/projection/BankAccountMongoProjection.java:75

next →1–100 of 101, ranked by callers