Compare commits
1 Commits
main
...
main-25111
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
b51fa8c881 |
@@ -44,6 +44,21 @@ impl SupervisorBuilder {
|
||||
}
|
||||
}
|
||||
|
||||
/// Set the Redis URL for the supervisor and underlying job client
|
||||
pub fn redis_url<S: Into<String>>(mut self, url: S) -> Self {
|
||||
let url_str = url.into();
|
||||
self.redis_url = url_str.clone();
|
||||
self.client_builder = self.client_builder.redis_url(url_str);
|
||||
self
|
||||
}
|
||||
|
||||
/// Set the namespace for Redis keys used by the job client
|
||||
pub fn namespace<S: Into<String>>(mut self, namespace: S) -> Self {
|
||||
let ns = namespace.into();
|
||||
self.client_builder = self.client_builder.namespace(ns);
|
||||
self
|
||||
}
|
||||
|
||||
/// Set the Osiris URL for queries
|
||||
pub fn osiris_url<S: Into<String>>(mut self, url: S) -> Self {
|
||||
self.osiris_url = Some(url.into());
|
||||
|
||||
Reference in New Issue
Block a user