Module meta

Modules

• actor_count_per_parallelism
  Nested message and enum types in ActorCountPerParallelism.
• add_event_log_request
  Nested message and enum types in AddEventLogRequest.
• add_worker_node_request
  Nested message and enum types in AddWorkerNodeRequest.
• cancel_creating_jobs_request
  Nested message and enum types in CancelCreatingJobsRequest.
• cluster_limit
  Nested message and enum types in ClusterLimit.
• cluster_limit_service_client
  Generated client implementations.
• cluster_limit_service_server
  Generated server implementations.
• cluster_service_client
  Generated client implementations.
• cluster_service_server
  Generated server implementations.
• event_log
  Nested message and enum types in EventLog.
• event_log_service_client
  Generated client implementations.
• event_log_service_server
  Generated server implementations.
• get_serverless_streaming_jobs_status_response
  Nested message and enum types in GetServerlessStreamingJobsStatusResponse.
• heartbeat_service_client
  Generated client implementations.
• heartbeat_service_server
  Generated server implementations.
• list_actor_splits_response
  Nested message and enum types in ListActorSplitsResponse.
• list_actor_states_response
  Nested message and enum types in ListActorStatesResponse.
• list_fragment_distribution_response
  Nested message and enum types in ListFragmentDistributionResponse.
• list_object_dependencies_response
  Nested message and enum types in ListObjectDependenciesResponse.
• list_rate_limits_response
  Nested message and enum types in ListRateLimitsResponse.
• list_table_fragment_states_response
  Nested message and enum types in ListTableFragmentStatesResponse.
• list_table_fragments_response
  Nested message and enum types in ListTableFragmentsResponse.
• meta_member_service_client
  Generated client implementations.
• meta_member_service_server
  Generated server implementations.
• meta_snapshot
  Nested message and enum types in MetaSnapshot.
• notification_service_client
  Generated client implementations.
• notification_service_server
  Generated server implementations.
• relation
  Nested message and enum types in Relation.
• scale_service_client
  Generated client implementations.
• scale_service_server
  Generated server implementations.
• serving_service_client
  Generated client implementations.
• serving_service_server
  Generated server implementations.
• session_param_service_client
  Generated client implementations.
• session_param_service_server
  Generated server implementations.
• stream_manager_service_client
  Generated client implementations.
• stream_manager_service_server
  Generated server implementations.
• subscribe_response
  Nested message and enum types in SubscribeResponse.
• system_params_service_client
  Generated client implementations.
• system_params_service_server
  Generated server implementations.
• table_fragments
  Nested message and enum types in TableFragments.
• table_parallelism
  Nested message and enum types in TableParallelism.
• telemetry_info_service_client
  Generated client implementations.
• telemetry_info_service_server
  Generated server implementations.
• update_worker_node_schedulability_request
  Nested message and enum types in UpdateWorkerNodeSchedulabilityRequest.

Structs

• ActivateWorkerNodeRequest
• ActivateWorkerNodeResponse
• ActorCountPerParallelism
• ActorIds
• ActorLocation
  TODO: remove this when dashboard refactored.
• AddEventLogRequest
• AddEventLogResponse
• AddWorkerNodeRequest
• AddWorkerNodeResponse
• ApplyThrottleRequest
• ApplyThrottleResponse
• CancelCreatingJobsRequest
• CancelCreatingJobsResponse
• ClusterLimit
• DeleteWorkerNodeRequest
• DeleteWorkerNodeResponse
• EventLog
• FlushRequest
• FlushResponse
• FragmentIdToActorIdMap
• FragmentVertexToRelationMap
• FragmentWorkerSlotMapping
  / Worker slot mapping with fragment id, used for notification.
• FragmentWorkerSlotMappings
• GetClusterInfoRequest
• GetClusterInfoResponse
• GetClusterLimitsRequest
• GetClusterLimitsResponse
• GetClusterRecoveryStatusRequest
• GetClusterRecoveryStatusResponse
• GetServerlessStreamingJobsStatusRequest
• GetServerlessStreamingJobsStatusResponse
  Descriptions of MVs and sinks
• GetServingVnodeMappingsRequest
• GetServingVnodeMappingsResponse
• GetSessionParamsRequest
• GetSessionParamsResponse
• GetSystemParamsRequest
• GetSystemParamsResponse
• GetTelemetryInfoRequest
• HeartbeatRequest
• HeartbeatResponse
• ListActorSplitsRequest
• ListActorSplitsResponse
• ListActorStatesRequest
• ListActorStatesResponse
• ListAllNodesRequest
• ListAllNodesResponse
• ListEventLogRequest
• ListEventLogResponse
• ListFragmentDistributionRequest
• ListFragmentDistributionResponse
• ListObjectDependenciesRequest
• ListObjectDependenciesResponse
• ListRateLimitsRequest
• ListRateLimitsResponse
• ListTableFragmentStatesRequest
• ListTableFragmentStatesResponse
• ListTableFragmentsRequest
• ListTableFragmentsResponse
• MembersRequest
• MembersResponse
• MetaMember
• MetaSnapshot
• MigrationPlan
• PauseRequest
• PauseResponse
• RecoverRequest
• RecoverResponse
• Recovery
• Relation
• RelationGroup
• RelationIdInfos
  / Provides all the ids: relation_id, fragment_id, actor_id / in an hierarchical format. / relation_id -> [fragment_id] / fragment_id -> [actor_id]
• RescheduleRequest
• RescheduleResponse
• ResumeRequest
• ResumeResponse
• SetSessionParamRequest
• SetSessionParamResponse
• SetSystemParamRequest
• SetSystemParamResponse
• SubscribeRequest
  Below for notification service.
• SubscribeResponse
• SystemParams
  The schema for persisted system parameters. Note on backward compatibility:
• TableFragments
  Fragments of a Streaming Job
• TableParallelism
• TelemetryInfoResponse
• UpdateStreamingJobNodeLabelsRequest
  Changes a streaming job in place by overwriting its node_label. This may cause the re-scheduling of the streaming job actors.
• UpdateStreamingJobNodeLabelsResponse
  We do not need to add an explicit status field here, we can just use the RPC status
• UpdateWorkerNodeSchedulabilityRequest
  Mark CN as schedulable or as unschedulable
• UpdateWorkerNodeSchedulabilityResponse
• WorkerReschedule
  For each fragment that needs to be rescheduled, there will be a WorkerReschedule, indicating on which workers the actors of this fragment need to be changed and by how many.

Enums

• PausedReason
  The reason why the data sources in the cluster are paused.
• RecoveryStatus
• SubscribeType
• ThrottleTarget

Type Aliases

• PbActivateWorkerNodeRequest
  Alias for ActivateWorkerNodeRequest.
• PbActivateWorkerNodeResponse
  Alias for ActivateWorkerNodeResponse.
• PbActorCountPerParallelism
  Alias for ActorCountPerParallelism.
• PbActorIds
  Alias for ActorIds.
• PbActorLocation
  Alias for ActorLocation.
• PbAddEventLogRequest
  Alias for AddEventLogRequest.
• PbAddEventLogResponse
  Alias for AddEventLogResponse.
• PbAddWorkerNodeRequest
  Alias for AddWorkerNodeRequest.
• PbAddWorkerNodeResponse
  Alias for AddWorkerNodeResponse.
• PbApplyThrottleRequest
  Alias for ApplyThrottleRequest.
• PbApplyThrottleResponse
  Alias for ApplyThrottleResponse.
• PbCancelCreatingJobsRequest
  Alias for CancelCreatingJobsRequest.
• PbCancelCreatingJobsResponse
  Alias for CancelCreatingJobsResponse.
• PbClusterLimit
  Alias for ClusterLimit.
• PbDeleteWorkerNodeRequest
  Alias for DeleteWorkerNodeRequest.
• PbDeleteWorkerNodeResponse
  Alias for DeleteWorkerNodeResponse.
• PbEventLog
  Alias for EventLog.
• PbFlushRequest
  Alias for FlushRequest.
• PbFlushResponse
  Alias for FlushResponse.
• PbFragmentIdToActorIdMap
  Alias for FragmentIdToActorIdMap.
• PbFragmentVertexToRelationMap
  Alias for FragmentVertexToRelationMap.
• PbFragmentWorkerSlotMapping
  Alias for FragmentWorkerSlotMapping.
• PbFragmentWorkerSlotMappings
  Alias for FragmentWorkerSlotMappings.
• PbGetClusterInfoRequest
  Alias for GetClusterInfoRequest.
• PbGetClusterInfoResponse
  Alias for GetClusterInfoResponse.
• PbGetClusterLimitsRequest
  Alias for GetClusterLimitsRequest.
• PbGetClusterLimitsResponse
  Alias for GetClusterLimitsResponse.
• PbGetClusterRecoveryStatusRequest
  Alias for GetClusterRecoveryStatusRequest.
• PbGetClusterRecoveryStatusResponse
  Alias for GetClusterRecoveryStatusResponse.
• PbGetServerlessStreamingJobsStatusRequest
  Alias for GetServerlessStreamingJobsStatusRequest.
• PbGetServerlessStreamingJobsStatusResponse
  Alias for GetServerlessStreamingJobsStatusResponse.
• PbGetServingVnodeMappingsRequest
  Alias for GetServingVnodeMappingsRequest.
• PbGetServingVnodeMappingsResponse
  Alias for GetServingVnodeMappingsResponse.
• PbGetSessionParamsRequest
  Alias for GetSessionParamsRequest.
• PbGetSessionParamsResponse
  Alias for GetSessionParamsResponse.
• PbGetSystemParamsRequest
  Alias for GetSystemParamsRequest.
• PbGetSystemParamsResponse
  Alias for GetSystemParamsResponse.
• PbGetTelemetryInfoRequest
  Alias for GetTelemetryInfoRequest.
• PbHeartbeatRequest
  Alias for HeartbeatRequest.
• PbHeartbeatResponse
  Alias for HeartbeatResponse.
• PbListActorSplitsRequest
  Alias for ListActorSplitsRequest.
• PbListActorSplitsResponse
  Alias for ListActorSplitsResponse.
• PbListActorStatesRequest
  Alias for ListActorStatesRequest.
• PbListActorStatesResponse
  Alias for ListActorStatesResponse.
• PbListAllNodesRequest
  Alias for ListAllNodesRequest.
• PbListAllNodesResponse
  Alias for ListAllNodesResponse.
• PbListEventLogRequest
  Alias for ListEventLogRequest.
• PbListEventLogResponse
  Alias for ListEventLogResponse.
• PbListFragmentDistributionRequest
  Alias for ListFragmentDistributionRequest.
• PbListFragmentDistributionResponse
  Alias for ListFragmentDistributionResponse.
• PbListObjectDependenciesRequest
  Alias for ListObjectDependenciesRequest.
• PbListObjectDependenciesResponse
  Alias for ListObjectDependenciesResponse.
• PbListRateLimitsRequest
  Alias for ListRateLimitsRequest.
• PbListRateLimitsResponse
  Alias for ListRateLimitsResponse.
• PbListTableFragmentStatesRequest
  Alias for ListTableFragmentStatesRequest.
• PbListTableFragmentStatesResponse
  Alias for ListTableFragmentStatesResponse.
• PbListTableFragmentsRequest
  Alias for ListTableFragmentsRequest.
• PbListTableFragmentsResponse
  Alias for ListTableFragmentsResponse.
• PbMembersRequest
  Alias for MembersRequest.
• PbMembersResponse
  Alias for MembersResponse.
• PbMetaMember
  Alias for MetaMember.
• PbMetaSnapshot
  Alias for MetaSnapshot.
• PbMigrationPlan
  Alias for MigrationPlan.
• PbPauseRequest
  Alias for PauseRequest.
• PbPauseResponse
  Alias for PauseResponse.
• PbPausedReason
  Alias for PausedReason.
• PbRecoverRequest
  Alias for RecoverRequest.
• PbRecoverResponse
  Alias for RecoverResponse.
• PbRecovery
  Alias for Recovery.
• PbRecoveryStatus
  Alias for RecoveryStatus.
• PbRelation
  Alias for Relation.
• PbRelationGroup
  Alias for RelationGroup.
• PbRelationIdInfos
  Alias for RelationIdInfos.
• PbRescheduleRequest
  Alias for RescheduleRequest.
• PbRescheduleResponse
  Alias for RescheduleResponse.
• PbResumeRequest
  Alias for ResumeRequest.
• PbResumeResponse
  Alias for ResumeResponse.
• PbSetSessionParamRequest
  Alias for SetSessionParamRequest.
• PbSetSessionParamResponse
  Alias for SetSessionParamResponse.
• PbSetSystemParamRequest
  Alias for SetSystemParamRequest.
• PbSetSystemParamResponse
  Alias for SetSystemParamResponse.
• PbSubscribeRequest
  Alias for SubscribeRequest.
• PbSubscribeResponse
  Alias for SubscribeResponse.
• PbSubscribeType
  Alias for SubscribeType.
• PbSystemParams
  Alias for SystemParams.
• PbTableFragments
  Alias for TableFragments.
• PbTableParallelism
  Alias for TableParallelism.
• PbTelemetryInfoResponse
  Alias for TelemetryInfoResponse.
• PbThrottleTarget
  Alias for ThrottleTarget.
• PbUpdateStreamingJobNodeLabelsRequest
  Alias for UpdateStreamingJobNodeLabelsRequest.
• PbUpdateStreamingJobNodeLabelsResponse
  Alias for UpdateStreamingJobNodeLabelsResponse.
• PbUpdateWorkerNodeSchedulabilityRequest
  Alias for UpdateWorkerNodeSchedulabilityRequest.
• PbUpdateWorkerNodeSchedulabilityResponse
  Alias for UpdateWorkerNodeSchedulabilityResponse.
• PbWorkerReschedule
  Alias for WorkerReschedule.