[Improve][Manager] Add a heartbeat timeout status to the source

[fuweng11]

Description

Add a heartBeatTimeout status to the source.

Currently streamSource has the following problems：
1.StreamSource information that is in the status to be delivered or modified cannot be deleted.
2.If the agent does not report data for a long time due to the abnormal status of the streamSource, streamSource information cannot be deleted or remains in the status to be issued for a long time.

Solution：
Currently, the Agent supports heartbeat reporting and automatic registration. After receiving the heartbeat information from the Agent, the Manager registers the corresponding cluster and node information and sets the node status to NORMAL.

To solve the above two problems, the agent HEARTBEAT_TIMEOUT state is added to the streamSource. The streamSource in this state can be deleted but cannot be modified.

In this case, if the Agent cluster corresponding to the data source to be delivered fails to report the heartbeat information due to various problems, the Manager does not receive the heartbeat information of the Agent for a long time and changes the node status to HEARTBEAT_TIMEOUT and change the status of the streamSource corresponding to the node to agent heartbeat Timeout.

In this case, you can choose to delete the data source or wait for the recovery of the agent node to continue the task. If you choose to delete the data source, after the Agent node recovers,

The Manager determines if the previous task needs to continue based on the is_deleted property of the current data source, if is_delted! =0, the current data source needs to be deleted. Therefore, the data source status is changed to to be deleted.

To solve the above two problems.

InLong Component

InLong Manager

Are you willing to submit PR?

• Yes, I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct