()
| 109 | } |
| 110 | |
| 111 | func (w *WorkerNode) ConnectToWorker() proto.WorkerNodeInterfaceClient { |
| 112 | if w.wnConnection == nil { |
| 113 | var err error |
| 114 | |
| 115 | w.wnConnection, err = grpc_helpers.InitializeWorkerNodeConnection(w.IP, w.Port) |
| 116 | if err != nil { |
| 117 | logrus.Errorf("Failed to establish connection with the worker node.") |
| 118 | } |
| 119 | } |
| 120 | |
| 121 | return w.wnConnection |
| 122 | } |
| 123 | |
| 124 | func (w *WorkerNode) UpdateLastHearBeat() { |
| 125 | w.LastHeartbeat = time.Now() |
nothing calls this directly
no test coverage detected