risingwave_pb

Module task_service

Source

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
Alias for CancelTaskRequest.
PbCancelTaskResponse
Alias for CancelTaskResponse.
PbCreateTaskRequest
Alias for CreateTaskRequest.
PbExecuteRequest
Alias for ExecuteRequest.
PbFastInsertRequest
Alias for FastInsertRequest.
PbFastInsertResponse
Alias for FastInsertResponse.
PbGetDataRequest
Alias for GetDataRequest.
PbGetDataResponse
Alias for GetDataResponse.
PbGetStreamRequest
Alias for GetStreamRequest.
PbGetStreamResponse
Alias for GetStreamResponse.
PbGetTaskInfoRequest
Alias for GetTaskInfoRequest.
PbPermits
Alias for Permits.
PbTaskId
Alias for TaskId.
PbTaskInfoResponse
Alias for TaskInfoResponse.