Class AssignerImpl (1.12.22)

Version 1.12.22

• 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