Package com.chrt.api.resources.shipping.taskartifacts

Class AsyncTaskArtifactsClient

java.lang.Object

com.chrt.api.resources.shipping.taskartifacts.AsyncTaskArtifactsClient

public class AsyncTaskArtifactsClient
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
protected ClientOptions	clientOptions
protected java.util.function.Supplier<AsyncS3ObjectClient>	s3ObjectClient
protected java.util.function.Supplier<AsyncScanClient>	scanClient

Constructor Summary

Constructors

Constructor	Description
AsyncTaskArtifactsClient(ClientOptions clientOptions)

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletableFuture<java.lang.String>	addToTaskV1(java.lang.String taskId, AddTaskArtifactReq request)	Adds a new task artifact to a task.
java.util.concurrent.CompletableFuture<java.lang.String>	addToTaskV1(java.lang.String taskId, AddTaskArtifactReq request, RequestOptions requestOptions)	Adds a new task artifact to a task.
java.util.concurrent.CompletableFuture<java.lang.Boolean>	completeV1(java.lang.String taskArtifactId)	Marks a task artifact as COMPLETED.
java.util.concurrent.CompletableFuture<java.lang.Boolean>	completeV1(java.lang.String taskArtifactId, RequestOptions requestOptions)	Marks a task artifact as COMPLETED.
java.util.concurrent.CompletableFuture<java.lang.Boolean>	deleteV1(java.lang.String taskArtifactId)	Deletes a task artifact.
java.util.concurrent.CompletableFuture<java.lang.Boolean>	deleteV1(java.lang.String taskArtifactId, RequestOptions requestOptions)	Deletes a task artifact.
AsyncS3ObjectClient	s3Object()
AsyncScanClient	scan()
java.util.concurrent.CompletableFuture<java.lang.Boolean>	skipV1(java.lang.String taskArtifactId)	Marks a task artifact as SKIPPED.
java.util.concurrent.CompletableFuture<java.lang.Boolean>	skipV1(java.lang.String taskArtifactId, RequestOptions requestOptions)	Marks a task artifact as SKIPPED.
AsyncRawTaskArtifactsClient	withRawResponse()	Get responses with HTTP metadata like headers

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

clientOptions

protected final ClientOptions clientOptions

s3ObjectClient

protected final java.util.function.Supplier<AsyncS3ObjectClient> s3ObjectClient

scanClient

protected final java.util.function.Supplier<AsyncScanClient> scanClient

Constructor Detail

AsyncTaskArtifactsClient

public AsyncTaskArtifactsClient(ClientOptions clientOptions)

Method Detail

withRawResponse

public AsyncRawTaskArtifactsClient withRawResponse()

Get responses with HTTP metadata like headers

addToTaskV1

public java.util.concurrent.CompletableFuture<java.lang.String> addToTaskV1(java.lang.String taskId,
                                                                            AddTaskArtifactReq request)

Adds a new task artifact to a task. | authz_personas=[driver_for_executor, executor_org_operators, coordinator_org_operators] | (AddTaskArtifactReq) -> (PydanticObjectId)

addToTaskV1

public java.util.concurrent.CompletableFuture<java.lang.String> addToTaskV1(java.lang.String taskId,
                                                                            AddTaskArtifactReq request,
                                                                            RequestOptions requestOptions)

Adds a new task artifact to a task. | authz_personas=[driver_for_executor, executor_org_operators, coordinator_org_operators] | (AddTaskArtifactReq) -> (PydanticObjectId)

completeV1

public java.util.concurrent.CompletableFuture<java.lang.Boolean> completeV1(java.lang.String taskArtifactId)

Marks a task artifact as COMPLETED. | authz_personas=[driver_for_executor, executor_org_operators, coordinator_org_operators] | () -> (bool)

completeV1

public java.util.concurrent.CompletableFuture<java.lang.Boolean> completeV1(java.lang.String taskArtifactId,
                                                                            RequestOptions requestOptions)

Marks a task artifact as COMPLETED. | authz_personas=[driver_for_executor, executor_org_operators, coordinator_org_operators] | () -> (bool)

skipV1

public java.util.concurrent.CompletableFuture<java.lang.Boolean> skipV1(java.lang.String taskArtifactId)

Marks a task artifact as SKIPPED. | authz_personas=[driver_for_executor, executor_org_operators, coordinator_org_operators] | () -> (bool)

skipV1

public java.util.concurrent.CompletableFuture<java.lang.Boolean> skipV1(java.lang.String taskArtifactId,
                                                                        RequestOptions requestOptions)

Marks a task artifact as SKIPPED. | authz_personas=[driver_for_executor, executor_org_operators, coordinator_org_operators] | () -> (bool)

deleteV1

public java.util.concurrent.CompletableFuture<java.lang.Boolean> deleteV1(java.lang.String taskArtifactId)

Deletes a task artifact. | authz_personas=[lig_owner_operators] | () -> (bool)

deleteV1

public java.util.concurrent.CompletableFuture<java.lang.Boolean> deleteV1(java.lang.String taskArtifactId,
                                                                          RequestOptions requestOptions)

Deletes a task artifact. | authz_personas=[lig_owner_operators] | () -> (bool)

s3Object

public AsyncS3ObjectClient s3Object()

scan

public AsyncScanClient scan()