# Functions
HeartbeatPingTopic is heartbeat ping message topic, each master has a unique one.
HeartbeatPongTopic is heartbeat pong message topic, each worker has a unique one.
WorkerStatusChangeRequestTopic message topic used when updating worker status.
# Constants
Defines all task type TODO: Refine me.Currently, when adding a new worker type or job type, we need to modify many code places, NOTICE: DO NOT CHANGE the previous worker type Modify the comment in model IF you add some new worker type.
Defines all task type TODO: Refine me.Currently, when adding a new worker type or job type, we need to modify many code places, NOTICE: DO NOT CHANGE the previous worker type Modify the comment in model IF you add some new worker type.
job master.
task.
Defines all task type TODO: Refine me.Currently, when adding a new worker type or job type, we need to modify many code places, NOTICE: DO NOT CHANGE the previous worker type Modify the comment in model IF you add some new worker type.
Defines all task type TODO: Refine me.Currently, when adding a new worker type or job type, we need to modify many code places, NOTICE: DO NOT CHANGE the previous worker type Modify the comment in model IF you add some new worker type.
Defines all task type TODO: Refine me.Currently, when adding a new worker type or job type, we need to modify many code places, NOTICE: DO NOT CHANGE the previous worker type Modify the comment in model IF you add some new worker type.
Defines all task type TODO: Refine me.Currently, when adding a new worker type or job type, we need to modify many code places, NOTICE: DO NOT CHANGE the previous worker type Modify the comment in model IF you add some new worker type.
Defines all task type TODO: Refine me.Currently, when adding a new worker type or job type, we need to modify many code places, NOTICE: DO NOT CHANGE the previous worker type Modify the comment in model IF you add some new worker type.
Job master statuses NOTICE: DO NOT CHANGE the previous status code Modify the MasterMeta.State comment IF you add some new status code.
Job master statuses NOTICE: DO NOT CHANGE the previous status code Modify the MasterMeta.State comment IF you add some new status code.
Job master statuses NOTICE: DO NOT CHANGE the previous status code Modify the MasterMeta.State comment IF you add some new status code.
Job master statuses NOTICE: DO NOT CHANGE the previous status code Modify the MasterMeta.State comment IF you add some new status code.
Job master statuses NOTICE: DO NOT CHANGE the previous status code Modify the MasterMeta.State comment IF you add some new status code.
worker.
Defines all task type TODO: Refine me.Currently, when adding a new worker type or job type, we need to modify many code places, NOTICE: DO NOT CHANGE the previous worker type Modify the comment in model IF you add some new worker type.
Defines all task type TODO: Refine me.Currently, when adding a new worker type or job type, we need to modify many code places, NOTICE: DO NOT CHANGE the previous worker type Modify the comment in model IF you add some new worker type.
Among these statuses, only WorkerStateCreated is used by the framework for now.
Among these statuses, only WorkerStateCreated is used by the framework for now.
Among these statuses, only WorkerStateCreated is used by the framework for now.
Among these statuses, only WorkerStateCreated is used by the framework for now.
Among these statuses, only WorkerStateCreated is used by the framework for now.
Among these statuses, only WorkerStateCreated is used by the framework for now.
# Variables
MasterUpdateColumns is used in gorm update TODO: using reflect to generate it more generally related to some implement of gorm.
WorkerUpdateColumns is used in gorm update.
# Structs
HeartbeatPingMessage ships information in heartbeat ping.
HeartbeatPongMessage ships information in heartbeat pong.
MasterMeta defines the metadata of job master.
MasterMetaExt stores some attributes of job masters that do not need to be indexed.
StatusChangeRequest ships information when updating worker status.
WorkerStatus records worker information, including master id, worker id, worker type, project id(tenant), worker status(used in master worker framework), error message and ext bytes(passed from business logic) in metastore.
# Type aliases
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
WorkerState represents worker running status in master worker framework TODO: add fsm of WorkerState.
No description provided by the author