Package org.apache.iceberg.rest.auth

Class OAuth2Util.AuthSession

java.lang.Object

org.apache.iceberg.rest.auth.OAuth2Util.AuthSession

Enclosing class:

OAuth2Util

public static class OAuth2Util.AuthSession
extends Object

Class to handle authorization headers and token refresh.

Constructor Summary

Constructors

Constructor	Description
AuthSession(Map<String,String> baseHeaders, AuthConfig config)

Method Summary

Modifier and Type	Method	Description
AuthConfig	config()
String	credential()
static OAuth2Util.AuthSession	empty()	A new OAuth2Util.AuthSession with empty headers.
Long	expiresAtMillis()
static OAuth2Util.AuthSession	fromAccessToken(RESTClient client, ScheduledExecutorService executor, String token, Long defaultExpiresAtMillis, OAuth2Util.AuthSession parent)
static OAuth2Util.AuthSession	fromCredential(RESTClient client, ScheduledExecutorService executor, String credential, OAuth2Util.AuthSession parent)
static OAuth2Util.AuthSession	fromTokenExchange(RESTClient client, ScheduledExecutorService executor, String token, String tokenType, OAuth2Util.AuthSession parent)
static OAuth2Util.AuthSession	fromTokenResponse(RESTClient client, ScheduledExecutorService executor, OAuthTokenResponse response, long startTimeMillis, OAuth2Util.AuthSession parent)
Map<String,String>	headers()
String	oauth2ServerUri()
Map<String,String>	optionalOAuthParams()
Pair<Integer,TimeUnit>	refresh(RESTClient client)	Attempt to refresh the session token using the token exchange flow.
String	scope()
void	stopRefreshing()
String	token()
String	tokenType()

Methods inherited from class java.lang.Object

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

Constructor Details

AuthSession

public AuthSession(Map<String,String> baseHeaders,
 AuthConfig config)

Method Details

headers

public Map<String,String> headers()

token

public String token()

tokenType

public String tokenType()

expiresAtMillis

public Long expiresAtMillis()

scope

public String scope()

stopRefreshing

public void stopRefreshing()

credential

public String credential()

oauth2ServerUri

public String oauth2ServerUri()

optionalOAuthParams

public Map<String,String> optionalOAuthParams()

config

public AuthConfig config()

empty

public static OAuth2Util.AuthSession empty()

A new OAuth2Util.AuthSession with empty headers.

Returns:

A new OAuth2Util.AuthSession with empty headers.

refresh

public Pair<Integer,TimeUnit> refresh(RESTClient client)

Attempt to refresh the session token using the token exchange flow.

Parameters:

client - a RESTClient

Returns:

interval to wait before calling refresh again, or null if no refresh is needed

fromAccessToken

public static OAuth2Util.AuthSession fromAccessToken(RESTClient client,
 ScheduledExecutorService executor,
 String token,
 Long defaultExpiresAtMillis,
 OAuth2Util.AuthSession parent)

fromCredential

public static OAuth2Util.AuthSession fromCredential(RESTClient client,
 ScheduledExecutorService executor,
 String credential,
 OAuth2Util.AuthSession parent)

fromTokenResponse

public static OAuth2Util.AuthSession fromTokenResponse(RESTClient client,
 ScheduledExecutorService executor,
 OAuthTokenResponse response,
 long startTimeMillis,
 OAuth2Util.AuthSession parent)

fromTokenExchange

public static OAuth2Util.AuthSession fromTokenExchange(RESTClient client,
 ScheduledExecutorService executor,
 String token,
 String tokenType,
 OAuth2Util.AuthSession parent)