faust.auth

Authentication Credentials.

class faust.auth.Credentials[source]

Base class for authentication credentials.

class faust.auth.SASLCredentials(*, username: Optional[str] = None, password: Optional[str] = None, ssl_context: Optional[SSLContext] = None, mechanism: Optional[Union[str, SASLMechanism]] = None)[source]

Describe SASL credentials.

username: Optional[str]
password: Optional[str]
ssl_context: Optional[SSLContext]
protocol: AuthProtocol = 'SASL_PLAINTEXT'
mechanism: SASLMechanism = 'PLAIN'
class faust.auth.OAuthCredentials(*, oauth_cb: AbstractTokenProvider, ssl_context: Optional[SSLContext] = None)[source]

Describe OAuth Bearer credentials over SASL

mechanism: SASLMechanism = 'OAUTHBEARER'
ssl_context: Optional[SSLContext]
protocol: AuthProtocol = 'SASL_PLAINTEXT'
class faust.auth.GSSAPICredentials(*, kerberos_service_name: str = 'kafka', kerberos_domain_name: Optional[str] = None, ssl_context: Optional[SSLContext] = None, mechanism: Optional[Union[str, SASLMechanism]] = None)[source]

Describe GSSAPI credentials over SASL.

ssl_context: Optional[SSLContext]
protocol: AuthProtocol = 'SASL_PLAINTEXT'
mechanism: SASLMechanism = 'GSSAPI'
class faust.auth.SSLCredentials(context: Optional[SSLContext] = None, *, purpose: Optional[Any] = None, cafile: Optional[str] = None, capath: Optional[str] = None, cadata: Optional[str] = None)[source]

Describe SSL credentials/settings.

protocol: AuthProtocol = 'SSL'
context: SSLContext