DefaultTimestreamQueryEndpointDiscoverer

class DefaultTimestreamQueryEndpointDiscoverer(val cache: <Error class: unknown class><DiscoveryParams, <Error class: unknown class>> = PeriodicSweepCache(10.minutes)) : TimestreamQueryEndpointDiscoverer

A class which looks up specific endpoints for TimestreamQuery 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

Constructors

Link copied to clipboard
constructor(cache: <Error class: unknown class><DiscoveryParams, <Error class: unknown class>> = PeriodicSweepCache(10.minutes))

Properties

Link copied to clipboard
val cache: <Error class: unknown class><DiscoveryParams, <Error class: unknown class>>

Functions

Link copied to clipboard
open override fun asEndpointResolver(client: TimestreamQueryClient, delegate: <Error class: unknown class>): <Error class: unknown class>
Link copied to clipboard
open suspend override fun invalidate(context: <Error class: unknown class>)

Inherited functions

Link copied to clipboard
open suspend fun discoverHost(client: TimestreamQueryClient): <Error class: unknown class><<Error class: unknown class>>