com.couchbase.client.core.config.refresher

Class CarrierRefresher

java.lang.Object

com.couchbase.client.core.config.refresher.AbstractRefresher

com.couchbase.client.core.config.refresher.CarrierRefresher

All Implemented Interfaces:

Refresher

public class CarrierRefresher
extends AbstractRefresher

Keeps the bucket config fresh through carrier configuration management.

Since:

1.0

Author:

Michael Nitschinger

Constructor Summary

Constructors

Constructor and Description
CarrierRefresher(CoreEnvironment environment, ClusterFacade cluster) Creates a new CarrierRefresher.

Method Summary

Modifier and Type	Method and Description
void	markTainted(BucketConfig config) Marks the given bucket as tainted.
void	markUntainted(BucketConfig config) Mark the given bucket as not tainted.
void	refresh(ClusterConfig config) If pull based, refresh configs for registered buckets.
rx.Observable<Boolean>	shutdown() Shuts down all open registration streams.

Methods inherited from class com.couchbase.client.core.config.refresher.AbstractRefresher

cluster, configs, deregisterBucket, provider, provider, pushConfig, registerBucket, registerBucket, registrations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CarrierRefresher

public CarrierRefresher(CoreEnvironment environment,
                        ClusterFacade cluster)

Creates a new CarrierRefresher.

Parameters:

environment - the environment to use.

cluster - the cluster reference.

Method Detail

shutdown

public rx.Observable<Boolean> shutdown()

Description copied from interface: Refresher

Shuts down all open registration streams.

Returns:

true if succeeded, a failing Observable otherwise with the cause.

markTainted

public void markTainted(BucketConfig config)

Description copied from interface: Refresher

Marks the given bucket as tainted.

Parameters:

config - the config of the bucket that should be marked.

markUntainted

public void markUntainted(BucketConfig config)

Description copied from interface: Refresher

Mark the given bucket as not tainted.

Parameters:

config - the config of the bucket that should not be marked anymore.

refresh

public void refresh(ClusterConfig config)

Description copied from interface: Refresher

If pull based, refresh configs for registered buckets.