Class SelectBucketHandler

  • All Implemented Interfaces:,,

    public class SelectBucketHandler
    The SelectBucketHandler is responsible for, selecting the right bucket on this KV connection.

    The reason this handler is in place that since Server 5.0 and RBAC (role based access control) one user after SASL/cert auth can have credentials for more than one bucket. To signal the server which bucket it should select, this command is used as usually the last step in the pipeline.

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void channelActive​( ctx)  
      void channelRead​( ctx, Object msg)  
      void connect​( ctx, SocketAddress remoteAddress, SocketAddress localAddress, promise)  
      • Methods inherited from class

        bind, close, deregister, disconnect, flush, read, write
      • Methods inherited from class

        channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
      • Methods inherited from class

        ensureNotSharable, handlerAdded, handlerRemoved, isSharable
      • Methods inherited from interface

        handlerAdded, handlerRemoved
    • Constructor Detail

      • SelectBucketHandler

        public SelectBucketHandler​(EndpointContext endpointContext,
                                   String bucketName)
        Creates a new SelectBucketHandler.
        endpointContext - the core context used to refer to values like the core id.
        bucketName - the bucket name to select.
    • Method Detail

      • connect

        public void connect​( ctx,
                            SocketAddress remoteAddress,
                            SocketAddress localAddress,
        Specified by:
        connect in interface
        connect in class
      • channelActive

        public void channelActive​( ctx)
        Specified by:
        channelActive in interface
        channelActive in class
      • channelRead

        public void channelRead​( ctx,
                                Object msg)
        Specified by:
        channelRead in interface
        channelRead in class