risingwave_pb

Trait Message

source
pub trait Message:
    Debug
    + Send
    + Sync {
    // Required methods
    fn encoded_len(&self) -> usize;
    fn clear(&mut self);

    // Provided methods
    fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>
       where Self: Sized { ... }
    fn encode_to_vec(&self) -> Vec<u8>
       where Self: Sized { ... }
    fn encode_length_delimited(
        &self,
        buf: &mut impl BufMut,
    ) -> Result<(), EncodeError>
       where Self: Sized { ... }
    fn encode_length_delimited_to_vec(&self) -> Vec<u8>
       where Self: Sized { ... }
    fn decode(buf: impl Buf) -> Result<Self, DecodeError>
       where Self: Default { ... }
    fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>
       where Self: Default { ... }
    fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>
       where Self: Sized { ... }
    fn merge_length_delimited(
        &mut self,
        buf: impl Buf,
    ) -> Result<(), DecodeError>
       where Self: Sized { ... }
}
Expand description

A Protocol Buffers message.

Required Methods§

source

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

source

fn clear(&mut self)

Clears the message, resetting all fields to their default.

Provided Methods§

source

fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>
where Self: Sized,

Encodes the message to a buffer.

An error will be returned if the buffer does not have sufficient capacity.

source

fn encode_to_vec(&self) -> Vec<u8>
where Self: Sized,

Encodes the message to a newly allocated buffer.

source

fn encode_length_delimited( &self, buf: &mut impl BufMut, ) -> Result<(), EncodeError>
where Self: Sized,

Encodes the message with a length-delimiter to a buffer.

An error will be returned if the buffer does not have sufficient capacity.

source

fn encode_length_delimited_to_vec(&self) -> Vec<u8>
where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

source

fn decode(buf: impl Buf) -> Result<Self, DecodeError>
where Self: Default,

Decodes an instance of the message from a buffer.

The entire buffer will be consumed.

source

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>
where Self: Default,

Decodes a length-delimited instance of the message from the buffer.

source

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>
where Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

The entire buffer will be consumed.

source

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>
where Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

Implementations on Foreign Types§

source§

impl Message for bool

google.protobuf.BoolValue

source§

fn encoded_len(&self) -> usize

source§

fn clear(&mut self)

source§

impl Message for f32

google.protobuf.FloatValue

source§

fn encoded_len(&self) -> usize

source§

fn clear(&mut self)

source§

impl Message for f64

google.protobuf.DoubleValue

source§

fn encoded_len(&self) -> usize

source§

fn clear(&mut self)

source§

impl Message for i32

google.protobuf.Int32Value

source§

fn encoded_len(&self) -> usize

source§

fn clear(&mut self)

source§

impl Message for i64

google.protobuf.Int64Value

source§

fn encoded_len(&self) -> usize

source§

fn clear(&mut self)

source§

impl Message for u32

google.protobuf.UInt32Value

source§

fn encoded_len(&self) -> usize

source§

fn clear(&mut self)

source§

impl Message for u64

google.protobuf.UInt64Value

source§

fn encoded_len(&self) -> usize

source§

fn clear(&mut self)

source§

impl Message for ()

google.protobuf.Empty

source§

fn encoded_len(&self) -> usize

source§

fn clear(&mut self)

source§

impl Message for String

google.protobuf.StringValue

source§

fn encoded_len(&self) -> usize

source§

fn clear(&mut self)

source§

impl Message for Vec<u8>

google.protobuf.BytesValue

source§

fn encoded_len(&self) -> usize

source§

fn clear(&mut self)

source§

impl Message for Bytes

google.protobuf.BytesValue

source§

fn encoded_len(&self) -> usize

source§

fn clear(&mut self)

source§

impl<M> Message for Box<M>
where M: Message,

source§

fn encoded_len(&self) -> usize

source§

fn clear(&mut self)

Implementors§

source§

impl Message for BackupMetaRequest

source§

impl Message for BackupMetaResponse

source§

impl Message for DeleteMetaSnapshotRequest

source§

impl Message for DeleteMetaSnapshotResponse

source§

impl Message for GetBackupJobStatusRequest

source§

impl Message for GetBackupJobStatusResponse

source§

impl Message for GetMetaSnapshotManifestRequest

source§

impl Message for GetMetaSnapshotManifestResponse

source§

impl Message for MetaBackupManifestId

source§

impl Message for MetaSnapshotManifest

source§

impl Message for MetaSnapshotMetadata

source§

impl Message for BroadcastInfo

source§

impl Message for ConsistentHashInfo

source§

impl Message for HashInfo

source§

impl Message for risingwave_pb::batch_plan::expand_node::Subset

source§

impl Message for risingwave_pb::batch_plan::scan_range::Bound

source§

impl Message for DeleteNode

source§

impl Message for DistributedLookupJoinNode

source§

impl Message for ExchangeInfo

source§

impl Message for risingwave_pb::batch_plan::ExchangeNode

source§

impl Message for ExchangeSource

source§

impl Message for risingwave_pb::batch_plan::ExpandNode

source§

impl Message for FileScanNode

source§

impl Message for risingwave_pb::batch_plan::FilterNode

source§

impl Message for risingwave_pb::batch_plan::GroupTopNNode

source§

impl Message for risingwave_pb::batch_plan::HashAggNode

source§

impl Message for risingwave_pb::batch_plan::HashJoinNode

source§

impl Message for risingwave_pb::batch_plan::HopWindowNode

source§

impl Message for IcebergScanNode

source§

impl Message for InsertNode

source§

impl Message for LimitNode

source§

impl Message for LocalExecutePlan

source§

impl Message for LocalLookupJoinNode

source§

impl Message for LogRowSeqScanNode

source§

impl Message for MaxOneRowNode

source§

impl Message for MergeSortExchangeNode

source§

impl Message for MySqlQueryNode

source§

impl Message for NestedLoopJoinNode

source§

impl Message for PlanFragment

source§

impl Message for PlanNode

source§

impl Message for PostgresQueryNode

source§

impl Message for risingwave_pb::batch_plan::ProjectNode

source§

impl Message for risingwave_pb::batch_plan::ProjectSetNode

source§

impl Message for RowSeqScanNode

source§

impl Message for ScanRange

source§

impl Message for SortAggNode

source§

impl Message for SortMergeJoinNode

source§

impl Message for risingwave_pb::batch_plan::SortNode

source§

impl Message for SortOverWindowNode

source§

impl Message for risingwave_pb::batch_plan::SourceNode

source§

impl Message for SysRowSeqScanNode

source§

impl Message for TableFunctionNode

source§

impl Message for risingwave_pb::batch_plan::TaskId

source§

impl Message for TaskOutputId

source§

impl Message for risingwave_pb::batch_plan::TopNNode

source§

impl Message for risingwave_pb::batch_plan::UnionNode

source§

impl Message for UpdateNode

source§

impl Message for risingwave_pb::batch_plan::ValuesNode

source§

impl Message for risingwave_pb::batch_plan::values_node::ExprTuple

source§

impl Message for PrivateLinkService

source§

impl Message for AggregateFunction

source§

impl Message for ScalarFunction

source§

impl Message for risingwave_pb::catalog::function::TableFunction

source§

impl Message for ColIndexMapping

source§

impl Message for Comment

source§

impl Message for Connection

source§

impl Message for Database

source§

impl Message for Function

source§

impl Message for Index

source§

impl Message for IndexColumnProperties

source§

impl Message for OptionsWithSecret

source§

impl Message for Schema

source§

impl Message for risingwave_pb::catalog::Secret

source§

impl Message for Sink

source§

impl Message for SinkFormatDesc

source§

impl Message for Source

source§

impl Message for StreamSourceInfo

source§

impl Message for Subscription

source§

impl Message for Table

source§

impl Message for View

source§

impl Message for WatermarkDesc

source§

impl Message for TableVersion

source§

impl Message for Error

source§

impl Message for RwCloudValidateSourceRequest

source§

impl Message for RwCloudValidateSourceResponse

source§

impl Message for risingwave_pb::common::ActorInfo

source§

impl Message for risingwave_pb::common::ActorLocation

source§

impl Message for BatchQueryCommittedEpoch

source§

impl Message for BatchQueryEpoch

source§

impl Message for Buffer

source§

impl Message for ColumnOrder

source§

impl Message for HostAddress

source§

impl Message for OrderType

source§

impl Message for risingwave_pb::common::Status

source§

impl Message for WorkerNode

source§

impl Message for WorkerSlotMapping

source§

impl Message for risingwave_pb::common::worker_node::Property

source§

impl Message for Resource

source§

impl Message for DispatchCompactionTaskRequest

source§

impl Message for DispatchCompactionTaskResponse

source§

impl Message for EchoRequest

source§

impl Message for EchoResponse

source§

impl Message for ShowConfigRequest

source§

impl Message for ShowConfigResponse

source§

impl Message for CommitRequest

source§

impl Message for StartCoordinationRequest

source§

impl Message for UpdateVnodeBitmapRequest

source§

impl Message for risingwave_pb::connector_service::coordinate_response::CommitResponse

source§

impl Message for StartCoordinationResponse

source§

impl Message for ControlInfo

source§

impl Message for CommitMetadata

source§

impl Message for StartCoordinator

source§

impl Message for risingwave_pb::connector_service::sink_coordinator_stream_response::CommitResponse

source§

impl Message for risingwave_pb::connector_service::sink_coordinator_stream_response::StartResponse

source§

impl Message for SerializedMetadata

source§

impl Message for risingwave_pb::connector_service::sink_writer_stream_request::Barrier

source§

impl Message for StartSink

source§

impl Message for WriteBatch

source§

impl Message for StreamChunkPayload

source§

impl Message for BatchWrittenResponse

source§

impl Message for risingwave_pb::connector_service::sink_writer_stream_response::CommitResponse

source§

impl Message for risingwave_pb::connector_service::sink_writer_stream_response::StartResponse

source§

impl Message for CdcMessage

source§

impl Message for CoordinateRequest

source§

impl Message for CoordinateResponse

source§

impl Message for GetEventStreamRequest

source§

impl Message for GetEventStreamResponse

source§

impl Message for SinkCoordinatorStreamRequest

source§

impl Message for SinkCoordinatorStreamResponse

source§

impl Message for SinkMetadata

source§

impl Message for SinkParam

source§

impl Message for SinkWriterStreamRequest

source§

impl Message for SinkWriterStreamResponse

source§

impl Message for risingwave_pb::connector_service::TableSchema

source§

impl Message for ValidateSinkRequest

source§

impl Message for ValidateSinkResponse

source§

impl Message for ValidateSourceRequest

source§

impl Message for ValidateSourceResponse

source§

impl Message for ValidationError

source§

impl Message for Array

source§

impl Message for DataChunk

source§

impl Message for DataType

source§

impl Message for Datum

source§

impl Message for Epoch

source§

impl Message for Interval

source§

impl Message for ListArrayData

source§

impl Message for StreamChunk

source§

impl Message for StructArrayData

source§

impl Message for Terminate

source§

impl Message for ObjectNameSwapPair

source§

impl Message for AlterNameRequest

source§

impl Message for AlterNameResponse

source§

impl Message for AlterOwnerRequest

source§

impl Message for AlterOwnerResponse

source§

impl Message for AlterParallelismRequest

source§

impl Message for AlterParallelismResponse

source§

impl Message for AlterSetSchemaRequest

source§

impl Message for AlterSetSchemaResponse

source§

impl Message for AlterSourceRequest

source§

impl Message for AlterSourceResponse

source§

impl Message for AlterSwapRenameRequest

source§

impl Message for AlterSwapRenameResponse

source§

impl Message for AutoSchemaChangeRequest

source§

impl Message for AutoSchemaChangeResponse

source§

impl Message for CommentOnRequest

source§

impl Message for CommentOnResponse

source§

impl Message for CreateConnectionRequest

source§

impl Message for CreateConnectionResponse

source§

impl Message for CreateDatabaseRequest

source§

impl Message for CreateDatabaseResponse

source§

impl Message for CreateFunctionRequest

source§

impl Message for CreateFunctionResponse

source§

impl Message for CreateIndexRequest

source§

impl Message for CreateIndexResponse

source§

impl Message for CreateMaterializedViewRequest

source§

impl Message for CreateMaterializedViewResponse

source§

impl Message for CreateSchemaRequest

source§

impl Message for CreateSchemaResponse

source§

impl Message for CreateSecretRequest

source§

impl Message for CreateSecretResponse

source§

impl Message for CreateSinkRequest

source§

impl Message for CreateSinkResponse

source§

impl Message for CreateSourceRequest

source§

impl Message for CreateSourceResponse

source§

impl Message for CreateSubscriptionRequest

source§

impl Message for CreateSubscriptionResponse

source§

impl Message for CreateTableRequest

source§

impl Message for CreateTableResponse

source§

impl Message for CreateViewRequest

source§

impl Message for CreateViewResponse

source§

impl Message for DdlProgress

source§

impl Message for DropConnectionRequest

source§

impl Message for DropConnectionResponse

source§

impl Message for DropDatabaseRequest

source§

impl Message for DropDatabaseResponse

source§

impl Message for DropFunctionRequest

source§

impl Message for DropFunctionResponse

source§

impl Message for DropIndexRequest

source§

impl Message for DropIndexResponse

source§

impl Message for DropMaterializedViewRequest

source§

impl Message for DropMaterializedViewResponse

source§

impl Message for DropSchemaRequest

source§

impl Message for DropSchemaResponse

source§

impl Message for DropSecretRequest

source§

impl Message for DropSecretResponse

source§

impl Message for DropSinkRequest

source§

impl Message for DropSinkResponse

source§

impl Message for DropSourceRequest

source§

impl Message for DropSourceResponse

source§

impl Message for DropSubscriptionRequest

source§

impl Message for DropSubscriptionResponse

source§

impl Message for DropTableRequest

source§

impl Message for DropTableResponse

source§

impl Message for DropViewRequest

source§

impl Message for DropViewResponse

source§

impl Message for GetDdlProgressRequest

source§

impl Message for GetDdlProgressResponse

source§

impl Message for GetTableRequest

source§

impl Message for GetTableResponse

source§

impl Message for GetTablesRequest

source§

impl Message for GetTablesResponse

source§

impl Message for ListConnectionsRequest

source§

impl Message for ListConnectionsResponse

source§

impl Message for ReplaceTablePlan

source§

impl Message for ReplaceTablePlanRequest

source§

impl Message for ReplaceTablePlanResponse

source§

impl Message for RisectlListStateTablesRequest

source§

impl Message for RisectlListStateTablesResponse

source§

impl Message for SchemaChangeEnvelope

source§

impl Message for TableSchemaChange

source§

impl Message for WaitRequest

source§

impl Message for WaitResponse

source§

impl Message for WaitVersion

source§

impl Message for NowRexNode

source§

impl Message for AggCall

source§

impl Message for AggType

source§

impl Message for Constant

source§

impl Message for ExprNode

source§

impl Message for FunctionCall

source§

impl Message for InputRef

source§

impl Message for ProjectSetSelectItem

source§

impl Message for risingwave_pb::expr::TableFunction

source§

impl Message for UserDefinedFunction

source§

impl Message for UserDefinedFunctionMetadata

source§

impl Message for WindowFrame

source§

impl Message for WindowFunction

source§

impl Message for risingwave_pb::expr::window_frame::Bound

source§

impl Message for RangeFrameBound

source§

impl Message for RangeFrameBounds

source§

impl Message for RowsFrameBound

source§

impl Message for RowsFrameBounds

source§

impl Message for SessionFrameBounds

source§

impl Message for GetTableReplacePlanRequest

source§

impl Message for GetTableReplacePlanResponse

source§

impl Message for HealthCheckRequest

source§

impl Message for HealthCheckResponse

source§

impl Message for PickerInfo

source§

impl Message for Levels

source§

impl Message for StaleObjects

source§

impl Message for ChangeLogDelta

source§

impl Message for GroupDeltas

source§

impl Message for RunningCompactTask

source§

impl Message for risingwave_pb::hummock::report_compaction_task_request::HeartBeat

source§

impl Message for risingwave_pb::hummock::report_compaction_task_request::ReportTask

source§

impl Message for CompressionAlgorithm

source§

impl Message for MutableConfig

source§

impl Message for BranchedObject

source§

impl Message for CancelCompactTask

source§

impl Message for CancelCompactTaskRequest

source§

impl Message for CancelCompactTaskResponse

source§

impl Message for CompactStatus

source§

impl Message for CompactTask

source§

impl Message for CompactTaskAssignment

source§

impl Message for CompactTaskProgress

source§

impl Message for CompactionConfig

source§

impl Message for CompactionGroup

source§

impl Message for CompactionGroupInfo

source§

impl Message for DisableCommitEpochRequest

source§

impl Message for DisableCommitEpochResponse

source§

impl Message for EpochNewChangeLog

source§

impl Message for FullScanTask

source§

impl Message for GetAssignedCompactTaskNumRequest

source§

impl Message for GetAssignedCompactTaskNumResponse

source§

impl Message for GetCompactionScoreRequest

source§

impl Message for GetCompactionScoreResponse

source§

impl Message for GetCurrentVersionRequest

source§

impl Message for GetCurrentVersionResponse

source§

impl Message for GetNewSstIdsRequest

source§

impl Message for GetNewSstIdsResponse

source§

impl Message for GetVersionByEpochRequest

source§

impl Message for GetVersionByEpochResponse

source§

impl Message for GroupConstruct

source§

impl Message for GroupDelta

source§

impl Message for GroupDestroy

source§

impl Message for GroupMerge

source§

impl Message for HummockPinnedSnapshot

source§

impl Message for HummockPinnedVersion

source§

impl Message for HummockVersion

source§

impl Message for HummockVersionArchive

source§

impl Message for HummockVersionCheckpoint

source§

impl Message for HummockVersionDelta

source§

impl Message for HummockVersionDeltas

source§

impl Message for HummockVersionStats

source§

impl Message for InitMetadataForReplayRequest

source§

impl Message for InitMetadataForReplayResponse

source§

impl Message for InputLevel

source§

impl Message for IntraLevelDelta

source§

impl Message for risingwave_pb::hummock::KeyRange

source§

impl Message for Level

source§

impl Message for LevelHandler

source§

impl Message for ListActiveWriteLimitRequest

source§

impl Message for ListActiveWriteLimitResponse

source§

impl Message for ListBranchedObjectRequest

source§

impl Message for ListBranchedObjectResponse

source§

impl Message for ListCompactTaskAssignmentRequest

source§

impl Message for ListCompactTaskAssignmentResponse

source§

impl Message for ListCompactTaskProgressRequest

source§

impl Message for ListCompactTaskProgressResponse

source§

impl Message for ListHummockMetaConfigRequest

source§

impl Message for ListHummockMetaConfigResponse

source§

impl Message for ListVersionDeltasRequest

source§

impl Message for ListVersionDeltasResponse

source§

impl Message for MergeCompactionGroupRequest

source§

impl Message for MergeCompactionGroupResponse

source§

impl Message for NewL0SubLevel

source§

impl Message for OverlappingLevel

source§

impl Message for PinVersionRequest

source§

impl Message for PinVersionResponse

source§

impl Message for PinnedVersionsSummary

source§

impl Message for ReplayVersionDeltaRequest

source§

impl Message for ReplayVersionDeltaResponse

source§

impl Message for ReportCompactionTaskRequest

source§

impl Message for ReportCompactionTaskResponse

source§

impl Message for RiseCtlGetCheckpointVersionRequest

source§

impl Message for RiseCtlGetCheckpointVersionResponse

source§

impl Message for RiseCtlGetPinnedVersionsSummaryRequest

source§

impl Message for RiseCtlGetPinnedVersionsSummaryResponse

source§

impl Message for RiseCtlListCompactionGroupRequest

source§

impl Message for RiseCtlListCompactionGroupResponse

source§

impl Message for RiseCtlListCompactionStatusRequest

source§

impl Message for RiseCtlListCompactionStatusResponse

source§

impl Message for RiseCtlPauseVersionCheckpointRequest

source§

impl Message for RiseCtlPauseVersionCheckpointResponse

source§

impl Message for RiseCtlRebuildTableStatsRequest

source§

impl Message for RiseCtlRebuildTableStatsResponse

source§

impl Message for RiseCtlResumeVersionCheckpointRequest

source§

impl Message for RiseCtlResumeVersionCheckpointResponse

source§

impl Message for RiseCtlUpdateCompactionConfigRequest

source§

impl Message for RiseCtlUpdateCompactionConfigResponse

source§

impl Message for SplitCompactionGroupRequest

source§

impl Message for SplitCompactionGroupResponse

source§

impl Message for SstableInfo

source§

impl Message for StateTableInfo

source§

impl Message for StateTableInfoDelta

source§

impl Message for SubscribeCompactionEventRequest

source§

impl Message for SubscribeCompactionEventResponse

source§

impl Message for TableChangeLog

source§

impl Message for TableOption

source§

impl Message for risingwave_pb::hummock::TableSchema

source§

impl Message for TableStats

source§

impl Message for TableWatermarks

source§

impl Message for TriggerCompactionDeterministicRequest

source§

impl Message for TriggerCompactionDeterministicResponse

source§

impl Message for TriggerFullGcRequest

source§

impl Message for TriggerFullGcResponse

source§

impl Message for TriggerManualCompactionRequest

source§

impl Message for TriggerManualCompactionResponse

source§

impl Message for UncommittedEpoch

source§

impl Message for UnpinVersionBeforeRequest

source§

impl Message for UnpinVersionBeforeResponse

source§

impl Message for UnpinVersionRequest

source§

impl Message for UnpinVersionResponse

source§

impl Message for VacuumTask

source§

impl Message for ValidationTask

source§

impl Message for VersionUpdatePayload

source§

impl Message for VnodeWatermark

source§

impl Message for WriteLimits

source§

impl Message for risingwave_pb::hummock::subscribe_compaction_event_request::HeartBeat

source§

impl Message for PullTask

source§

impl Message for Register

source§

impl Message for risingwave_pb::hummock::subscribe_compaction_event_request::ReportTask

source§

impl Message for PullTaskAck

source§

impl Message for EpochNewWatermarks

source§

impl Message for WriteLimit

source§

impl Message for risingwave_pb::java_binding::KeyRange

source§

impl Message for ReadPlan

source§

impl Message for WorkerActorCount

source§

impl Message for risingwave_pb::meta::add_worker_node_request::Property

source§

impl Message for CreatingJobIds

source§

impl Message for CreatingJobInfo

source§

impl Message for CreatingJobInfos

source§

impl Message for EventAutoSchemaChangeFail

source§

impl Message for EventBarrierComplete

source§

impl Message for EventCollectBarrierFail

source§

impl Message for EventCreateStreamJobFail

source§

impl Message for EventDirtyStreamJobClear

source§

impl Message for EventInjectBarrierFail

source§

impl Message for EventMetaNodeStart

source§

impl Message for EventSinkFail

source§

impl Message for EventWorkerNodePanic

source§

impl Message for risingwave_pb::meta::get_serverless_streaming_jobs_status_response::Status

source§

impl Message for ActorSplit

source§

impl Message for ActorState

source§

impl Message for FragmentDistribution

source§

impl Message for ObjectDependencies

source§

impl Message for RateLimitInfo

source§

impl Message for TableFragmentState

source§

impl Message for risingwave_pb::meta::list_table_fragments_response::ActorInfo

source§

impl Message for FragmentInfo

source§

impl Message for TableFragmentInfo

source§

impl Message for SnapshotVersion

source§

impl Message for ActivateWorkerNodeRequest

source§

impl Message for ActivateWorkerNodeResponse

source§

impl Message for ActorCountPerParallelism

source§

impl Message for ActorIds

source§

impl Message for risingwave_pb::meta::ActorLocation

source§

impl Message for AddEventLogRequest

source§

impl Message for AddEventLogResponse

source§

impl Message for AddWorkerNodeRequest

source§

impl Message for AddWorkerNodeResponse

source§

impl Message for ApplyThrottleRequest

source§

impl Message for ApplyThrottleResponse

source§

impl Message for CancelCreatingJobsRequest

source§

impl Message for CancelCreatingJobsResponse

source§

impl Message for ClusterLimit

source§

impl Message for DeleteWorkerNodeRequest

source§

impl Message for DeleteWorkerNodeResponse

source§

impl Message for EventLog

source§

impl Message for FlushRequest

source§

impl Message for FlushResponse

source§

impl Message for FragmentIdToActorIdMap

source§

impl Message for FragmentVertexToRelationMap

source§

impl Message for FragmentWorkerSlotMapping

source§

impl Message for FragmentWorkerSlotMappings

source§

impl Message for GetClusterInfoRequest

source§

impl Message for GetClusterInfoResponse

source§

impl Message for GetClusterLimitsRequest

source§

impl Message for GetClusterLimitsResponse

source§

impl Message for GetClusterRecoveryStatusRequest

source§

impl Message for GetClusterRecoveryStatusResponse

source§

impl Message for GetServerlessStreamingJobsStatusRequest

source§

impl Message for GetServerlessStreamingJobsStatusResponse

source§

impl Message for GetServingVnodeMappingsRequest

source§

impl Message for GetServingVnodeMappingsResponse

source§

impl Message for GetSessionParamsRequest

source§

impl Message for GetSessionParamsResponse

source§

impl Message for GetSystemParamsRequest

source§

impl Message for GetSystemParamsResponse

source§

impl Message for GetTelemetryInfoRequest

source§

impl Message for HeartbeatRequest

source§

impl Message for HeartbeatResponse

source§

impl Message for ListActorSplitsRequest

source§

impl Message for ListActorSplitsResponse

source§

impl Message for ListActorStatesRequest

source§

impl Message for ListActorStatesResponse

source§

impl Message for ListAllNodesRequest

source§

impl Message for ListAllNodesResponse

source§

impl Message for ListEventLogRequest

source§

impl Message for ListEventLogResponse

source§

impl Message for ListFragmentDistributionRequest

source§

impl Message for ListFragmentDistributionResponse

source§

impl Message for ListObjectDependenciesRequest

source§

impl Message for ListObjectDependenciesResponse

source§

impl Message for ListRateLimitsRequest

source§

impl Message for ListRateLimitsResponse

source§

impl Message for ListTableFragmentStatesRequest

source§

impl Message for ListTableFragmentStatesResponse

source§

impl Message for ListTableFragmentsRequest

source§

impl Message for ListTableFragmentsResponse

source§

impl Message for MembersRequest

source§

impl Message for MembersResponse

source§

impl Message for MetaMember

source§

impl Message for MetaSnapshot

source§

impl Message for MigrationPlan

source§

impl Message for PauseRequest

source§

impl Message for PauseResponse

source§

impl Message for RecoverRequest

source§

impl Message for RecoverResponse

source§

impl Message for Recovery

source§

impl Message for Relation

source§

impl Message for RelationGroup

source§

impl Message for RelationIdInfos

source§

impl Message for RescheduleRequest

source§

impl Message for RescheduleResponse

source§

impl Message for ResumeRequest

source§

impl Message for ResumeResponse

source§

impl Message for SetSessionParamRequest

source§

impl Message for SetSessionParamResponse

source§

impl Message for SetSystemParamRequest

source§

impl Message for SetSystemParamResponse

source§

impl Message for SubscribeRequest

source§

impl Message for SubscribeResponse

source§

impl Message for SystemParams

source§

impl Message for TableFragments

source§

impl Message for TableParallelism

source§

impl Message for TelemetryInfoResponse

source§

impl Message for UpdateStreamingJobNodeLabelsRequest

source§

impl Message for UpdateStreamingJobNodeLabelsResponse

source§

impl Message for UpdateWorkerNodeSchedulabilityRequest

source§

impl Message for UpdateWorkerNodeSchedulabilityResponse

source§

impl Message for WorkerReschedule

source§

impl Message for ActorStatus

source§

impl Message for Fragment

source§

impl Message for AdaptiveParallelism

source§

impl Message for AutoParallelism

source§

impl Message for CustomParallelism

source§

impl Message for FixedParallelism

source§

impl Message for AnalyzeHeapRequest

source§

impl Message for AnalyzeHeapResponse

source§

impl Message for BackPressureInfo

source§

impl Message for GetBackPressureRequest

source§

impl Message for GetBackPressureResponse

source§

impl Message for HeapProfilingRequest

source§

impl Message for HeapProfilingResponse

source§

impl Message for ListHeapProfilingRequest

source§

impl Message for ListHeapProfilingResponse

source§

impl Message for ProfilingRequest

source§

impl Message for ProfilingResponse

source§

impl Message for StackTraceRequest

source§

impl Message for StackTraceResponse

source§

impl Message for TieredCacheTracingRequest

source§

impl Message for TieredCacheTracingResponse

source§

impl Message for ProcessTime

source§

impl Message for Timestamp

source§

impl Message for Version

source§

impl Message for AdditionalCollectionName

source§

impl Message for AdditionalColumn

source§

impl Message for AdditionalColumnFilename

source§

impl Message for AdditionalColumnHeader

source§

impl Message for AdditionalColumnHeaders

source§

impl Message for AdditionalColumnKey

source§

impl Message for AdditionalColumnOffset

source§

impl Message for AdditionalColumnPartition

source§

impl Message for AdditionalColumnPayload

source§

impl Message for AdditionalColumnTimestamp

source§

impl Message for AdditionalDatabaseName

source§

impl Message for AdditionalSchemaName

source§

impl Message for AdditionalTableName

source§

impl Message for AsOf

source§

impl Message for AsOfJoinDesc

source§

impl Message for Cardinality

source§

impl Message for ColumnCatalog

source§

impl Message for ColumnDesc

source§

impl Message for DefaultColumnDesc

source§

impl Message for DefaultColumns

source§

impl Message for ExprContext

source§

impl Message for ExternalTableDesc

source§

impl Message for Field

source§

impl Message for GeneratedColumnDesc

source§

impl Message for IndexAndExpr

source§

impl Message for StorageTableDesc

source§

impl Message for risingwave_pb::secret::Secret

source§

impl Message for SecretHashicropValutBackend

source§

impl Message for SecretMetaBackend

source§

impl Message for SecretRef

source§

impl Message for ConnectorSplit

source§

impl Message for ConnectorSplits

source§

impl Message for SourceActorInfo

source§

impl Message for MaterializedInputState

source§

impl Message for ValueState

source§

impl Message for risingwave_pb::stream_plan::expand_node::Subset

source§

impl Message for Parallelism

source§

impl Message for StreamFragment

source§

impl Message for StreamFragmentEdge

source§

impl Message for ActorMapping

source§

impl Message for AddMutation

source§

impl Message for AggCallState

source§

impl Message for ArrangeNode

source§

impl Message for ArrangementInfo

source§

impl Message for AsOfJoinNode

source§

impl Message for risingwave_pb::stream_plan::Barrier

source§

impl Message for BarrierMutation

source§

impl Message for BarrierRecvNode

source§

impl Message for BatchPlanNode

source§

impl Message for CdcFilterNode

source§

impl Message for ChangeLogNode

source§

impl Message for CombinedMutation

source§

impl Message for DedupNode

source§

impl Message for DeltaExpression

source§

impl Message for DeltaIndexJoinNode

source§

impl Message for DispatchStrategy

source§

impl Message for Dispatcher

source§

impl Message for Dispatchers

source§

impl Message for DmlNode

source§

impl Message for DropSubscriptionsMutation

source§

impl Message for DynamicFilterNode

source§

impl Message for EowcOverWindowNode

source§

impl Message for risingwave_pb::stream_plan::ExchangeNode

source§

impl Message for risingwave_pb::stream_plan::ExpandNode

source§

impl Message for risingwave_pb::stream_plan::FilterNode

source§

impl Message for GlobalApproxPercentileNode

source§

impl Message for risingwave_pb::stream_plan::GroupTopNNode

source§

impl Message for risingwave_pb::stream_plan::HashAggNode

source§

impl Message for risingwave_pb::stream_plan::HashJoinNode

source§

impl Message for risingwave_pb::stream_plan::HopWindowNode

source§

impl Message for InequalityPair

source§

impl Message for LocalApproxPercentileNode

source§

impl Message for LookupNode

source§

impl Message for LookupUnionNode

source§

impl Message for MaterializeNode

source§

impl Message for MergeNode

source§

impl Message for NoOpNode

source§

impl Message for NowModeGenerateSeries

source§

impl Message for NowModeUpdateCurrent

source§

impl Message for NowNode

source§

impl Message for OverWindowNode

source§

impl Message for PauseMutation

source§

impl Message for risingwave_pb::stream_plan::ProjectNode

source§

impl Message for risingwave_pb::stream_plan::ProjectSetNode

source§

impl Message for ResumeMutation

source§

impl Message for RowIdGenNode

source§

impl Message for RowMergeNode

source§

impl Message for SimpleAggNode

source§

impl Message for SinkDesc

source§

impl Message for SinkNode

source§

impl Message for risingwave_pb::stream_plan::SortNode

source§

impl Message for SourceBackfillNode

source§

impl Message for SourceChangeSplitMutation

source§

impl Message for risingwave_pb::stream_plan::SourceNode

source§

impl Message for StopMutation

source§

impl Message for StreamActor

source§

impl Message for StreamCdcScanNode

source§

impl Message for StreamCdcScanOptions

source§

impl Message for StreamContext

source§

impl Message for StreamFragmentGraph

source§

impl Message for StreamFsFetch

source§

impl Message for StreamFsFetchNode

source§

impl Message for StreamMessage

source§

impl Message for StreamNode

source§

impl Message for StreamScanNode

source§

impl Message for StreamSource

source§

impl Message for SubscriptionUpstreamInfo

source§

impl Message for TemporalJoinNode

source§

impl Message for ThrottleMutation

source§

impl Message for risingwave_pb::stream_plan::TopNNode

source§

impl Message for risingwave_pb::stream_plan::UnionNode

source§

impl Message for UpdateMutation

source§

impl Message for risingwave_pb::stream_plan::ValuesNode

source§

impl Message for Watermark

source§

impl Message for WatermarkFilterNode

source§

impl Message for RateLimit

source§

impl Message for DispatcherUpdate

source§

impl Message for MergeUpdate

source§

impl Message for risingwave_pb::stream_plan::values_node::ExprTuple

source§

impl Message for CreateMviewProgress

source§

impl Message for LocalSstableInfo

source§

impl Message for CreatePartialGraphRequest

source§

impl Message for InitRequest

source§

impl Message for InitialPartialGraph

source§

impl Message for RemovePartialGraphRequest

source§

impl Message for InitResponse

source§

impl Message for ShutdownResponse

source§

impl Message for BarrierCompleteResponse

source§

impl Message for GetMinUncommittedSstIdRequest

source§

impl Message for GetMinUncommittedSstIdResponse

source§

impl Message for InjectBarrierRequest

source§

impl Message for StreamingControlStreamRequest

source§

impl Message for StreamingControlStreamResponse

source§

impl Message for WaitEpochCommitRequest

source§

impl Message for WaitEpochCommitResponse

source§

impl Message for Get

source§

impl Message for CancelTaskRequest

source§

impl Message for CancelTaskResponse

source§

impl Message for CreateTaskRequest

source§

impl Message for ExecuteRequest

source§

impl Message for GetDataRequest

source§

impl Message for GetDataResponse

source§

impl Message for GetStreamRequest

source§

impl Message for GetStreamResponse

source§

impl Message for GetTaskInfoRequest

source§

impl Message for Permits

source§

impl Message for risingwave_pb::task_service::TaskId

source§

impl Message for TaskInfoResponse

source§

impl Message for CompactorReport

source§

impl Message for ComputeReport

source§

impl Message for EventMessage

source§

impl Message for FrontendReport

source§

impl Message for MetaReport

source§

impl Message for NodeCount

source§

impl Message for ReportBase

source§

impl Message for RwVersion

source§

impl Message for StreamJobDesc

source§

impl Message for SystemCpu

source§

impl Message for SystemData

source§

impl Message for SystemMemory

source§

impl Message for SystemOs

source§

impl Message for ActionWithGrantOption

source§

impl Message for AuthInfo

source§

impl Message for CreateUserRequest

source§

impl Message for CreateUserResponse

source§

impl Message for DropUserRequest

source§

impl Message for DropUserResponse

source§

impl Message for GrantPrivilege

source§

impl Message for GrantPrivilegeRequest

source§

impl Message for GrantPrivilegeResponse

source§

impl Message for RevokePrivilegeRequest

source§

impl Message for RevokePrivilegeResponse

source§

impl Message for UpdateUserRequest

source§

impl Message for UpdateUserResponse

source§

impl Message for UserInfo