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 java.lang.Object

Class to handle authorization headers and token refresh.

Constructor Summary

Constructors

Constructor	Description
AuthSession(java.util.Map<java.lang.String,java.lang.String> baseHeaders, AuthConfig config)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AuthSession

public AuthSession(java.util.Map<java.lang.String,java.lang.String> baseHeaders,
                   AuthConfig config)

Method Detail

headers

public java.util.Map<java.lang.String,java.lang.String> headers()

token

public java.lang.String token()

tokenType

public java.lang.String tokenType()

expiresAtMillis

public java.lang.Long expiresAtMillis()

scope

public java.lang.String scope()

stopRefreshing

public void stopRefreshing()

credential

public java.lang.String credential()

oauth2ServerUri

public java.lang.String oauth2ServerUri()

optionalOAuthParams

public java.util.Map<java.lang.String,java.lang.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<java.lang.Integer,java.util.concurrent.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,
                                                     java.util.concurrent.ScheduledExecutorService executor,
                                                     java.lang.String token,
                                                     java.lang.Long defaultExpiresAtMillis,
                                                     OAuth2Util.AuthSession parent)

fromCredential

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

fromTokenResponse

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

fromTokenExchange

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