Public Member Functions | |
| EtcdWatcher (ConfigEtcdClient *etcd_client) | |
| virtual bool | Run () |
| Code to execute in a task. Returns true if task is completed. Return false to reschedule the task. More... | |
| ConfigEtcdClient * | client () const |
| string | Description () const |
| Gives a description of the task. More... | |
 Public Member Functions inherited from Task | |
| Task (int task_id, int task_data_id) | |
| Creates a new task with the given values of task code ID and task data ID. More... | |
| Task (int task_id) | |
| Creates a new task with the given value of task code ID and wildcard for task data ID. More... | |
| virtual | ~Task () |
| Destroys a task. More... | |
| virtual void | OnTaskCancel () |
| Called on task exit, if it is marked for cancellation. If the user wants to do any cleanup on task cancellation, then he/she can overload this function. More... | |
| State | state () const |
| Returns a state value of a task. More... | |
| int | task_code_id () const |
| Returns the code ID of this task. More... | |
| int | task_data_id () const |
| Returns the data ID of this task. More... | |
| uint64_t | seqno () const |
| Returns the sequence number of this task. More... | |
| bool | task_cancelled () const |
| Returns true if the task has been canceled. More... | |
| uint64_t | enqueue_time () const |
| Returns the time when the task was enqueued for execution. More... | |
| uint64_t | schedule_time () const |
| Returns the time when the task execution was started. More... | |
| uint32_t | execute_delay () const |
| Returns the threshold for the task execution duration. More... | |
| uint32_t | schedule_delay () const |
| Returns the time threshold for time difference between moments when the task was started and when it was enqueue. More... | |
Private Member Functions | |
| void | ProcessResponse (EtcdResponse resp) |
Private Attributes | |
| ConfigEtcdClient * | etcd_client_ |
Additional Inherited Members | |
| Public Types inherited from Task | |
| enum | State { INIT , WAIT , RUN } |
| Task states. More... | |
| enum | TbbState { TBB_INIT , TBB_ENQUEUED , TBB_EXEC , TBB_DONE } |
| Describes states of a task according to TBB library. More... | |
| Static Public Member Functions inherited from Task | |
| static Task * | Running () |
| Returns a pointer to the current task the code is executing under. More... | |
| Static Public Attributes inherited from Task | |
| static const int | kTaskInstanceAny = -1 |
| Specifies value for wildcard (any or *) task data ID. More... | |
Detailed Description
ETCD Watcher class to enable watching for any changes to config. Invokes etcd::Watch() which watches the ETCD server for any changes and invokes provided callback when a change is detected.
Definition at line 62 of file config_etcd_client.cc.
Constructor & Destructor Documentation
◆ EtcdWatcher()
|
inline |
Definition at line 64 of file config_etcd_client.cc.
Member Function Documentation
◆ client()
|
inline |
Definition at line 71 of file config_etcd_client.cc.
◆ Description()
|
inlinevirtual |
Gives a description of the task.
Implements Task.
Definition at line 74 of file config_etcd_client.cc.
◆ ProcessResponse()
|
private |
◆ Run()
|
virtual |
Code to execute in a task. Returns true if task is completed. Return false to reschedule the task.
If reinit is triggerred, don't wait for end of config trigger. Return from here to process reinit.
Invoke etcd client library to watch for changes.
Implements Task.
Definition at line 141 of file config_etcd_client.cc.
Member Data Documentation
◆ etcd_client_
|
private |
Definition at line 79 of file config_etcd_client.cc.
The documentation for this class was generated from the following file:
