Package-level declarations
Types
Link copied to clipboard
Default implementation of TaskBridgeRouteResolver using standard api/v1/tasks paths.
Link copied to clipboard
The main entry point for interacting with the TaskBridge backend.
Link copied to clipboard
data class TaskBridgeConfig<Ctx>(val baseUrl: String, val transportFactory: TaskBridgeTransportFactory<Ctx>, val routeResolver: TaskBridgeRouteResolver<Ctx> = DefaultTaskBridgeRouteResolver(), val authHeaderProvider: suspend (context: Ctx, forceRefresh: Boolean) -> String?? = null, val checkpointStore: TaskBridgeCheckpointStore = InMemoryTaskBridgeCheckpointStore(), val checkpointNamespace: String? = null, val failureClassifier: TaskBridgeFailureClassifier = DefaultTaskBridgeFailureClassifier(), val retryPolicy: TaskBridgeRetryPolicy = ExponentialBackoffTaskBridgeRetryPolicy(), val retryGate: TransportRetryGate = NoOpTransportRetryGate, val streamTransport: TaskBridgeStreamTransportConfig = TaskBridgeStreamTransportConfig(), val transportEventListener: TaskBridgeTransportEventListener<Ctx>? = null, val json: Json = taskBridgeJson(), val dispatcher: CoroutineDispatcher = Dispatchers.IO, val commandMaxAttempts: Int = 3)
Configuration for TaskBridgeClient.
Link copied to clipboard
Produces URL paths for all TaskBridge HTTP and WebSocket endpoints.
Functions
Link copied to clipboard
suspend fun TaskBridgeClient<Unit>.cancelTask(taskId: String, reason: String? = null): CancelTaskResponse
Link copied to clipboard
fun TaskBridgeClient<Unit>.observeTaskEvents(taskId: String, lastEventId: String? = null): Flow<TaskEvent>
Link copied to clipboard
suspend fun TaskBridgeClient<Unit>.startTaskJson(request: TaskCreateJsonRequest): TaskCreatedResponse
Extension methods for TaskBridgeClient with Unit context to maintain backward compatibility.
Link copied to clipboard
suspend fun TaskBridgeClient<Unit>.startTaskMultipart(clientRequestId: String, taskType: String, inputJson: String?, metadataJson: String?, attachments: List<TaskBridgeMultipartAttachment>): TaskCreatedResponse
Link copied to clipboard
suspend fun TaskBridgeClient<Unit>.submitAction(taskId: String, action: TaskActionRequest): SubmitActionResponse