org.apache.pekko.stream.connectors.google.auth
ProvidedCredentials
Companion object ProvidedCredentials
final class ProvidedCredentials extends Credentials
Wraps a user-provided com.google.auth.Credentials instance for use with Google connectors. This allows users to bring their own credentials resolved through any mechanism.
- Annotations
- @ApiMayChange()
- Source
- ProvidedCredentials.scala
- Since
2.0.0
- Alphabetic
- By Inheritance
- ProvidedCredentials
- Credentials
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new ProvidedCredentials(projectId: String, credentials: com.google.auth.Credentials)
- projectId
the GCP project id
- credentials
the user-provided Google credentials
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def asGoogle(implicit ec: ExecutionContext, settings: RequestSettings): com.google.auth.Credentials
Wraps these credentials as a com.google.auth.Credentials for interop with Google's Java client libraries.
Wraps these credentials as a com.google.auth.Credentials for interop with Google's Java client libraries.
- ec
the scala.concurrent.ExecutionContext to use for blocking requests if credentials are requested synchronously
- settings
additional request settings
- Definition Classes
- ProvidedCredentials → Credentials
- final def asGoogle(exec: Executor, settings: RequestSettings): com.google.auth.Credentials
Java API: Wraps these credentials as a com.google.auth.Credentials for interop with Google's Java client libraries.
Java API: Wraps these credentials as a com.google.auth.Credentials for interop with Google's Java client libraries.
- exec
the java.util.concurrent.Executor to use for blocking requests if credentials are requested synchronously
- settings
additional request settings
- Definition Classes
- Credentials
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def close(): Unit
Releases any resources held by these credentials, such as the stream that caches and refreshes OAuth2 access tokens.
Releases any resources held by these credentials, such as the stream that caches and refreshes OAuth2 access tokens. The credentials must not be used again once closed, and closing more than once has no further effect.
Credentials obtained from GoogleSettings via an
ActorSystemare cached per system and their resources are released when that system terminates, so only credentials that are built directly, for example one set of credentials per tenant, need to be closed.- Definition Classes
- Credentials
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getProjectId: String
Java API
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- val projectId: String
- Definition Classes
- ProvidedCredentials → Credentials
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])