feat: add Redis URL and namespace configuration to supervisor builder
This commit is contained in:
@@ -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