public class AssignerImpl extends ProxyService implements Assigner, RetryingConnectionObserver<PartitionAssignment>
Implements
Assigner, com.google.cloud.pubsublite.internal.wire.RetryingConnectionObserver<com.google.cloud.pubsublite.proto.PartitionAssignment>Constructors
AssignerImpl(PartitionAssignmentServiceClient client, InitialPartitionAssignmentRequest initialRequest, PartitionAssignmentReceiver receiver)
public AssignerImpl(PartitionAssignmentServiceClient client, InitialPartitionAssignmentRequest initialRequest, PartitionAssignmentReceiver receiver)
Name | Description |
client | PartitionAssignmentServiceClient |
initialRequest | InitialPartitionAssignmentRequest |
receiver | PartitionAssignmentReceiver |
Methods
onClientResponse(PartitionAssignment value)
public void onClientResponse(PartitionAssignment value)
Name | Description |
value | PartitionAssignment |
Type | Description |
CheckedApiException |
triggerReinitialize(CheckedApiException streamError)
public void triggerReinitialize(CheckedApiException streamError)
Name | Description |
streamError | CheckedApiException |