Skip to main content

WireEncode

Trait WireEncode 

Source
pub trait WireEncode {
    // Required methods
    fn encode(&self, buf: &mut BytesMut);
    fn encoded_size(&self) -> usize;

    // Provided method
    fn to_bytes(&self) -> Bytes { ... }
}
Expand description

Encode a wire type into a caller-owned buffer.

Buffer-first design: the caller controls allocation. The to_bytes() convenience method allocates when needed, but hot paths can reuse buffers via encode() directly.

Required Methods§

Source

fn encode(&self, buf: &mut BytesMut)

Write the encoded representation into buf.

Source

fn encoded_size(&self) -> usize

Return the exact encoded size in bytes.

Provided Methods§

Source

fn to_bytes(&self) -> Bytes

Convenience: allocate a new Bytes and encode into it.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§

Source§

impl WireEncode for AttachConsumerSessionRequest

Source§

impl WireEncode for ChangePasswordRequest

Source§

impl WireEncode for ClientDetailsResponse

Source§

impl WireEncode for ClientResponse

Source§

impl WireEncode for ClientVersionInfo

Source§

impl WireEncode for ClusterMetadataResponse

Source§

impl WireEncode for ClusterNodeResponse

Source§

impl WireEncode for ConsumerGroupDetailsResponse

Source§

impl WireEncode for ConsumerGroupInfoResponse

Source§

impl WireEncode for ConsumerGroupMemberResponse

Source§

impl WireEncode for ConsumerGroupResponse

Source§

impl WireEncode for ConsumerOffsetResponse

Source§

impl WireEncode for CreateConsumerGroupRequest

Source§

impl WireEncode for CreatePartitionsRequest

Source§

impl WireEncode for CreatePartitionsWithAssignmentsRequest

Source§

impl WireEncode for CreatePersonalAccessTokenRequest

Source§

impl WireEncode for CreateStreamRequest

Source§

impl WireEncode for CreateTopicRequest

Source§

impl WireEncode for CreateTopicWithAssignmentsRequest

Source§

impl WireEncode for CreateUserRequest

Source§

impl WireEncode for CreatedPartitionAssignment

Source§

impl WireEncode for DeleteConsumerGroupRequest

Source§

impl WireEncode for DeleteConsumerOffsetRequest

Source§

impl WireEncode for DeletePartitionsRequest

Source§

impl WireEncode for DeletePersonalAccessTokenRequest

Source§

impl WireEncode for DeleteSegmentsRequest

Source§

impl WireEncode for DeleteStreamRequest

Source§

impl WireEncode for DeleteTopicRequest

Source§

impl WireEncode for DeleteUserRequest

Source§

impl WireEncode for DescribeOptionsRequest

Source§

impl WireEncode for DescribeOptionsResponse

Source§

impl WireEncode for EmptyResponse

Source§

impl WireEncode for FlushUnsavedBufferRequest

Source§

impl WireEncode for GetClientRequest

Source§

impl WireEncode for GetClientsRequest

Source§

impl WireEncode for GetClientsResponse

Source§

impl WireEncode for GetClusterMetadataRequest

Source§

impl WireEncode for GetConsumerGroupRequest

Source§

impl WireEncode for GetConsumerGroupsRequest

Source§

impl WireEncode for GetConsumerGroupsResponse

Source§

impl WireEncode for GetConsumerOffsetRequest

Source§

impl WireEncode for GetMeRequest

Source§

impl WireEncode for GetPersonalAccessTokensRequest

Source§

impl WireEncode for GetPersonalAccessTokensResponse

Source§

impl WireEncode for GetSnapshotRequest

Source§

impl WireEncode for GetSnapshotResponse

Source§

impl WireEncode for GetStatsRequest

Source§

impl WireEncode for GetStreamRequest

Source§

impl WireEncode for GetStreamResponse

Source§

impl WireEncode for GetStreamsRequest

Source§

impl WireEncode for GetStreamsResponse

Source§

impl WireEncode for GetTopicRequest

Source§

impl WireEncode for GetTopicResponse

Source§

impl WireEncode for GetTopicsRequest

Source§

impl WireEncode for GetTopicsResponse

Source§

impl WireEncode for GetUserRequest

Source§

impl WireEncode for GetUsersRequest

Source§

impl WireEncode for GetUsersResponse

Source§

impl WireEncode for IdentityResponse

Source§

impl WireEncode for JoinConsumerGroupRequest

Source§

impl WireEncode for LeaveConsumerGroupRequest

Source§

impl WireEncode for LoginRegisterRequest

Source§

impl WireEncode for LoginRegisterResponse

Source§

impl WireEncode for LoginRegisterWithPatRequest

Source§

impl WireEncode for LoginUserRequest

Source§

impl WireEncode for LoginWithPersonalAccessTokenRequest

Source§

impl WireEncode for LogoutUserRequest

Source§

impl WireEncode for OptionDescriptor

Source§

impl WireEncode for PartitionResponse

Source§

impl WireEncode for PersonalAccessTokenResponse

Source§

impl WireEncode for PingRequest

Source§

impl WireEncode for PollMessagesRequest

Source§

impl WireEncode for PollMessagesResponseHeader

Source§

impl WireEncode for PollRoutingResponse

Source§

impl WireEncode for PurgeStreamRequest

Source§

impl WireEncode for PurgeTopicRequest

Source§

impl WireEncode for RawPersonalAccessTokenResponse

Source§

impl WireEncode for SendMessagesConfirmationResponse

Source§

impl WireEncode for SendMessagesHeader

Source§

impl WireEncode for SendMessagesResponse

Source§

impl WireEncode for StatsResponse

Source§

impl WireEncode for StoreConsumerOffsetRequest

Source§

impl WireEncode for StreamResponse

Source§

impl WireEncode for SyncConsumerGroupRequest

Source§

impl WireEncode for SyncConsumerGroupResponse

Source§

impl WireEncode for TopicHeader

Source§

impl WireEncode for UpdatePermissionsRequest

Source§

impl WireEncode for UpdateStreamRequest

Source§

impl WireEncode for UpdateTopicRequest

Source§

impl WireEncode for UpdateUserRequest

Source§

impl WireEncode for UserDetailsResponse

Source§

impl WireEncode for UserResponse

Source§

impl WireEncode for WireConsumer

Source§

impl WireEncode for WireIdentifier

Source§

impl WireEncode for WireName

Source§

impl WireEncode for WireOptions

Source§

impl WireEncode for WirePartitioning

Source§

impl WireEncode for WirePermissions

Source§

impl WireEncode for WirePollingStrategy

Source§

impl WireEncode for WireUserHeaders