DefaultTimestreamWriteEndpointDiscoverer
class DefaultTimestreamWriteEndpointDiscoverer(val cache: ExpiringKeyedCache<DiscoveryParams, Host> = PeriodicSweepCache(10.minutes)) : TimestreamWriteEndpointDiscoverer
A class which looks up specific endpoints for TimestreamWrite calls via the describeEndpoints API. These unique endpoints are cached as appropriate to avoid unnecessary latency in subsequent calls.
Parameters
cache
An ExpiringKeyedCache implementation used to cache discovered hosts
Functions
Link copied to clipboard
open override fun asEndpointResolver(client: TimestreamWriteClient, delegate: EndpointResolver): EndpointResolver
Link copied to clipboard