Package | Description |
---|---|
com.couchbase.client.core |
Couchbase Core IO - Domain Model and Architecture
|
com.couchbase.client.core.endpoint | |
com.couchbase.client.core.message.internal | |
com.couchbase.client.core.node | |
com.couchbase.client.core.service | |
com.couchbase.client.core.state |
Modifier and Type | Method and Description |
---|---|
rx.Observable<LifecycleState> |
RequestHandler.addNode(NetworkAddress hostname,
NetworkAddress alternate)
Add a
Node identified by its hostname. |
rx.Observable<LifecycleState> |
RequestHandler.removeNode(NetworkAddress hostname)
Remove a
Node identified by its hostname. |
Modifier and Type | Method and Description |
---|---|
rx.Observable<LifecycleState> |
AbstractEndpoint.connect() |
rx.Observable<LifecycleState> |
Endpoint.connect()
Connect the
Endpoint to the underlying channel. |
protected rx.Observable<LifecycleState> |
AbstractEndpoint.connect(boolean bootstrapping)
An internal alternative to
AbstractEndpoint.connect() where signalling that this is post-bootstrapping can be done. |
rx.Observable<LifecycleState> |
AbstractEndpoint.disconnect() |
rx.Observable<LifecycleState> |
Endpoint.disconnect()
Disconnect the
Endpoint from the underlying channel. |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractEndpoint.doConnect(rx.subjects.Subject<LifecycleState,LifecycleState> observable,
boolean bootstrapping)
Helper method to perform the actual connect and reconnect.
|
protected void |
AbstractEndpoint.doConnect(rx.subjects.Subject<LifecycleState,LifecycleState> observable,
boolean bootstrapping)
Helper method to perform the actual connect and reconnect.
|
Modifier and Type | Method and Description |
---|---|
LifecycleState |
EndpointHealth.state() |
Constructor and Description |
---|
EndpointHealth(ServiceType type,
LifecycleState state,
SocketAddress localAddr,
SocketAddress remoteAddr,
long lastActivityUs,
String id) |
Modifier and Type | Method and Description |
---|---|
protected LifecycleState |
ServiceStateZipper.zipWith(Collection<LifecycleState> states) |
Modifier and Type | Method and Description |
---|---|
rx.Observable<LifecycleState> |
CouchbaseNode.connect() |
rx.Observable<LifecycleState> |
Node.connect()
Connects all currently enabled
Service s. |
rx.Observable<LifecycleState> |
CouchbaseNode.disconnect() |
rx.Observable<LifecycleState> |
Node.disconnect()
Disconnects all currently enabled
Service s. |
Modifier and Type | Method and Description |
---|---|
protected LifecycleState |
ServiceStateZipper.zipWith(Collection<LifecycleState> states) |
Constructor and Description |
---|
ServiceStateZipper(LifecycleState initial) |
Modifier and Type | Method and Description |
---|---|
protected LifecycleState |
EndpointStateZipper.zipWith(Collection<LifecycleState> states) |
Modifier and Type | Method and Description |
---|---|
rx.Observable<LifecycleState> |
AbstractDynamicService.connect() |
rx.Observable<LifecycleState> |
Service.connect()
|
rx.Observable<LifecycleState> |
PooledService.connect() |
rx.Observable<LifecycleState> |
AbstractDynamicService.disconnect() |
rx.Observable<LifecycleState> |
Service.disconnect()
|
rx.Observable<LifecycleState> |
AbstractOnDemandService.disconnect() |
rx.Observable<LifecycleState> |
PooledService.disconnect() |
Modifier and Type | Method and Description |
---|---|
protected static void |
AbstractDynamicService.whenState(Endpoint endpoint,
LifecycleState wanted,
rx.functions.Action1<LifecycleState> then)
Waits until the endpoint goes into the given state, calls the action and then unsubscribes.
|
Modifier and Type | Method and Description |
---|---|
protected static void |
AbstractDynamicService.whenState(Endpoint endpoint,
LifecycleState wanted,
rx.functions.Action1<LifecycleState> then)
Waits until the endpoint goes into the given state, calls the action and then unsubscribes.
|
protected LifecycleState |
EndpointStateZipper.zipWith(Collection<LifecycleState> states) |
Constructor and Description |
---|
EndpointStateZipper(LifecycleState initial) |
Modifier and Type | Method and Description |
---|---|
static LifecycleState |
LifecycleState.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static LifecycleState[] |
LifecycleState.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Copyright © 2018 Couchbase, Inc.. All rights reserved.