org.opendaylight.controller.cluster.access.client

Class BackendInfoResolver<T extends BackendInfo>

java.lang.Object

org.opendaylight.controller.cluster.access.client.BackendInfoResolver<T>

All Implemented Interfaces:

AutoCloseable

public abstract class BackendInfoResolver<T extends BackendInfo>
extends Object
implements AutoCloseable

Caching resolver which resolves a cookie to a leader ActorRef. This class needs to be specialized by the client. It is used by ClientActorBehavior for request dispatch. Results are cached until they are invalidated by either the client actor (when a message timeout is detected) and by the specific frontend (on explicit invalidation or when updated information becomes available).

If the completion stage returned by this interface's methods fails with a RequestException, it will be forwarded to all outstanding requests towards the leader. If it fails with a TimeoutException, resolution process will be retried. If it fails with any other cause, it will we wrapped as a RuntimeRequestException wrapping that cause.

Author:

Robert Varga

Constructor Summary

Constructors

Constructor and Description
BackendInfoResolver()

Method Summary

Modifier and Type	Method and Description
void	close()
abstract CompletionStage<? extends T>	getBackendInfo(Long cookie) Request resolution of a particular backend identified by a cookie.
abstract org.opendaylight.yangtools.concepts.Registration	notifyWhenBackendInfoIsStale(Consumer<Long> callback) Registers a callback to be notified when BackendInfo that may have been previously obtained is now stale and should be refreshed.
abstract CompletionStage<? extends T>	refreshBackendInfo(Long cookie, T staleInfo) Request re-resolution of a particular backend identified by a cookie, indicating a particular information as being stale.

Methods inherited from class java.lang.Object

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

Constructor Detail

BackendInfoResolver

public BackendInfoResolver()

Method Detail

getBackendInfo

@Nonnull
public abstract CompletionStage<? extends T> getBackendInfo(@Nonnull
                                                                     Long cookie)

Request resolution of a particular backend identified by a cookie. This request can be satisfied from the cache.

Parameters:

cookie - Backend cookie

Returns:

A CompletionStage resulting in information about the backend

refreshBackendInfo

@Nonnull
public abstract CompletionStage<? extends T> refreshBackendInfo(@Nonnull
                                                                         Long cookie,
                                                                         @Nonnull
                                                                         T staleInfo)

Request re-resolution of a particular backend identified by a cookie, indicating a particular information as being stale. If the implementation's cache holds the stale information, it should be purged.

Parameters:

cookie - Backend cookie

staleInfo - Stale backend information

Returns:

A CompletionStage resulting in information about the backend

notifyWhenBackendInfoIsStale

@Nonnull
public abstract org.opendaylight.yangtools.concepts.Registration notifyWhenBackendInfoIsStale(Consumer<Long> callback)

Registers a callback to be notified when BackendInfo that may have been previously obtained is now stale and should be refreshed.

Parameters:

callback - the callback that takes the backend cookie whose BackendInfo is now stale.

Returns:

a Registration

close

public void close()

Specified by:

close in interface AutoCloseable