Enum GroupWriteCommand 

pub enum GroupWriteCommand {
    Stream(StreamCommand),
    Batch {
        commands: Vec<StreamCommand>,
    },
    Transaction {
        commands: Vec<StreamCommand>,
    },
}

Replicated group-level write envelope around the canonical StreamCommand: one command, a throughput batch with independent item results, or an all-or-none append transaction. Batch and transaction envelopes each occupy one Raft entry. This enum (serde-encoded) is the Raft log payload; there is no separate wire mirror.

Variants

Stream(StreamCommand)

Batch

Fields

commands: Vec<StreamCommand>

Transaction

Fields

commands: Vec<StreamCommand>

Trait Implementations

impl Clone for GroupWriteCommand

fn clone(&self) -> GroupWriteCommand

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for GroupWriteCommand

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for GroupWriteCommand

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for GroupWriteCommand

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for GroupWriteCommand

impl From<AdvanceRetentionRequest> for GroupWriteCommand

fn from(request: AdvanceRetentionRequest) -> Self

Converts to this type from the input type.

impl From<AppendBatchRequest> for GroupWriteCommand

fn from(request: AppendBatchRequest) -> Self

Converts to this type from the input type.

impl From<AppendExternalRequest> for GroupWriteCommand

fn from(request: AppendExternalRequest) -> Self

Converts to this type from the input type.

impl From<AppendRequest> for GroupWriteCommand

fn from(request: AppendRequest) -> Self

Converts to this type from the input type.

impl From<CloseStreamRequest> for GroupWriteCommand

fn from(request: CloseStreamRequest) -> Self

Converts to this type from the input type.

impl From<CompactColdRequest> for GroupWriteCommand

fn from(request: CompactColdRequest) -> Self

Converts to this type from the input type.

impl From<CreateStreamExternalRequest> for GroupWriteCommand

fn from(request: CreateStreamExternalRequest) -> Self

Converts to this type from the input type.

impl From<CreateStreamRequest> for GroupWriteCommand

fn from(request: CreateStreamRequest) -> Self

Converts to this type from the input type.

impl From<DeleteStreamRequest> for GroupWriteCommand

fn from(request: DeleteStreamRequest) -> Self

Converts to this type from the input type.

impl From<FlushColdRequest> for GroupWriteCommand

fn from(request: FlushColdRequest) -> Self

Converts to this type from the input type.

impl From<PublishSnapshotRequest> for GroupWriteCommand

fn from(request: PublishSnapshotRequest) -> Self

Converts to this type from the input type.

impl From<SetBucketQuotaRequest> for GroupWriteCommand

fn from(request: SetBucketQuotaRequest) -> Self

Converts to this type from the input type.

impl From<StreamCommand> for GroupWriteCommand

fn from(command: StreamCommand) -> Self

Converts to this type from the input type.

impl From<UpdateStreamAttrsRequest> for GroupWriteCommand

fn from(request: UpdateStreamAttrsRequest) -> Self

Converts to this type from the input type.

impl PartialEq for GroupWriteCommand

fn eq(&self, other: &GroupWriteCommand) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for GroupWriteCommand

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for GroupWriteCommand