11import abc
22import json
33import logging
4- from datetime import datetime
5- from threading import Thread , Event
64import time
5+
6+ from datetime import datetime
7+ from threading import Event , Thread
8+ from typing import Union
9+
710import six
811
9- from .dcs import Member , Cluster
12+ import kubernetes
13+
14+ from .dcs import Cluster , Member
1015from .dcs .kubernetes import catch_kubernetes_errors , Kubernetes
1116from .exceptions import DCSError
1217
13- import kubernetes
14-
1518logger = logging .getLogger (__name__ )
1619
1720@six .add_metaclass (abc .ABCMeta )
@@ -25,13 +28,14 @@ def start(self):
2528 def shutdown (self ):
2629 pass
2730
28- def get_active_standby_config (self ):
31+ def get_active_standby_config (self ) -> Union [ dict , None ] :
2932 """Returns currently active configuration for standby leader"""
33+ return {}
3034
3135 def is_leader_site (self ):
3236 return self .get_active_standby_config () is None
3337
34- def resolve_leader (self ):
38+ def resolve_leader (self ) -> Union [ str , None ] :
3539 """Try to become leader, update active config correspondingly.
3640
3741 Return error when unable to resolve"""
@@ -48,9 +52,9 @@ def release(self):
4852 pass
4953
5054 def status (self ):
51- pass
55+ return {}
5256
53- def should_failover (self ):
57+ def should_failover (self ) -> bool :
5458 return False
5559
5660 def on_shutdown (self , checkpoint_location ):
0 commit comments