com.couchbase.client
Class ViewNode

java.lang.Object
  extended by net.spy.memcached.compat.SpyObject
      extended by com.couchbase.client.ViewNode

public class ViewNode
extends net.spy.memcached.compat.SpyObject

Establishes a HTTP connection to a single Couchbase node. Based upon http://hc.apache.org/httpcomponents-core-ga/httpcore-nio/ examples/org/apache/http/examples/nio/NHttpClientConnManagement.java


Constructor Summary
ViewNode(java.net.InetSocketAddress a, AsyncConnectionManager mgr, long queueLen, long maxBlockTime, long operationTimeout, java.lang.String usr, java.lang.String pwd)
           
 
Method Summary
 java.net.InetSocketAddress getSocketAddress()
           
 boolean hasWriteOps()
           
 void init()
           
 void shutdown()
           
 void shutdown(long time, java.util.concurrent.TimeUnit unit)
           
 void writeOp(HttpOperation op)
           
 
Methods inherited from class net.spy.memcached.compat.SpyObject
getLogger
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ViewNode

public ViewNode(java.net.InetSocketAddress a,
                AsyncConnectionManager mgr,
                long queueLen,
                long maxBlockTime,
                long operationTimeout,
                java.lang.String usr,
                java.lang.String pwd)
Method Detail

init

public void init()
          throws org.apache.http.nio.reactor.IOReactorException
Throws:
org.apache.http.nio.reactor.IOReactorException

writeOp

public void writeOp(HttpOperation op)

hasWriteOps

public boolean hasWriteOps()

getSocketAddress

public java.net.InetSocketAddress getSocketAddress()

shutdown

public void shutdown()
              throws java.io.IOException
Throws:
java.io.IOException

shutdown

public void shutdown(long time,
                     java.util.concurrent.TimeUnit unit)
              throws java.io.IOException
Throws:
java.io.IOException


Copyright © 2006-2009 Dustin Sallings, 2009-2012 Couchbase, Inc.