add support for custom cluster name
This commit is contained in:
parent
95a2299405
commit
7b25b0f15d
@ -28,7 +28,7 @@ class K8sAPI:
|
|||||||
def __init__(self):
|
def __init__(self):
|
||||||
super().__init__()
|
super().__init__()
|
||||||
self.namespace = os.environ.get("CRAWLER_NAMESPACE") or "crawlers"
|
self.namespace = os.environ.get("CRAWLER_NAMESPACE") or "crawlers"
|
||||||
self.browser_sufix = os.environ.get("CRAWLER_FQDN_SUFFIX") or ".crawlers.svc.k.brass.host"
|
self.browser_suffix = os.environ.get("CRAWLER_FQDN_SUFFIX") or ".crawlers.svc.cluster.local"
|
||||||
self.custom_resources = {}
|
self.custom_resources = {}
|
||||||
|
|
||||||
self.templates = Jinja2Templates(
|
self.templates = Jinja2Templates(
|
||||||
@ -63,7 +63,7 @@ class K8sAPI:
|
|||||||
def get_redis_url(self, crawl_id):
|
def get_redis_url(self, crawl_id):
|
||||||
"""get redis url for crawl id"""
|
"""get redis url for crawl id"""
|
||||||
redis_url = (
|
redis_url = (
|
||||||
f"redis://redis-{crawl_id}.redis.{self.namespace}{self.browser_suffix}/0"
|
f"redis://redis-{crawl_id}.redis{self.browser_suffix}/0"
|
||||||
)
|
)
|
||||||
return redis_url
|
return redis_url
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user