io.servicetalk.client.api.internal

Class DefaultPartitionedClientGroup<U,R,Client extends ListenableAsyncCloseable>

Object

DefaultPartitionedClientGroup<U,R,Client>

Type Parameters:

U - the type of address before resolution (unresolved address)

R - the type of address after resolution (resolved address)

Client - the type of client to connect to the partitions

All Implemented Interfaces:

ClientGroup<PartitionAttributes,Client>, AsyncCloseable, ListenableAsyncCloseable

Deprecated.

We are unaware of anyone using "partition" feature and plan to remove it in future releases. If you depend on it, consider using ClientGroup as an alternative or reach out to the maintainers describing the use-case.

@Deprecated
public final class DefaultPartitionedClientGroup<U,R,Client extends ListenableAsyncCloseable>
extends Object
implements ClientGroup<PartitionAttributes,Client>

An implementation of ClientGroup that can be used for partitioned client use-cases where PartitionAttributes are discovered through PartitionedServiceDiscovererEvents.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	DefaultPartitionedClientGroup.PartitionedClientFactory<U,R,Client> Deprecated. We are unaware of anyone using "partition" feature and plan to remove it in future releases. If you depend on it, consider using ClientGroup as an alternative or reach out to the maintainers describing the use-case.

Constructor Summary

Constructors

Constructor and Description
DefaultPartitionedClientGroup(Function<PartitionAttributes,Client> closedPartitionClient, Function<PartitionAttributes,Client> unknownPartitionClient, DefaultPartitionedClientGroup.PartitionedClientFactory<U,R,Client> clientFactory, PartitionMapFactory partitionMapFactory, Publisher<PartitionedServiceDiscovererEvent<R>> psdEvents, int psdMaxQueueSize) Deprecated. Creates a new instance.

Method Summary

Modifier and Type	Method and Description
Completable	closeAsync() Deprecated.
Completable	closeAsyncGracefully() Deprecated.
Client	get(PartitionAttributes partitionAttributes) Deprecated.
Completable	onClose() Deprecated.
Completable	onClosing() Deprecated.

Methods inherited from class Object

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

Methods inherited from interface ClientGroup

from

Constructor Detail

DefaultPartitionedClientGroup

public DefaultPartitionedClientGroup(Function<PartitionAttributes,Client> closedPartitionClient,
                                     Function<PartitionAttributes,Client> unknownPartitionClient,
                                     DefaultPartitionedClientGroup.PartitionedClientFactory<U,R,Client> clientFactory,
                                     PartitionMapFactory partitionMapFactory,
                                     Publisher<PartitionedServiceDiscovererEvent<R>> psdEvents,
                                     int psdMaxQueueSize)

Deprecated.

Creates a new instance.

Parameters:

closedPartitionClient - factory for clients that handle requests for a closed partition

unknownPartitionClient - factory for clients that handles requests for an unknown partition

clientFactory - used to create clients for newly discovered partitions

partitionMapFactory - factory to provide a PartitionMap implementation appropriate for the use-case

psdEvents - the stream of PartitionedServiceDiscovererEvents

psdMaxQueueSize - max number of new partitions to queue up

Method Detail

onClose

public Completable onClose()

Deprecated.

Specified by:

onClose in interface ListenableAsyncCloseable

onClosing

public Completable onClosing()

Deprecated.

Specified by:

onClosing in interface ListenableAsyncCloseable

closeAsync

public Completable closeAsync()

Deprecated.

Specified by:

closeAsync in interface AsyncCloseable

closeAsyncGracefully

public Completable closeAsyncGracefully()

Deprecated.

Specified by:

closeAsyncGracefully in interface AsyncCloseable

get

public Client get(PartitionAttributes partitionAttributes)

Deprecated.

Specified by:

get in interface ClientGroup<PartitionAttributes,Client extends ListenableAsyncCloseable>