Module task_service

Modules

exchange_service_client

Generated client implementations.

exchange_service_server

Generated server implementations.

fast_insert_response

Nested message and enum types in FastInsertResponse.

get_stream_request

Nested message and enum types in GetStreamRequest.

permits

Nested message and enum types in Permits.

task_info_response

Nested message and enum types in TaskInfoResponse.

task_service_client

Generated client implementations.

task_service_server

Generated server implementations.

Structs

CancelTaskRequest

CancelTaskResponse

CreateTaskRequest

ExecuteRequest

FastInsertRequest

FastInsertResponse

GetDataRequest

GetDataResponse

GetStreamRequest

GetStreamResponse

GetTaskInfoRequest

Permits

The structure for permit-based back-pressure.

TaskId

Task is a running instance of Stage.

TaskInfoResponse

Type Aliases

PbCancelTaskRequest

PbCancelTaskResponse

PbCreateTaskRequest

PbExecuteRequest

PbFastInsertRequest

PbFastInsertResponse

PbGetDataRequest

PbGetDataResponse

PbGetStreamRequest

PbGetStreamResponse

PbGetTaskInfoRequest

PbPermits

PbTaskId

PbTaskInfoResponse