Package org.apache.iceberg.rest.auth

Class RefreshingAuthManager

java.lang.Object

org.apache.iceberg.rest.auth.RefreshingAuthManager

All Implemented Interfaces:

AutoCloseable, AuthManager

Direct Known Subclasses:

OAuth2Manager

public abstract class RefreshingAuthManager
extends Object
implements AuthManager

An AuthManager that provides machinery for refreshing authentication data asynchronously, using a background thread pool.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RefreshingAuthManager(String executorNamePrefix)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the manager and releases any resources.
void	keepRefreshed(boolean keep)
protected ScheduledExecutorService	refreshExecutor()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.rest.auth.AuthManager

catalogSession, contextualSession, initSession, tableSession

Constructor Details

RefreshingAuthManager

protected RefreshingAuthManager(String executorNamePrefix)

Method Details

keepRefreshed

public void keepRefreshed(boolean keep)

close

public void close()

Description copied from interface: AuthManager

Closes the manager and releases any resources.

This method is called when the owning catalog is closed.

Specified by:

close in interface AuthManager

Specified by:

close in interface AutoCloseable

refreshExecutor

@Nullable
protected ScheduledExecutorService refreshExecutor()