Class MembershipRpcResponseContext

  • All Implemented Interfaces:
    java.io.Externalizable , java.io.Serializable , java.lang.Comparable , org.apache.avro.generic.GenericContainer , org.apache.avro.generic.GenericRecord , org.apache.avro.generic.IndexedRecord , org.apache.avro.specific.SpecificRecord

    
    public class MembershipRpcResponseContext
    extends SpecificRecordBase implements SpecificRecord
                        

    Basic, common information about the RPC operations response for membership groups.

    • Constructor Detail

      • MembershipRpcResponseContext

        MembershipRpcResponseContext()
        Default constructor.
      • MembershipRpcResponseContext

        MembershipRpcResponseContext(String requestId, Instant requestTimestamp, Instant responseTimestamp)
        All-args constructor.
        Parameters:
        requestId - ID of the request.
        requestTimestamp - Time ([Instant]) in milliseconds when the request was issued.
        responseTimestamp - Time ([Instant]) in milliseconds when the response was issued.
    • Method Detail

      • getRequestId

         String getRequestId()

        Gets the value of the 'requestId' field.

        Returns:

        ID of the request.

      • setRequestId

         void setRequestId(String value)

        Sets the value of the 'requestId' field. ID of the request.

        Parameters:
        value - the value to set.
      • getRequestTimestamp

         Instant getRequestTimestamp()

        Gets the value of the 'requestTimestamp' field.

        Returns:

        Time ([Instant]) in milliseconds when the request was issued.

      • setRequestTimestamp

         void setRequestTimestamp(Instant value)

        Sets the value of the 'requestTimestamp' field. Time ([Instant]) in milliseconds when the request was issued.

        Parameters:
        value - the value to set.
      • getResponseTimestamp

         Instant getResponseTimestamp()

        Gets the value of the 'responseTimestamp' field.

        Returns:

        Time ([Instant]) in milliseconds when the response was issued.

      • setResponseTimestamp

         void setResponseTimestamp(Instant value)

        Sets the value of the 'responseTimestamp' field. Time ([Instant]) in milliseconds when the response was issued.

        Parameters:
        value - the value to set.
      • getEncoder

         static BinaryMessageEncoder<MembershipRpcResponseContext> getEncoder()

        Return the BinaryMessageEncoder instance used by this class.

        Returns:

        the message encoder used by this class

      • getDecoder

         static BinaryMessageDecoder<MembershipRpcResponseContext> getDecoder()

        Return the BinaryMessageDecoder instance used by this class.

        Returns:

        the message decoder used by this class

      • createDecoder

         static BinaryMessageDecoder<MembershipRpcResponseContext> createDecoder(SchemaStore resolver)

        Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.

        Parameters:
        resolver - a SchemaStore used to find schemas by fingerprint
        Returns:

        a BinaryMessageDecoder instance for this class backed by the given SchemaStore

      • toByteBuffer

         ByteBuffer toByteBuffer()

        Serializes this MembershipRpcResponseContext to a ByteBuffer.

        Returns:

        a buffer holding the serialized data for this instance

      • fromByteBuffer

         static MembershipRpcResponseContext fromByteBuffer(ByteBuffer b)

        Deserializes a MembershipRpcResponseContext from a ByteBuffer.

        Parameters:
        b - a byte buffer holding serialized data for an instance of this class
        Returns:

        a MembershipRpcResponseContext instance decoded from the given buffer