Class ObserveViaSeqnoRequest

    • Method Detail

      • replica

        public int replica()
      • active

        public boolean active()
      • encode

        public encode​( alloc,
                                                                             int opaque,
                                                                             KeyValueChannelContext ctx)
        Description copied from interface: KeyValueRequest
        Encode this request with the given allocator and opaque.
        alloc - the allocator where to grab the buffers from.
        opaque - the opaque value to use.
        ctx - more encode context.
        the encoded request as a ByteBuf.
      • decode

        public ObserveViaSeqnoResponse decode​( response,
                                              KeyValueChannelContext ctx)
        Description copied from interface: KeyValueRequest
        Decode the encoded response into its message representation.
        response - the response to decode.
        the decoded response as the generic type R.
      • idempotent

        public boolean idempotent()
        Description copied from interface: Request
        Returns if the given request is idempotent or not.

        By default, this method always returns false for data consistency reasons. Only specific idempotent operations should override this default since it impacts retry handling quite a bit. DO NOT SET THIS TO TRUE ON MUTATING OPERATIONS!

        true if idempotent.
      • name

        public String name()
        Description copied from interface: Request
        The unique name of the request, usually related to the type but not necessarily.

        The default implementation is derived from the class name (i.e. FooRequest => foo), but if that does not match up it should be overridden in the actual class.

        the name of the request type.