test_class.declarator: actorSystem = ActorSystem.create()
test_class.modifier: private final
test_class.original_string: private final ActorSystem actorSystem = ActorSystem.create();
test_class.type: ActorSystem
test_class.var_name: actorSystem
test_class.declarator: updaterShardProbe = TestProbe.apply("updater", actorSystem)
test_class.modifier: private final
test_class.original_string: private final TestProbe updaterShardProbe = TestProbe.apply("updater", actorSystem);
test_class.type: TestProbe
test_class.var_name: updaterShardProbe
test_class.declarator: underTest = BulkWriteResultAckFlow.of(updaterShardProbe.ref())
test_class.modifier: private final
test_class.original_string: private final BulkWriteResultAckFlow underTest = BulkWriteResultAckFlow.of(updaterShardProbe.ref());
test_class.type: BulkWriteResultAckFlow
test_class.var_name: underTest
test_class.file: services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/write/streaming/BulkWriteResultAckFlowTest.java
test_class.identifier: BulkWriteResultAckFlowTest
test_case.body: @Test
      public void allSuccess() {
          final List<AbstractWriteModel> writeModels = generate5WriteModels();
          final BulkWriteResult result = BulkWriteResult.acknowledged(0, 3, 1, 1,
                  List.of(new BulkWriteUpsert(0, new BsonString("upsert 0")),
                          new BulkWriteUpsert(4, new BsonString("upsert 4")))
          );
  
          // WHEN
          final WriteResultAndErrors resultAndErrors = WriteResultAndErrors.success(writeModels, result);
          final String message = runBulkWriteResultAckFlowAndGetFirstLogEntry(resultAndErrors);
  
          // THEN
          actorSystem.log().info(message);
          assertThat(message).contains("Acknowledged: Success");
      }
test_case.class_method_signature: BulkWriteResultAckFlowTest.allSuccess()
test_case.full_signature: @Test public void allSuccess()
test_case.identifier: allSuccess
test_case.invocations: generate5WriteModels acknowledged of success runBulkWriteResultAckFlowAndGetFirstLogEntry info log contains assertThat
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void allSuccess()
focal_class.declarator: ERRORS_COUNTER_NAME = "search-index-update-errors"
focal_class.modifier: private static final
focal_class.original_string: private static final String ERRORS_COUNTER_NAME = "search-index-update-errors";
focal_class.type: String
focal_class.var_name: ERRORS_COUNTER_NAME
focal_class.declarator: updaterShard
focal_class.modifier: private final
focal_class.original_string: private final ActorRef updaterShard;
focal_class.type: ActorRef
focal_class.var_name: updaterShard
focal_class.declarator: errorsCounter
focal_class.modifier: private final
focal_class.original_string: private final Counter errorsCounter;
focal_class.type: Counter
focal_class.var_name: errorsCounter
focal_class.file: services/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/write/streaming/BulkWriteResultAckFlow.java
focal_class.identifier: BulkWriteResultAckFlow
focal_class.class_method_signature: BulkWriteResultAckFlow.BulkWriteResultAckFlow(final ActorRef updaterShard)
focal_class.full_signature: private  BulkWriteResultAckFlow(final ActorRef updaterShard)
focal_class.identifier: BulkWriteResultAckFlow
focal_class.modifiers: private
focal_class.parameters: (final ActorRef updaterShard)
focal_class.signature:  BulkWriteResultAckFlow(final ActorRef updaterShard)
focal_class.class_method_signature: BulkWriteResultAckFlow.of(final ActorRef updaterShard)
focal_class.full_signature: static BulkWriteResultAckFlow of(final ActorRef updaterShard)
focal_class.identifier: of
focal_class.modifiers: static
focal_class.parameters: (final ActorRef updaterShard)
focal_class.return: BulkWriteResultAckFlow
focal_class.signature: BulkWriteResultAckFlow of(final ActorRef updaterShard)
focal_class.class_method_signature: BulkWriteResultAckFlow.start()
focal_class.full_signature:  Flow<WriteResultAndErrors, String, NotUsed> start()
focal_class.identifier: start
focal_class.parameters: ()
focal_class.return: Flow<WriteResultAndErrors, String, NotUsed>
focal_class.signature: Flow<WriteResultAndErrors, String, NotUsed> start()
focal_class.class_method_signature: BulkWriteResultAckFlow.checkBulkWriteResult(final WriteResultAndErrors writeResultAndErrors)
focal_class.full_signature: private Iterable<String> checkBulkWriteResult(final WriteResultAndErrors writeResultAndErrors)
focal_class.identifier: checkBulkWriteResult
focal_class.modifiers: private
focal_class.parameters: (final WriteResultAndErrors writeResultAndErrors)
focal_class.return: Iterable<String>
focal_class.signature: Iterable<String> checkBulkWriteResult(final WriteResultAndErrors writeResultAndErrors)
focal_class.class_method_signature: BulkWriteResultAckFlow.acknowledgeFailures(final List<Metadata> things)
focal_class.full_signature: private void acknowledgeFailures(final List<Metadata> things)
focal_class.identifier: acknowledgeFailures
focal_class.modifiers: private
focal_class.parameters: (final List<Metadata> things)
focal_class.return: void
focal_class.signature: void acknowledgeFailures(final List<Metadata> things)
focal_class.class_method_signature: BulkWriteResultAckFlow.acknowledge(final List<Metadata> things,
              final Function<Metadata, UpdateThingResponse> responseCreator)
focal_class.full_signature: private void acknowledge(final List<Metadata> things,
              final Function<Metadata, UpdateThingResponse> responseCreator)
focal_class.identifier: acknowledge
focal_class.modifiers: private
focal_class.parameters: (final List<Metadata> things,
              final Function<Metadata, UpdateThingResponse> responseCreator)
focal_class.return: void
focal_class.signature: void acknowledge(final List<Metadata> things,
              final Function<Metadata, UpdateThingResponse> responseCreator)
focal_class.class_method_signature: BulkWriteResultAckFlow.createFailureResponse(final Metadata metadata)
focal_class.full_signature: private static UpdateThingResponse createFailureResponse(final Metadata metadata)
focal_class.identifier: createFailureResponse
focal_class.modifiers: private static
focal_class.parameters: (final Metadata metadata)
focal_class.return: UpdateThingResponse
focal_class.signature: UpdateThingResponse createFailureResponse(final Metadata metadata)
focal_class.class_method_signature: BulkWriteResultAckFlow.createResponse(final Metadata metadata, final boolean isSuccess)
focal_class.full_signature: private static UpdateThingResponse createResponse(final Metadata metadata, final boolean isSuccess)
focal_class.identifier: createResponse
focal_class.modifiers: private static
focal_class.parameters: (final Metadata metadata, final boolean isSuccess)
focal_class.return: UpdateThingResponse
focal_class.signature: UpdateThingResponse createResponse(final Metadata metadata, final boolean isSuccess)
focal_class.class_method_signature: BulkWriteResultAckFlow.wasNotAcknowledged(final WriteResultAndErrors writeResultAndErrors)
focal_class.full_signature: private static boolean wasNotAcknowledged(final WriteResultAndErrors writeResultAndErrors)
focal_class.identifier: wasNotAcknowledged
focal_class.modifiers: private static
focal_class.parameters: (final WriteResultAndErrors writeResultAndErrors)
focal_class.return: boolean
focal_class.signature: boolean wasNotAcknowledged(final WriteResultAndErrors writeResultAndErrors)
focal_class.class_method_signature: BulkWriteResultAckFlow.checkForConsistencyError(final WriteResultAndErrors resultAndErrors)
focal_class.full_signature: private static Optional<String> checkForConsistencyError(final WriteResultAndErrors resultAndErrors)
focal_class.identifier: checkForConsistencyError
focal_class.modifiers: private static
focal_class.parameters: (final WriteResultAndErrors resultAndErrors)
focal_class.return: Optional<String>
focal_class.signature: Optional<String> checkForConsistencyError(final WriteResultAndErrors resultAndErrors)
focal_class.class_method_signature: BulkWriteResultAckFlow.areAllIndexesWithinBounds(final List<BulkWriteError> bulkWriteErrors, final int requested)
focal_class.full_signature: private static boolean areAllIndexesWithinBounds(final List<BulkWriteError> bulkWriteErrors, final int requested)
focal_class.identifier: areAllIndexesWithinBounds
focal_class.modifiers: private static
focal_class.parameters: (final List<BulkWriteError> bulkWriteErrors, final int requested)
focal_class.return: boolean
focal_class.signature: boolean areAllIndexesWithinBounds(final List<BulkWriteError> bulkWriteErrors, final int requested)
focal_class.class_method_signature: BulkWriteResultAckFlow.getAllThings(final WriteResultAndErrors writeResultAndErrors)
focal_class.full_signature: private static List<Metadata> getAllThings(final WriteResultAndErrors writeResultAndErrors)
focal_class.identifier: getAllThings
focal_class.modifiers: private static
focal_class.parameters: (final WriteResultAndErrors writeResultAndErrors)
focal_class.return: List<Metadata>
focal_class.signature: List<Metadata> getAllThings(final WriteResultAndErrors writeResultAndErrors)
focal_class.class_method_signature: BulkWriteResultAckFlow.logResult(final String status, final WriteResultAndErrors writeResultAndErrors,
              final boolean isCompleteSuccess)
focal_class.full_signature: private static String logResult(final String status, final WriteResultAndErrors writeResultAndErrors,
              final boolean isCompleteSuccess)
focal_class.identifier: logResult
focal_class.modifiers: private static
focal_class.parameters: (final String status, final WriteResultAndErrors writeResultAndErrors,
              final boolean isCompleteSuccess)
focal_class.return: String
focal_class.signature: String logResult(final String status, final WriteResultAndErrors writeResultAndErrors,
              final boolean isCompleteSuccess)
focal_method.body: static BulkWriteResultAckFlow of(final ActorRef updaterShard) {
          return new BulkWriteResultAckFlow(updaterShard);
      }
focal_method.class_method_signature: BulkWriteResultAckFlow.of(final ActorRef updaterShard)
focal_method.full_signature: static BulkWriteResultAckFlow of(final ActorRef updaterShard)
focal_method.identifier: of
focal_method.modifiers: static
focal_method.parameters: (final ActorRef updaterShard)
focal_method.return: BulkWriteResultAckFlow
focal_method.signature: BulkWriteResultAckFlow of(final ActorRef updaterShard)