com.couchbase.client

Class ViewNode

java.lang.Object

net.spy.memcached.compat.SpyObject

com.couchbase.client.ViewNode

public class ViewNode
extends 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

Constructors

Constructor and Description
ViewNode(java.net.InetSocketAddress a, AsyncConnectionManager mgr, long queueLen, long maxBlockTime, long operationTimeout, java.lang.String usr, java.lang.String pwd)

Method Summary

Methods

Modifier and Type	Method and Description
java.net.InetSocketAddress	getSocketAddress()
boolean	hasWriteOps()
void	init()
boolean	isShuttingDown()
void	shutdown()
void	shutdown(long time, java.util.concurrent.TimeUnit unit)
boolean	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 boolean 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

isShuttingDown

public boolean isShuttingDown()