wehub-resource-sync
37 lines
1.8 KiB
Go
37 lines
1.8 KiB
Go
package messaging
|
|
|
|
// Phase values published on the BackendInstallProgressEvent.Phase field.
|
|
// Defined as exported constants so producer (worker install handler) and
|
|
// consumer (master bridge into OpStatus) share a single source of truth
|
|
// instead of two copies of the literal string.
|
|
const (
|
|
PhaseResolving = "resolving" // worker is locating the gallery / image manifest
|
|
PhaseDownloading = "downloading" // worker is actively pulling layers
|
|
PhaseExtracting = "extracting" // worker is unpacking the downloaded archive
|
|
PhaseStarting = "starting" // worker is spawning the gRPC backend process
|
|
)
|
|
|
|
// BackendInstallProgressEvent is the wire payload published by a worker to
|
|
// nodes.<nodeID>.backend.install.<opID>.progress while a long-running install
|
|
// is in flight. Transient: dropped events are acceptable, the master relies
|
|
// on BackendInstallReply for ground truth on success/failure.
|
|
//
|
|
// Phase holds one of the Phase* constants above.
|
|
type BackendInstallProgressEvent struct {
|
|
OpID string `json:"op_id"`
|
|
NodeID string `json:"node_id"`
|
|
Backend string `json:"backend"`
|
|
FileName string `json:"file_name,omitempty"`
|
|
Current string `json:"current,omitempty"` // human-readable size, e.g. "412 MB"
|
|
Total string `json:"total,omitempty"` // human-readable size, e.g. "2.1 GB"
|
|
Percentage float64 `json:"percentage"`
|
|
Phase string `json:"phase,omitempty"`
|
|
}
|
|
|
|
// SubjectNodeBackendInstallProgress returns the NATS subject for transient
|
|
// progress events emitted by a worker during a single backend.install run.
|
|
// Per-op so multiple concurrent installs on the same node never alias.
|
|
func SubjectNodeBackendInstallProgress(nodeID, opID string) string {
|
|
return subjectNodePrefix + sanitizeSubjectToken(nodeID) + ".backend.install." + sanitizeSubjectToken(opID) + ".progress"
|
|
}
|