Compare commits
1 Commits
9f6032e2e1
...
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
|
/// Set the Osiris URL for queries
|
||||||
pub fn osiris_url<S: Into<String>>(mut self, url: S) -> Self {
|
pub fn osiris_url<S: Into<String>>(mut self, url: S) -> Self {
|
||||||
self.osiris_url = Some(url.into());
|
self.osiris_url = Some(url.into());
|
||||||
|
|||||||
Reference in New Issue
Block a user