Class AssignerImpl (1.8.0)

Version 1.8.0

• 1.14.7 (latest)
• 1.14.4
• 1.13.8
• 1.12.22
• 1.11.2
• 1.10.0
• 1.9.4
• 1.8.0
• 1.7.1
• 1.6.3
• 1.5.5
• 1.4.12

public class AssignerImpl extends ProxyService implements Assigner, RetryingConnectionObserver<PartitionAssignment>

Inheritance

java.lang.Object > AbstractApiService > ProxyService > AssignerImpl

Implements

Assigner, com.google.cloud.pubsublite.internal.wire.RetryingConnectionObserver<com.google.cloud.pubsublite.proto.PartitionAssignment>

Inherited Members

AbstractApiService.addListener(ApiService.Listener,Executor)

AbstractApiService.awaitRunning()

AbstractApiService.awaitRunning(long,TimeUnit)

AbstractApiService.awaitTerminated()

AbstractApiService.awaitTerminated(long,TimeUnit)

AbstractApiService.failureCause()

AbstractApiService.isRunning()

AbstractApiService.notifyFailed(Throwable)

AbstractApiService.notifyStarted()

AbstractApiService.notifyStopped()

AbstractApiService.startAsync()

AbstractApiService.state()

AbstractApiService.stopAsync()

ProxyService.<T>addServices(Collection<T>)

ProxyService.addServices(ApiService)

ProxyService.doStart()

ProxyService.doStop()

ProxyService.handlePermanentError(CheckedApiException)

ProxyService.onPermanentError(CheckedApiException)

ProxyService.start()

ProxyService.stop()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

AssignerImpl(PartitionAssignmentServiceClient client, InitialPartitionAssignmentRequest initialRequest, PartitionAssignmentReceiver receiver)

public AssignerImpl(PartitionAssignmentServiceClient client, InitialPartitionAssignmentRequest initialRequest, PartitionAssignmentReceiver receiver)

Parameters

Name	Description
client	PartitionAssignmentServiceClient
initialRequest	InitialPartitionAssignmentRequest
receiver	PartitionAssignmentReceiver

Methods

onClientResponse(PartitionAssignment value)

public void onClientResponse(PartitionAssignment value)

Parameter

Name	Description
value	PartitionAssignment

Exceptions

Type	Description
CheckedApiException

triggerReinitialize(CheckedApiException streamError)

public void triggerReinitialize(CheckedApiException streamError)

Parameter

Name	Description
streamError	CheckedApiException