Struct FileCredential 

pub struct FileCredential { /* private fields */ }

Reads a token file at construction and after its modification time or size changes.

File metadata is checked at most once per second. Surrounding whitespace is removed. If the file becomes empty or unreadable, requests fail until a later check succeeds; no stale token is sent. The constructor fails when the initial file is unreadable or empty. Checks and reads use a mutex, briefly serializing concurrent callers. Use a local filesystem; slow network filesystems can delay calls. Replace the token atomically by writing a temporary file and renaming it. An empty or partial token can fail pull stream opens, which back off for about one minute.

use std::sync::Arc;
use dex_sdk::{ClientOptions, FileCredential, WorkerOptions};
let credential = Arc::new(FileCredential::new("/var/run/secrets/dex/token")?);
let client_options = ClientOptions::new().credential(credential.clone());
let worker_options = WorkerOptions::new().credential(credential);

Implementations

impl FileCredential

pub fn new(path: impl AsRef<Path>) -> Result<Self>

Opens path and reads its initial nonempty token.

Errors

Returns an I/O error if the file cannot be inspected or read, or contains only whitespace. See the FileCredential example for sharing the credential with a Client and Worker.

Trait Implementations

impl Credential for FileCredential

fn token(&self) -> Result<String, CredentialError>

Returns the current bare token, or an error that fails the request locally.

fn discard_rejected_token(&self, _rejected_token: &str)

Discards a token rejected by Dex if it is still the credential’s cached token.

fn token_after_rejection( &self, ) -> Option<Pin<Box<dyn Future<Output = Result<String, CredentialError>> + Send + '_>>>

Supplies an asynchronous fresh token after rejection when supported.

impl Debug for FileCredential

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.