Skip to content

Commit cdb838c

Browse files
feat(specs): add new ingestion property for push (generated)
algolia/api-clients-automation#5007 Co-authored-by: algolia-bot <[email protected]> Co-authored-by: Clément Vannicatte <[email protected]>
1 parent 11a32bb commit cdb838c

File tree

2 files changed

+31
-10
lines changed

2 files changed

+31
-10
lines changed

algoliasearch/src/main/java/com/algolia/api/IngestionClient.java

Lines changed: 29 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -3133,6 +3133,9 @@ public CompletableFuture<ListTransformationsResponse> listTransformationsAsync()
31333133
* @param pushTaskPayload (required)
31343134
* @param watch When provided, the push operation will be synchronous and the API will wait for
31353135
* the ingestion to be finished before responding. (optional)
3136+
* @param referenceIndexName This is required when targeting an index that does not have a push
3137+
* connector setup (e.g. a tmp index), but you wish to attach another index's transformation
3138+
* to it (e.g. the source index name). (optional)
31363139
* @param requestOptions The requestOptions to send along with the query, they will be merged with
31373140
* the transporter requestOptions.
31383141
* @throws AlgoliaRuntimeException If it fails to process the API call
@@ -3141,9 +3144,10 @@ public WatchResponse push(
31413144
@Nonnull String indexName,
31423145
@Nonnull PushTaskPayload pushTaskPayload,
31433146
Boolean watch,
3147+
String referenceIndexName,
31443148
@Nullable RequestOptions requestOptions
31453149
) throws AlgoliaRuntimeException {
3146-
return LaunderThrowable.await(pushAsync(indexName, pushTaskPayload, watch, requestOptions));
3150+
return LaunderThrowable.await(pushAsync(indexName, pushTaskPayload, watch, referenceIndexName, requestOptions));
31473151
}
31483152

31493153
/**
@@ -3160,11 +3164,14 @@ public WatchResponse push(
31603164
* @param pushTaskPayload (required)
31613165
* @param watch When provided, the push operation will be synchronous and the API will wait for
31623166
* the ingestion to be finished before responding. (optional)
3167+
* @param referenceIndexName This is required when targeting an index that does not have a push
3168+
* connector setup (e.g. a tmp index), but you wish to attach another index's transformation
3169+
* to it (e.g. the source index name). (optional)
31633170
* @throws AlgoliaRuntimeException If it fails to process the API call
31643171
*/
3165-
public WatchResponse push(@Nonnull String indexName, @Nonnull PushTaskPayload pushTaskPayload, Boolean watch)
3172+
public WatchResponse push(@Nonnull String indexName, @Nonnull PushTaskPayload pushTaskPayload, Boolean watch, String referenceIndexName)
31663173
throws AlgoliaRuntimeException {
3167-
return this.push(indexName, pushTaskPayload, watch, null);
3174+
return this.push(indexName, pushTaskPayload, watch, referenceIndexName, null);
31683175
}
31693176

31703177
/**
@@ -3185,7 +3192,7 @@ public WatchResponse push(@Nonnull String indexName, @Nonnull PushTaskPayload pu
31853192
*/
31863193
public WatchResponse push(@Nonnull String indexName, @Nonnull PushTaskPayload pushTaskPayload, @Nullable RequestOptions requestOptions)
31873194
throws AlgoliaRuntimeException {
3188-
return this.push(indexName, pushTaskPayload, null, requestOptions);
3195+
return this.push(indexName, pushTaskPayload, null, null, requestOptions);
31893196
}
31903197

31913198
/**
@@ -3203,7 +3210,7 @@ public WatchResponse push(@Nonnull String indexName, @Nonnull PushTaskPayload pu
32033210
* @throws AlgoliaRuntimeException If it fails to process the API call
32043211
*/
32053212
public WatchResponse push(@Nonnull String indexName, @Nonnull PushTaskPayload pushTaskPayload) throws AlgoliaRuntimeException {
3206-
return this.push(indexName, pushTaskPayload, null, null);
3213+
return this.push(indexName, pushTaskPayload, null, null, null);
32073214
}
32083215

32093216
/**
@@ -3220,6 +3227,9 @@ public WatchResponse push(@Nonnull String indexName, @Nonnull PushTaskPayload pu
32203227
* @param pushTaskPayload (required)
32213228
* @param watch When provided, the push operation will be synchronous and the API will wait for
32223229
* the ingestion to be finished before responding. (optional)
3230+
* @param referenceIndexName This is required when targeting an index that does not have a push
3231+
* connector setup (e.g. a tmp index), but you wish to attach another index's transformation
3232+
* to it (e.g. the source index name). (optional)
32233233
* @param requestOptions The requestOptions to send along with the query, they will be merged with
32243234
* the transporter requestOptions.
32253235
* @throws AlgoliaRuntimeException If it fails to process the API call
@@ -3228,6 +3238,7 @@ public CompletableFuture<WatchResponse> pushAsync(
32283238
@Nonnull String indexName,
32293239
@Nonnull PushTaskPayload pushTaskPayload,
32303240
Boolean watch,
3241+
String referenceIndexName,
32313242
@Nullable RequestOptions requestOptions
32323243
) throws AlgoliaRuntimeException {
32333244
Parameters.requireNonNull(indexName, "Parameter `indexName` is required when calling `push`.");
@@ -3239,6 +3250,7 @@ public CompletableFuture<WatchResponse> pushAsync(
32393250
.setMethod("POST")
32403251
.setBody(pushTaskPayload)
32413252
.addQueryParameter("watch", watch)
3253+
.addQueryParameter("referenceIndexName", referenceIndexName)
32423254
.build();
32433255
return executeAsync(
32443256
request,
@@ -3265,11 +3277,18 @@ public CompletableFuture<WatchResponse> pushAsync(
32653277
* @param pushTaskPayload (required)
32663278
* @param watch When provided, the push operation will be synchronous and the API will wait for
32673279
* the ingestion to be finished before responding. (optional)
3280+
* @param referenceIndexName This is required when targeting an index that does not have a push
3281+
* connector setup (e.g. a tmp index), but you wish to attach another index's transformation
3282+
* to it (e.g. the source index name). (optional)
32683283
* @throws AlgoliaRuntimeException If it fails to process the API call
32693284
*/
3270-
public CompletableFuture<WatchResponse> pushAsync(@Nonnull String indexName, @Nonnull PushTaskPayload pushTaskPayload, Boolean watch)
3271-
throws AlgoliaRuntimeException {
3272-
return this.pushAsync(indexName, pushTaskPayload, watch, null);
3285+
public CompletableFuture<WatchResponse> pushAsync(
3286+
@Nonnull String indexName,
3287+
@Nonnull PushTaskPayload pushTaskPayload,
3288+
Boolean watch,
3289+
String referenceIndexName
3290+
) throws AlgoliaRuntimeException {
3291+
return this.pushAsync(indexName, pushTaskPayload, watch, referenceIndexName, null);
32733292
}
32743293

32753294
/**
@@ -3293,7 +3312,7 @@ public CompletableFuture<WatchResponse> pushAsync(
32933312
@Nonnull PushTaskPayload pushTaskPayload,
32943313
@Nullable RequestOptions requestOptions
32953314
) throws AlgoliaRuntimeException {
3296-
return this.pushAsync(indexName, pushTaskPayload, null, requestOptions);
3315+
return this.pushAsync(indexName, pushTaskPayload, null, null, requestOptions);
32973316
}
32983317

32993318
/**
@@ -3312,7 +3331,7 @@ public CompletableFuture<WatchResponse> pushAsync(
33123331
*/
33133332
public CompletableFuture<WatchResponse> pushAsync(@Nonnull String indexName, @Nonnull PushTaskPayload pushTaskPayload)
33143333
throws AlgoliaRuntimeException {
3315-
return this.pushAsync(indexName, pushTaskPayload, null, null);
3334+
return this.pushAsync(indexName, pushTaskPayload, null, null, null);
33163335
}
33173336

33183337
/**

algoliasearch/src/main/java/com/algolia/api/SearchClient.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6838,6 +6838,7 @@ public <T> WatchResponse saveObjectsWithTransformation(
68386838
indexName,
68396839
new PushTaskPayload().setAction(com.algolia.model.ingestion.Action.ADD_OBJECT).setRecords(this.objectsToPushTaskRecords(objects)),
68406840
waitForTasks,
6841+
null,
68416842
requestOptions
68426843
);
68436844
}
@@ -7095,6 +7096,7 @@ public <T> WatchResponse partialUpdateObjectsWithTransformation(
70957096
)
70967097
.setRecords(this.objectsToPushTaskRecords(objects)),
70977098
waitForTasks,
7099+
null,
70987100
requestOptions
70997101
);
71007102
}

0 commit comments

Comments
 (0)