From 04bf9bdffa9ac4087bd2858bcfb3b1c8b4240350 Mon Sep 17 00:00:00 2001 From: TimHuynh Date: Fri, 20 Oct 2023 13:58:02 -0500 Subject: [PATCH 01/11] pre work --- cmd/vela-worker/operate.go | 19 +++++++++++++++++++ docker-compose.yml | 5 ++++- go.mod | 2 ++ go.sum | 2 -- 4 files changed, 25 insertions(+), 3 deletions(-) diff --git a/cmd/vela-worker/operate.go b/cmd/vela-worker/operate.go index b0e50b09..178488ed 100644 --- a/cmd/vela-worker/operate.go +++ b/cmd/vela-worker/operate.go @@ -122,6 +122,25 @@ func (w *Worker) operate(ctx context.Context) error { continue } + pErr := w.Queue.Ping(ctx) + if pErr != nil { + logrus.Errorf("worker %s unable to conteact the queue: %v", registryWorker.GetHostname(), err) + registryWorker.SetStatus(constants.WorkerStatusError) + _, resp, logErr := w.VelaClient.Worker.Update(registryWorker.GetHostname(), registryWorker) + + if resp == nil { + // log the error instead of returning so the operation doesn't block worker deployment + logrus.Error("worker status update response is nil") + } + + if logErr != nil { + if resp != nil { + // log the error instead of returning so the operation doesn't block worker deployment + logrus.Errorf("status code: %v, unable to update worker %s status with the server: %v", resp.StatusCode, registryWorker.GetHostname(), logErr) + } + } + + } // check in failed, token is still valid, retry logrus.Errorf("unable to check-in worker %s on the server: %v", registryWorker.GetHostname(), err) logrus.Info("retrying check-in...") diff --git a/docker-compose.yml b/docker-compose.yml index d20aeef7..71983a73 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -47,8 +47,11 @@ services: # # https://go-vela.github.io/docs/administration/server/ server: + build: + context: . + dockerfile: Dockerfile container_name: server - image: target/vela-server:latest + image: server:local networks: - vela environment: diff --git a/go.mod b/go.mod index 33ac9610..6ae47f89 100644 --- a/go.mod +++ b/go.mod @@ -2,6 +2,8 @@ module github.com/go-vela/worker go 1.21 +replace github.com/go-vela/server => ../server + require ( github.com/Masterminds/semver/v3 v3.2.1 github.com/docker/distribution v2.8.2+incompatible diff --git a/go.sum b/go.sum index 6b217251..b65ee637 100644 --- a/go.sum +++ b/go.sum @@ -152,8 +152,6 @@ github.com/go-task/slim-sprig v0.0.0-20230315185526-52ccab3ef572 h1:tfuBGBXKqDEe github.com/go-task/slim-sprig v0.0.0-20230315185526-52ccab3ef572/go.mod h1:9Pwr4B2jHnOSGXyyzV8ROjYa2ojvAY6HCGYYfMoC3Ls= github.com/go-vela/sdk-go v0.21.0 h1:Hedak1Yk9rGn3ZBOvLvxLrMcyvBf3+RB6/wMgHNxyxw= github.com/go-vela/sdk-go v0.21.0/go.mod h1:fNMQxSqBCXQH6bK3Ej0aCj/iugEDZNEIWW3Xj/m22AQ= -github.com/go-vela/server v0.21.1-0.20231017135815-bb35e76f6056 h1:TqLmvWRU3sqflw7kRUxDRw4H5g9JupLIp0JAGI8biG8= -github.com/go-vela/server v0.21.1-0.20231017135815-bb35e76f6056/go.mod h1:SFAAje/TsPxW+9iDo38CotLX0ralvPRLxbaS9fffT+A= github.com/go-vela/types v0.21.1-0.20231012142227-0c0b890487af h1:qiP6pXFDyPDDP+hy8zY+nhmoWv9aoQrrnNmfAAT6yCA= github.com/go-vela/types v0.21.1-0.20231012142227-0c0b890487af/go.mod h1:Jn8K28uj7mACc55fkFgaIzL0q45iXydOFGEeoSeHUtQ= github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU= From 37255311a0607ea975e32cc75a2875c2bb281274 Mon Sep 17 00:00:00 2001 From: TimHuynh Date: Mon, 23 Oct 2023 15:38:32 -0500 Subject: [PATCH 02/11] working code --- cmd/vela-worker/operate.go | 58 ++++++++++++------------------------- cmd/vela-worker/register.go | 45 ++++++++++++++++++++++++++++ cmd/vela-worker/worker.go | 2 ++ 3 files changed, 65 insertions(+), 40 deletions(-) diff --git a/cmd/vela-worker/operate.go b/cmd/vela-worker/operate.go index 178488ed..6ddc6bb7 100644 --- a/cmd/vela-worker/operate.go +++ b/cmd/vela-worker/operate.go @@ -4,9 +4,9 @@ package main import ( "context" + "github.com/go-vela/server/queue" "time" - "github.com/go-vela/server/queue" "github.com/go-vela/types/constants" "github.com/go-vela/types/library" @@ -47,13 +47,10 @@ func (w *Worker) operate(ctx context.Context) error { } logrus.Trace("getting queue creds") - // fetching queue credentials using registration token creds, _, err := w.VelaClient.Queue.GetInfo() if err != nil { logrus.Trace("error getting creds") - - return err } // set queue address and public key using credentials received from server @@ -66,23 +63,8 @@ func (w *Worker) operate(ctx context.Context) error { w.Queue, err = queue.New(w.Config.Queue) if err != nil { logrus.Error("queue setup failed") - - registryWorker.SetStatus(constants.WorkerStatusError) - _, resp, logErr := w.VelaClient.Worker.Update(registryWorker.GetHostname(), registryWorker) - - if resp == nil { - // log the error instead of returning so the operation doesn't block worker deployment - logrus.Error("worker status update response is nil") - } - - if logErr != nil { - if resp != nil { - // log the error instead of returning so the operation doesn't block worker deployment - logrus.Errorf("status code: %v, unable to update worker %s status with the server: %v", resp.StatusCode, registryWorker.GetHostname(), logErr) - } - } - - return err + // set to error as queue setup fails + w.updateWorkerStatus(registryWorker, constants.WorkerStatusError) } // spawn goroutine for phoning home @@ -122,25 +104,6 @@ func (w *Worker) operate(ctx context.Context) error { continue } - pErr := w.Queue.Ping(ctx) - if pErr != nil { - logrus.Errorf("worker %s unable to conteact the queue: %v", registryWorker.GetHostname(), err) - registryWorker.SetStatus(constants.WorkerStatusError) - _, resp, logErr := w.VelaClient.Worker.Update(registryWorker.GetHostname(), registryWorker) - - if resp == nil { - // log the error instead of returning so the operation doesn't block worker deployment - logrus.Error("worker status update response is nil") - } - - if logErr != nil { - if resp != nil { - // log the error instead of returning so the operation doesn't block worker deployment - logrus.Errorf("status code: %v, unable to update worker %s status with the server: %v", resp.StatusCode, registryWorker.GetHostname(), logErr) - } - } - - } // check in failed, token is still valid, retry logrus.Errorf("unable to check-in worker %s on the server: %v", registryWorker.GetHostname(), err) logrus.Info("retrying check-in...") @@ -149,6 +112,15 @@ func (w *Worker) operate(ctx context.Context) error { continue } + w.QueueCheckIn, err = w.queueCheckIn(gctx, registryWorker) + if err != nil { + // queue check in failed, retry + logrus.Errorf("unable to ping queue %v", err) + logrus.Info("retrying check-in...") + + time.Sleep(5 * time.Second) + continue + } // successful check in breaks the loop break @@ -190,6 +162,12 @@ func (w *Worker) operate(ctx context.Context) error { logrus.Info("worker not checked in, skipping queue read") continue } + // do not pull from queue unless queue setup is done and connected + if !w.QueueCheckIn { + time.Sleep(5 * time.Second) + logrus.Info("queue ping fails, skipping queue read") + continue + } select { case <-gctx.Done(): logrus.WithFields(logrus.Fields{ diff --git a/cmd/vela-worker/register.go b/cmd/vela-worker/register.go index 76ffab99..44dc5556 100644 --- a/cmd/vela-worker/register.go +++ b/cmd/vela-worker/register.go @@ -3,6 +3,7 @@ package main import ( + "context" "fmt" "net/http" @@ -19,6 +20,7 @@ func (w *Worker) checkIn(config *library.Worker) (bool, string, error) { _, resp, err := w.VelaClient.Worker.Get(config.GetHostname()) if err != nil { respErr := fmt.Errorf("unable to retrieve worker %s from the server: %w", config.GetHostname(), err) + // in the event of server is down, the worker status will not be updated if resp == nil { return false, "", respErr } @@ -35,8 +37,12 @@ func (w *Worker) checkIn(config *library.Worker) (bool, string, error) { tkn, _, err := w.VelaClient.Worker.RefreshAuth(config.GetHostname()) if err != nil { + // set to error as check in fails + w.updateWorkerStatus(config, constants.WorkerStatusError) return false, "", fmt.Errorf("unable to refresh auth for worker %s on the server: %w", config.GetHostname(), err) } + // update worker status to Idle when checkIn is successful. + w.updateWorkerStatus(config, constants.WorkerStatusIdle) return true, tkn.GetToken(), nil } @@ -45,6 +51,8 @@ func (w *Worker) checkIn(config *library.Worker) (bool, string, error) { func (w *Worker) register(config *library.Worker) (bool, string, error) { logrus.Infof("worker %s not found, registering it with the server", config.GetHostname()) + // status Idle will be set for worker upon first time registration + // if worker cannot be registered, no status will be set. config.SetStatus(constants.WorkerStatusIdle) tkn, _, err := w.VelaClient.Worker.Add(config) @@ -58,3 +66,40 @@ func (w *Worker) register(config *library.Worker) (bool, string, error) { // successfully added the worker so return nil return true, tkn.GetToken(), nil } + +// queueCheckIn is a helper function to phone home to the redis. +func (w *Worker) queueCheckIn(ctx context.Context, registryWorker *library.Worker) (bool, error) { + pErr := w.Queue.Ping(ctx) + if pErr != nil { + logrus.Errorf("worker %s unable to contact the queue: %v", registryWorker.GetHostname(), pErr) + // set status to error as queue is not available + w.updateWorkerStatus(registryWorker, constants.WorkerStatusError) + + return false, pErr + } + + // update worker status to Idle when setup and ping are good. + w.updateWorkerStatus(registryWorker, constants.WorkerStatusIdle) + + return true, nil +} + +// updateWorkerStatus is a helper function to update worker status +// logs the error if it can't update status +func (w *Worker) updateWorkerStatus(config *library.Worker, status string) { + config.SetStatus(status) + _, resp, logErr := w.VelaClient.Worker.Update(config.GetHostname(), config) + + if resp == nil { + // log the error instead of returning so the operation doesn't block worker deployment + logrus.Error("worker status update response is nil") + } + + if logErr != nil { + if resp != nil { + // log the error instead of returning so the operation doesn't block worker deployment + logrus.Errorf("status code: %v, unable to update worker %s status with the server: %v", + resp.StatusCode, config.GetHostname(), logErr) + } + } +} diff --git a/cmd/vela-worker/worker.go b/cmd/vela-worker/worker.go index 19c6c41b..df0b7539 100644 --- a/cmd/vela-worker/worker.go +++ b/cmd/vela-worker/worker.go @@ -68,6 +68,8 @@ type ( VelaClient *vela.Client RegisterToken chan string CheckedIn bool + QueueCheckIn bool + QueueRegister bool RunningBuildIDs []string RunningBuildIDsMutex sync.Mutex } From b7f0c5048bbaaef2360925c656291586b104e99f Mon Sep 17 00:00:00 2001 From: TimHuynh Date: Mon, 23 Oct 2023 15:56:20 -0500 Subject: [PATCH 03/11] cleanup --- cmd/vela-worker/worker.go | 1 - go.mod | 2 -- go.sum | 2 ++ 3 files changed, 2 insertions(+), 3 deletions(-) diff --git a/cmd/vela-worker/worker.go b/cmd/vela-worker/worker.go index df0b7539..ad031492 100644 --- a/cmd/vela-worker/worker.go +++ b/cmd/vela-worker/worker.go @@ -69,7 +69,6 @@ type ( RegisterToken chan string CheckedIn bool QueueCheckIn bool - QueueRegister bool RunningBuildIDs []string RunningBuildIDsMutex sync.Mutex } diff --git a/go.mod b/go.mod index 6ae47f89..33ac9610 100644 --- a/go.mod +++ b/go.mod @@ -2,8 +2,6 @@ module github.com/go-vela/worker go 1.21 -replace github.com/go-vela/server => ../server - require ( github.com/Masterminds/semver/v3 v3.2.1 github.com/docker/distribution v2.8.2+incompatible diff --git a/go.sum b/go.sum index b65ee637..6b217251 100644 --- a/go.sum +++ b/go.sum @@ -152,6 +152,8 @@ github.com/go-task/slim-sprig v0.0.0-20230315185526-52ccab3ef572 h1:tfuBGBXKqDEe github.com/go-task/slim-sprig v0.0.0-20230315185526-52ccab3ef572/go.mod h1:9Pwr4B2jHnOSGXyyzV8ROjYa2ojvAY6HCGYYfMoC3Ls= github.com/go-vela/sdk-go v0.21.0 h1:Hedak1Yk9rGn3ZBOvLvxLrMcyvBf3+RB6/wMgHNxyxw= github.com/go-vela/sdk-go v0.21.0/go.mod h1:fNMQxSqBCXQH6bK3Ej0aCj/iugEDZNEIWW3Xj/m22AQ= +github.com/go-vela/server v0.21.1-0.20231017135815-bb35e76f6056 h1:TqLmvWRU3sqflw7kRUxDRw4H5g9JupLIp0JAGI8biG8= +github.com/go-vela/server v0.21.1-0.20231017135815-bb35e76f6056/go.mod h1:SFAAje/TsPxW+9iDo38CotLX0ralvPRLxbaS9fffT+A= github.com/go-vela/types v0.21.1-0.20231012142227-0c0b890487af h1:qiP6pXFDyPDDP+hy8zY+nhmoWv9aoQrrnNmfAAT6yCA= github.com/go-vela/types v0.21.1-0.20231012142227-0c0b890487af/go.mod h1:Jn8K28uj7mACc55fkFgaIzL0q45iXydOFGEeoSeHUtQ= github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU= From f48579c361485e75368c3540b12fd38cb4392838 Mon Sep 17 00:00:00 2001 From: TimHuynh Date: Tue, 24 Oct 2023 09:18:35 -0500 Subject: [PATCH 04/11] reset docker compose --- docker-compose.yml | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/docker-compose.yml b/docker-compose.yml index 71983a73..d20aeef7 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -47,11 +47,8 @@ services: # # https://go-vela.github.io/docs/administration/server/ server: - build: - context: . - dockerfile: Dockerfile container_name: server - image: server:local + image: target/vela-server:latest networks: - vela environment: From f3b1c0ce4b850ef8464d34ebb5464a455118cbc6 Mon Sep 17 00:00:00 2001 From: Tim Huynh Date: Wed, 25 Oct 2023 09:19:57 -0500 Subject: [PATCH 05/11] Update cmd/vela-worker/register.go Co-authored-by: Jacob Floyd --- cmd/vela-worker/register.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/vela-worker/register.go b/cmd/vela-worker/register.go index 44dc5556..6b92db50 100644 --- a/cmd/vela-worker/register.go +++ b/cmd/vela-worker/register.go @@ -37,7 +37,7 @@ func (w *Worker) checkIn(config *library.Worker) (bool, string, error) { tkn, _, err := w.VelaClient.Worker.RefreshAuth(config.GetHostname()) if err != nil { - // set to error as check in fails + // set to error when check in fails w.updateWorkerStatus(config, constants.WorkerStatusError) return false, "", fmt.Errorf("unable to refresh auth for worker %s on the server: %w", config.GetHostname(), err) } From 1196b4282693b7deeab9d94ab32c148ea4ad0cd9 Mon Sep 17 00:00:00 2001 From: Tim Huynh Date: Wed, 25 Oct 2023 09:20:05 -0500 Subject: [PATCH 06/11] Update cmd/vela-worker/register.go Co-authored-by: Jacob Floyd --- cmd/vela-worker/register.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/vela-worker/register.go b/cmd/vela-worker/register.go index 6b92db50..7460e84a 100644 --- a/cmd/vela-worker/register.go +++ b/cmd/vela-worker/register.go @@ -20,7 +20,7 @@ func (w *Worker) checkIn(config *library.Worker) (bool, string, error) { _, resp, err := w.VelaClient.Worker.Get(config.GetHostname()) if err != nil { respErr := fmt.Errorf("unable to retrieve worker %s from the server: %w", config.GetHostname(), err) - // in the event of server is down, the worker status will not be updated + // if server is down, the worker status will not be updated if resp == nil { return false, "", respErr } From 40e410f8d5239d626c8c782fbfe3cf1516dfaf77 Mon Sep 17 00:00:00 2001 From: Tim Huynh Date: Wed, 25 Oct 2023 09:20:16 -0500 Subject: [PATCH 07/11] Update cmd/vela-worker/operate.go Co-authored-by: Jacob Floyd --- cmd/vela-worker/operate.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/vela-worker/operate.go b/cmd/vela-worker/operate.go index 6ddc6bb7..ca507ccf 100644 --- a/cmd/vela-worker/operate.go +++ b/cmd/vela-worker/operate.go @@ -165,7 +165,7 @@ func (w *Worker) operate(ctx context.Context) error { // do not pull from queue unless queue setup is done and connected if !w.QueueCheckIn { time.Sleep(5 * time.Second) - logrus.Info("queue ping fails, skipping queue read") + logrus.Info("queue ping failed, skipping queue read") continue } select { From 15076f7107589012c72b080c0225748cc15e8c34 Mon Sep 17 00:00:00 2001 From: TimHuynh Date: Wed, 25 Oct 2023 10:12:13 -0500 Subject: [PATCH 08/11] fix typos --- cmd/vela-worker/operate.go | 5 +++-- cmd/vela-worker/worker.go | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/cmd/vela-worker/operate.go b/cmd/vela-worker/operate.go index ca507ccf..9dcd83ed 100644 --- a/cmd/vela-worker/operate.go +++ b/cmd/vela-worker/operate.go @@ -51,6 +51,7 @@ func (w *Worker) operate(ctx context.Context) error { creds, _, err := w.VelaClient.Queue.GetInfo() if err != nil { logrus.Trace("error getting creds") + return err } // set queue address and public key using credentials received from server @@ -112,7 +113,7 @@ func (w *Worker) operate(ctx context.Context) error { continue } - w.QueueCheckIn, err = w.queueCheckIn(gctx, registryWorker) + w.QueueCheckedIn, err = w.queueCheckIn(gctx, registryWorker) if err != nil { // queue check in failed, retry logrus.Errorf("unable to ping queue %v", err) @@ -163,7 +164,7 @@ func (w *Worker) operate(ctx context.Context) error { continue } // do not pull from queue unless queue setup is done and connected - if !w.QueueCheckIn { + if !w.QueueCheckedIn { time.Sleep(5 * time.Second) logrus.Info("queue ping failed, skipping queue read") continue diff --git a/cmd/vela-worker/worker.go b/cmd/vela-worker/worker.go index ad031492..af03ff77 100644 --- a/cmd/vela-worker/worker.go +++ b/cmd/vela-worker/worker.go @@ -68,7 +68,7 @@ type ( VelaClient *vela.Client RegisterToken chan string CheckedIn bool - QueueCheckIn bool + QueueCheckedIn bool RunningBuildIDs []string RunningBuildIDsMutex sync.Mutex } From c1a6528c6237bd26182f6af9664700acf83e335d Mon Sep 17 00:00:00 2001 From: TimHuynh Date: Wed, 25 Oct 2023 10:13:04 -0500 Subject: [PATCH 09/11] fix import --- cmd/vela-worker/operate.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/cmd/vela-worker/operate.go b/cmd/vela-worker/operate.go index 9dcd83ed..5f1170bf 100644 --- a/cmd/vela-worker/operate.go +++ b/cmd/vela-worker/operate.go @@ -4,12 +4,11 @@ package main import ( "context" - "github.com/go-vela/server/queue" "time" + "github.com/go-vela/server/queue" "github.com/go-vela/types/constants" "github.com/go-vela/types/library" - "github.com/sirupsen/logrus" "golang.org/x/sync/errgroup" From 8543d7403e60ddc66787033866681ca43ce3002d Mon Sep 17 00:00:00 2001 From: TimHuynh Date: Tue, 31 Oct 2023 14:53:59 -0500 Subject: [PATCH 10/11] add logging --- cmd/vela-worker/register.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/cmd/vela-worker/register.go b/cmd/vela-worker/register.go index 7460e84a..ae07a369 100644 --- a/cmd/vela-worker/register.go +++ b/cmd/vela-worker/register.go @@ -101,5 +101,10 @@ func (w *Worker) updateWorkerStatus(config *library.Worker, status string) { logrus.Errorf("status code: %v, unable to update worker %s status with the server: %v", resp.StatusCode, config.GetHostname(), logErr) } + if resp == nil { + // log the error instead of returning so the operation doesn't block worker deployment + logrus.Errorf("worker status update response is nil, unable to update worker %s status with the server: %v", + config.GetHostname(), logErr) + } } } From 46b7db4ae5395aa9f61c5b2465a70e714539e546 Mon Sep 17 00:00:00 2001 From: TimHuynh Date: Tue, 31 Oct 2023 14:57:29 -0500 Subject: [PATCH 11/11] make clean --- go.mod | 4 ++-- go.sum | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/go.mod b/go.mod index 33ac9610..bf46316d 100644 --- a/go.mod +++ b/go.mod @@ -9,8 +9,8 @@ require ( github.com/docker/go-units v0.5.0 github.com/gin-gonic/gin v1.9.1 github.com/go-vela/sdk-go v0.21.0 - github.com/go-vela/server v0.21.1-0.20231017135815-bb35e76f6056 - github.com/go-vela/types v0.21.1-0.20231012142227-0c0b890487af + github.com/go-vela/server v0.21.1-0.20231031195602-6708cea79580 + github.com/go-vela/types v0.21.1-0.20231024201126-19101a5b1346 github.com/golang-jwt/jwt/v5 v5.0.0 github.com/google/go-cmp v0.5.9 github.com/joho/godotenv v1.5.1 diff --git a/go.sum b/go.sum index 6b217251..1b40c434 100644 --- a/go.sum +++ b/go.sum @@ -152,10 +152,10 @@ github.com/go-task/slim-sprig v0.0.0-20230315185526-52ccab3ef572 h1:tfuBGBXKqDEe github.com/go-task/slim-sprig v0.0.0-20230315185526-52ccab3ef572/go.mod h1:9Pwr4B2jHnOSGXyyzV8ROjYa2ojvAY6HCGYYfMoC3Ls= github.com/go-vela/sdk-go v0.21.0 h1:Hedak1Yk9rGn3ZBOvLvxLrMcyvBf3+RB6/wMgHNxyxw= github.com/go-vela/sdk-go v0.21.0/go.mod h1:fNMQxSqBCXQH6bK3Ej0aCj/iugEDZNEIWW3Xj/m22AQ= -github.com/go-vela/server v0.21.1-0.20231017135815-bb35e76f6056 h1:TqLmvWRU3sqflw7kRUxDRw4H5g9JupLIp0JAGI8biG8= -github.com/go-vela/server v0.21.1-0.20231017135815-bb35e76f6056/go.mod h1:SFAAje/TsPxW+9iDo38CotLX0ralvPRLxbaS9fffT+A= -github.com/go-vela/types v0.21.1-0.20231012142227-0c0b890487af h1:qiP6pXFDyPDDP+hy8zY+nhmoWv9aoQrrnNmfAAT6yCA= -github.com/go-vela/types v0.21.1-0.20231012142227-0c0b890487af/go.mod h1:Jn8K28uj7mACc55fkFgaIzL0q45iXydOFGEeoSeHUtQ= +github.com/go-vela/server v0.21.1-0.20231031195602-6708cea79580 h1:u1B9VAj6eMouR37zRXQ7ThXrXu282ud6+rvefQa8TOE= +github.com/go-vela/server v0.21.1-0.20231031195602-6708cea79580/go.mod h1:1nQQLHtK1EJWW/0sQ/62ryYsg4OccDt8JRmbzoIe+IA= +github.com/go-vela/types v0.21.1-0.20231024201126-19101a5b1346 h1:8VqRJ02KcAxV+gHuxLzuPuNaf7EOE/zfBomEV+UPj/E= +github.com/go-vela/types v0.21.1-0.20231024201126-19101a5b1346/go.mod h1:Jn8K28uj7mACc55fkFgaIzL0q45iXydOFGEeoSeHUtQ= github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU= github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I= github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q=