From f334c489674c9ad224a791ced3eeec047e64e4ce Mon Sep 17 00:00:00 2001 From: Chad Retz Date: Wed, 8 Jun 2022 06:20:25 -0500 Subject: [PATCH] Update SDK to v1.15.0 (#200) --- .github/workflows/ci.yml | 2 +- branch/starter/main.go | 2 +- branch/worker/main.go | 2 +- cancellation/cancel/main.go | 2 +- cancellation/starter/main.go | 2 +- cancellation/worker/main.go | 2 +- .../starter/main.go | 2 +- child-workflow-continue-as-new/worker/main.go | 2 +- child-workflow/starter/main.go | 2 +- child-workflow/worker/main.go | 2 +- choice-exclusive/starter/main.go | 2 +- choice-exclusive/worker/main.go | 2 +- choice-multi/starter/main.go | 2 +- choice-multi/worker/main.go | 2 +- codec-server/starter/main.go | 2 +- codec-server/worker/main.go | 2 +- cron/starter/main.go | 2 +- cron/worker/main.go | 2 +- ctxpropagation/starter/main.go | 2 +- ctxpropagation/worker/main.go | 2 +- dsl/starter/main.go | 2 +- dsl/worker/main.go | 2 +- dynamic/starter/main.go | 2 +- dynamic/worker/main.go | 2 +- encryption/starter/main.go | 2 +- encryption/worker/main.go | 2 +- expense/server/main.go | 2 +- expense/starter/main.go | 2 +- expense/worker/main.go | 2 +- fileprocessing/starter/main.go | 2 +- fileprocessing/worker/main.go | 2 +- go.mod | 10 ++--- go.sum | 40 ++++++++++++------- greetings/starter/main.go | 2 +- greetings/worker/main.go | 2 +- greetingslocal/starter/main.go | 2 +- greetingslocal/worker/main.go | 2 +- grpc-proxy/starter/main.go | 2 +- grpc-proxy/worker/main.go | 2 +- helloworld/starter/main.go | 2 +- helloworld/worker/main.go | 2 +- interceptor/starter/main.go | 2 +- interceptor/worker/main.go | 2 +- metrics/starter/main.go | 2 +- metrics/worker/main.go | 2 +- mutex/starter/main.go | 2 +- mutex/worker/main.go | 2 +- parallel/starter/main.go | 2 +- parallel/worker/main.go | 2 +- pickfirst/starter/main.go | 2 +- pickfirst/worker/main.go | 2 +- pso/query/main.go | 2 +- pso/starter/main.go | 2 +- pso/worker/main.go | 2 +- query/query/main.go | 2 +- query/starter/main.go | 2 +- query/worker/main.go | 2 +- recovery/query/main.go | 2 +- recovery/signal/main.go | 2 +- recovery/starter/main.go | 6 +-- recovery/worker/main.go | 2 +- reqrespactivity/request/main.go | 2 +- reqrespactivity/starter/main.go | 2 +- reqrespactivity/worker/main.go | 2 +- reqrespquery/request/main.go | 2 +- reqrespquery/starter/main.go | 2 +- reqrespquery/worker/main.go | 2 +- retryactivity/starter/main.go | 2 +- retryactivity/worker/main.go | 2 +- searchattributes/starter/main.go | 2 +- searchattributes/worker/main.go | 2 +- serverjwtauth/starter/main.go | 2 +- serverjwtauth/worker/main.go | 2 +- snappycompress/starter/main.go | 2 +- snappycompress/worker/main.go | 2 +- splitmerge/starter/main.go | 2 +- splitmerge/worker/main.go | 2 +- synchronous-proxy/ui/main.go | 2 +- synchronous-proxy/worker/main.go | 2 +- .../large-event-history/starter/main.go | 2 +- .../large-event-history/worker/main.go | 2 +- .../largepayload/starter/main.go | 2 +- temporal-fixtures/largepayload/worker/main.go | 2 +- temporal-fixtures/openNclosed/starter/main.go | 2 +- temporal-fixtures/openNclosed/worker/main.go | 2 +- .../rainbowstatusesworkflow.json | 1 - .../rainbow-statuses/starter/main.go | 2 +- .../rainbow-statuses/worker/main.go | 2 +- .../stuck-workflows/starter/main.go | 2 +- .../stuck-workflows/worker/main.go | 2 +- timer/starter/main.go | 2 +- timer/worker/main.go | 2 +- updatabletimer/starter/main.go | 2 +- updatabletimer/updater/main.go | 2 +- updatabletimer/worker/main.go | 2 +- zapadapter/starter/main.go | 2 +- zapadapter/worker/main.go | 2 +- 97 files changed, 126 insertions(+), 117 deletions(-) diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index e4848821..d5c1aaf2 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -16,6 +16,6 @@ jobs: submodules: recursive - uses: actions/setup-go@v2 with: - go-version: "1.17" + go-version: "1.18" - name: CI Build run: make ci-build diff --git a/branch/starter/main.go b/branch/starter/main.go index b23a4e52..4c91f58a 100644 --- a/branch/starter/main.go +++ b/branch/starter/main.go @@ -12,7 +12,7 @@ import ( // @@@SNIPSTART samples-go-branch-workflow-execution-starter func main() { // The client is a heavyweight object that should be created only once per process. - c, err := client.NewClient(client.Options{}) + c, err := client.Dial(client.Options{}) if err != nil { panic(err) } diff --git a/branch/worker/main.go b/branch/worker/main.go index 16d8c40e..eab57b6f 100644 --- a/branch/worker/main.go +++ b/branch/worker/main.go @@ -12,7 +12,7 @@ import ( // @@@SNIPSTART samples-go-branch-worker-starter func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/cancellation/cancel/main.go b/cancellation/cancel/main.go index 70373958..2b760d47 100644 --- a/cancellation/cancel/main.go +++ b/cancellation/cancel/main.go @@ -20,7 +20,7 @@ func main() { } // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/cancellation/starter/main.go b/cancellation/starter/main.go index 85715e74..b7cda8f1 100644 --- a/cancellation/starter/main.go +++ b/cancellation/starter/main.go @@ -17,7 +17,7 @@ func main() { flag.Parse() // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/cancellation/worker/main.go b/cancellation/worker/main.go index 2519fee3..467f94b4 100644 --- a/cancellation/worker/main.go +++ b/cancellation/worker/main.go @@ -12,7 +12,7 @@ import ( // @@@SNIPSTART samples-go-cancellation-worker-starter func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/child-workflow-continue-as-new/starter/main.go b/child-workflow-continue-as-new/starter/main.go index 51a26846..062b2a9d 100644 --- a/child-workflow-continue-as-new/starter/main.go +++ b/child-workflow-continue-as-new/starter/main.go @@ -13,7 +13,7 @@ import ( // @@@SNIPSTART samples-go-cw-cas-workflow-execution-starter func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/child-workflow-continue-as-new/worker/main.go b/child-workflow-continue-as-new/worker/main.go index 01bd2429..0f5fc9ef 100644 --- a/child-workflow-continue-as-new/worker/main.go +++ b/child-workflow-continue-as-new/worker/main.go @@ -12,7 +12,7 @@ import ( // @@@SNIPSTART samples-go-cw-cas-worker-starter func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/child-workflow/starter/main.go b/child-workflow/starter/main.go index b2a44226..a2c6a695 100644 --- a/child-workflow/starter/main.go +++ b/child-workflow/starter/main.go @@ -13,7 +13,7 @@ import ( // @@@SNIPSTART samples-go-child-workflow-example-execution-starter func main() { // The client is a heavyweight object that should be created only once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/child-workflow/worker/main.go b/child-workflow/worker/main.go index 712733b7..55878d20 100644 --- a/child-workflow/worker/main.go +++ b/child-workflow/worker/main.go @@ -12,7 +12,7 @@ import ( // @@@SNIPSTART samples-go-child-workflow-example-worker-starter func main() { // The client is a heavyweight object that should be created only once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/choice-exclusive/starter/main.go b/choice-exclusive/starter/main.go index 5ed774cb..38d95a16 100644 --- a/choice-exclusive/starter/main.go +++ b/choice-exclusive/starter/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/choice-exclusive/worker/main.go b/choice-exclusive/worker/main.go index b0337ca4..62593a9f 100644 --- a/choice-exclusive/worker/main.go +++ b/choice-exclusive/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/choice-multi/starter/main.go b/choice-multi/starter/main.go index 50fe9195..ba4f12a2 100644 --- a/choice-multi/starter/main.go +++ b/choice-multi/starter/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/choice-multi/worker/main.go b/choice-multi/worker/main.go index 4e9d7096..05ed60b0 100644 --- a/choice-multi/worker/main.go +++ b/choice-multi/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/codec-server/starter/main.go b/codec-server/starter/main.go index 65d5f52c..d58fe6ce 100644 --- a/codec-server/starter/main.go +++ b/codec-server/starter/main.go @@ -10,7 +10,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ // Set DataConverter here to ensure that workflow inputs and results are // encoded as required. DataConverter: codecserver.DataConverter, diff --git a/codec-server/worker/main.go b/codec-server/worker/main.go index 6378c2d7..9ff17ff1 100644 --- a/codec-server/worker/main.go +++ b/codec-server/worker/main.go @@ -10,7 +10,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ // Set DataConverter here so that workflow and activity inputs/results will // be compressed as required. DataConverter: codecserver.DataConverter, diff --git a/cron/starter/main.go b/cron/starter/main.go index 3fd18ad2..05f4d445 100644 --- a/cron/starter/main.go +++ b/cron/starter/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/cron/worker/main.go b/cron/worker/main.go index 1d9b3d0c..24e5342d 100644 --- a/cron/worker/main.go +++ b/cron/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/ctxpropagation/starter/main.go b/ctxpropagation/starter/main.go index aea07df2..b2b07034 100644 --- a/ctxpropagation/starter/main.go +++ b/ctxpropagation/starter/main.go @@ -25,7 +25,7 @@ func main() { } // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, Interceptors: []interceptor.ClientInterceptor{tracingInterceptor}, ContextPropagators: []workflow.ContextPropagator{ctxpropagation.NewContextPropagator()}, diff --git a/ctxpropagation/worker/main.go b/ctxpropagation/worker/main.go index 9c760ef2..94cd4019 100644 --- a/ctxpropagation/worker/main.go +++ b/ctxpropagation/worker/main.go @@ -24,7 +24,7 @@ func main() { } // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, ContextPropagators: []workflow.ContextPropagator{ctxpropagation.NewContextPropagator()}, Interceptors: []interceptor.ClientInterceptor{tracingInterceptor}, diff --git a/dsl/starter/main.go b/dsl/starter/main.go index 6d0813b4..98476914 100644 --- a/dsl/starter/main.go +++ b/dsl/starter/main.go @@ -28,7 +28,7 @@ func main() { } // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/dsl/worker/main.go b/dsl/worker/main.go index d2631698..1629c8a3 100644 --- a/dsl/worker/main.go +++ b/dsl/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/dynamic/starter/main.go b/dynamic/starter/main.go index a609d791..83962fb7 100644 --- a/dynamic/starter/main.go +++ b/dynamic/starter/main.go @@ -10,7 +10,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/dynamic/worker/main.go b/dynamic/worker/main.go index fe3db573..9dde6978 100644 --- a/dynamic/worker/main.go +++ b/dynamic/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/encryption/starter/main.go b/encryption/starter/main.go index 03ff0c9a..071c8365 100644 --- a/encryption/starter/main.go +++ b/encryption/starter/main.go @@ -13,7 +13,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ // If you intend to use the same encryption key for all workflows you can // set the KeyID for the encryption encoder like so: // diff --git a/encryption/worker/main.go b/encryption/worker/main.go index d9ab3847..3af4b531 100644 --- a/encryption/worker/main.go +++ b/encryption/worker/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ // If you intend to use the same encryption key for all workflows you can // set the KeyID for the encryption encoder like so: // diff --git a/expense/server/main.go b/expense/server/main.go index dd345ebf..c343e710 100644 --- a/expense/server/main.go +++ b/expense/server/main.go @@ -32,7 +32,7 @@ var ( func main() { var err error // The client is a heavyweight object that should be created once per process. - workflowClient, err = client.NewClient(client.Options{ + workflowClient, err = client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/expense/starter/main.go b/expense/starter/main.go index dc00d427..263edf21 100644 --- a/expense/starter/main.go +++ b/expense/starter/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/expense/worker/main.go b/expense/worker/main.go index e588ed23..05ce1d3b 100644 --- a/expense/worker/main.go +++ b/expense/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/fileprocessing/starter/main.go b/fileprocessing/starter/main.go index ce432fe8..cccd8aed 100644 --- a/fileprocessing/starter/main.go +++ b/fileprocessing/starter/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/fileprocessing/worker/main.go b/fileprocessing/worker/main.go index 448eb5b5..946dc2b0 100644 --- a/fileprocessing/worker/main.go +++ b/fileprocessing/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/go.mod b/go.mod index 3949399d..60d5af4b 100644 --- a/go.mod +++ b/go.mod @@ -13,19 +13,19 @@ require ( github.com/opentracing/opentracing-go v1.2.0 github.com/pborman/uuid v1.2.1 github.com/prometheus/client_golang v1.12.1 - github.com/stretchr/testify v1.7.0 + github.com/stretchr/testify v1.7.1 github.com/uber-go/tally/v4 v4.1.1 github.com/uber/jaeger-client-go v2.29.1+incompatible github.com/uber/jaeger-lib v2.4.1+incompatible // indirect - go.temporal.io/api v1.7.1-0.20220223032354-6e6fe738916a - go.temporal.io/sdk v1.14.0 + go.temporal.io/api v1.8.0 + go.temporal.io/sdk v1.15.0 go.temporal.io/sdk/contrib/opentracing v0.1.0 go.temporal.io/sdk/contrib/tally v0.1.0 go.temporal.io/sdk/contrib/tools/workflowcheck v0.0.0-20220331154559-fd0d1eb548eb go.temporal.io/server v1.15.2 go.uber.org/zap v1.20.0 - google.golang.org/grpc v1.44.0 + google.golang.org/grpc v1.47.0 gopkg.in/check.v1 v1.0.0-20200902074654-038fdea0a05b // indirect gopkg.in/square/go-jose.v2 v2.6.0 - gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b + gopkg.in/yaml.v3 v3.0.1 ) diff --git a/go.sum b/go.sum index 55d646cb..a8af43f1 100644 --- a/go.sum +++ b/go.sum @@ -105,6 +105,7 @@ github.com/cncf/udpa/go v0.0.0-20210930031921-04548b0d99d4/go.mod h1:6pvJx4me5XP github.com/cncf/xds/go v0.0.0-20210312221358-fbca930ec8ed/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= github.com/cncf/xds/go v0.0.0-20210805033703-aa0b78936158/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= github.com/cncf/xds/go v0.0.0-20210922020428-25de7278fc84/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= +github.com/cncf/xds/go v0.0.0-20211001041855-01bcc9b48dfe/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= github.com/cncf/xds/go v0.0.0-20211011173535-cb28da3451f1/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= github.com/codahale/hdrhistogram v0.0.0-20161010025455-3a0bb77429bd/go.mod h1:sE/e/2PUdi/liOCUjSTXgM1o87ZssimdTWN964YiIeI= github.com/cpuguy83/go-md2man/v2 v2.0.0-20190314233015-f79a8a8ca69d/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU= @@ -125,6 +126,7 @@ github.com/envoyproxy/go-control-plane v0.9.9-0.20201210154907-fd9021fe5dad/go.m github.com/envoyproxy/go-control-plane v0.9.9-0.20210217033140-668b12f5399d/go.mod h1:cXg6YxExXjJnVBQHBLXeUAgxn2UodCpnH306RInaBQk= github.com/envoyproxy/go-control-plane v0.9.9-0.20210512163311-63b5d3c536b0/go.mod h1:hliV/p42l8fGbc6Y9bQ70uLwIvmJyVE5k4iMKlh8wCQ= github.com/envoyproxy/go-control-plane v0.9.10-0.20210907150352-cf90f659a021/go.mod h1:AFq3mo9L8Lqqiid3OhADV3RfLJnjiw63cSpi+fDTRC0= +github.com/envoyproxy/go-control-plane v0.10.2-0.20220325020618-49ff273808a1/go.mod h1:KJwIaB5Mv44NWtYuAOFCVOjcI94vtpEz2JU/D2v6IjE= github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c= github.com/facebookgo/clock v0.0.0-20150410010913-600d898af40a h1:yDWHCSQ40h88yih2JAcL6Ls/kVkSE8GFACTGVnMPruw= github.com/facebookgo/clock v0.0.0-20150410010913-600d898af40a/go.mod h1:7Ga40egUymuWXxAe151lTNnCv97MddSOVsjpPPkityA= @@ -406,8 +408,9 @@ github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UV github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4= github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA= github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= -github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY= github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= +github.com/stretchr/testify v1.7.1 h1:5TQK59W5E3v0r2duFAb7P95B6hEeOyEnHRa8MjYSMTY= +github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= github.com/temporalio/ringpop-go v0.0.0-20211012191444-6f91b5915e95/go.mod h1:Ek9J8CAfI1IwVSqHpTOgj7FjzRSJ5SM/ud52eCmkhsw= github.com/twmb/murmur3 v1.1.5/go.mod h1:Qq/R7NUyOfr65zD+6Q5IHKsJLwP7exErjN6lyyq3OSQ= github.com/twmb/murmur3 v1.1.6 h1:mqrRot1BRxm+Yct+vavLMou2/iJt0tNVTTC0QoIjaZg= @@ -462,12 +465,12 @@ go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqe go.temporal.io/api v1.5.0/go.mod h1:BqKxEJJYdxb5dqf0ODfzfMxh8UEQ5L3zKS51FiIYYkA= go.temporal.io/api v1.6.1-0.20211110205628-60c98e9cbfe2/go.mod h1:IlUgOTGfmJuOkGrCZdptNxyXKE9CQz6oOx7/aH9bFY4= go.temporal.io/api v1.7.1-0.20220131203817-08fe71b1361d/go.mod h1:RJ6blV8Zh4cdZvR48DzFuMHUCP8fV4lIIBLDPkLkMBk= -go.temporal.io/api v1.7.1-0.20220223032354-6e6fe738916a h1:SgkeoCikBXMd/3fNNtymIfhpxk8o/E3zIZFBFkHzTtU= -go.temporal.io/api v1.7.1-0.20220223032354-6e6fe738916a/go.mod h1:OnUq5eS+Nyx+irKb3Ws5YB7yjGFf5XmI3WcVRU9COEo= +go.temporal.io/api v1.8.0 h1:FzAMmBeLs6BEMFyHeJ9M9GAv6McFuH/GjnliBCdQ/Zw= +go.temporal.io/api v1.8.0/go.mod h1:7m1ZOVUFi/54a5IMzMeELnvDy5sJwRfz11zi3Jrww8w= go.temporal.io/sdk v1.12.0/go.mod h1:lSp3lH1lI0TyOsus0arnO3FYvjVXBZGi/G7DjnAnm6o= go.temporal.io/sdk v1.13.0/go.mod h1:TCof7U/xas2FyDnx/UUEv4c/O/S41Lnhva+6JVer+Jo= -go.temporal.io/sdk v1.14.0 h1:7tJO72gK4xmsZ8W3Xp1rwKYdkwQ/mgnKN5LmROyZTac= -go.temporal.io/sdk v1.14.0/go.mod h1:7rvvSS6oCXp19JSFQtSOhLxCX3wpEQSJZJlyCGleo9M= +go.temporal.io/sdk v1.15.0 h1:1ZJEBNqLHAN0H64NpD4pydriYF9qhUIaimSVONm3ZKs= +go.temporal.io/sdk v1.15.0/go.mod h1:peqnjALtNpJMKRplWEubefPhDXdAtRTnebsLSFypSts= go.temporal.io/sdk/contrib/opentracing v0.1.0 h1:z5F1EoZQ6v8bMH/pzcFRgzoPKZCB+exUKMYt0jzuWME= go.temporal.io/sdk/contrib/opentracing v0.1.0/go.mod h1:rQavYHnrTXlFKvKrn5R91eOLdvaJJ27gtxaKFqH3LuM= go.temporal.io/sdk/contrib/tally v0.1.0 h1:edAcGKNIDYU7fd10e4C/43dHw/h1F9cACupcmIKwzPI= @@ -552,8 +555,9 @@ golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= golang.org/x/mod v0.4.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= golang.org/x/mod v0.4.1/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= golang.org/x/mod v0.4.2/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= -golang.org/x/mod v0.5.1 h1:OJxoQ/rynoF0dcCdI7cLPktw/hR2cueqYfjm43oqK38= golang.org/x/mod v0.5.1/go.mod h1:5OXOZSfqPIIbmVBIIKWRFfZjPR0E5r58TLhUjH0a2Ro= +golang.org/x/mod v0.6.0-dev.0.20220106191415-9b9b3d81d5e3 h1:kQgndtyPBW/JIYERgdxfwMYh3AVStj88WQTlNDi2a+o= +golang.org/x/mod v0.6.0-dev.0.20220106191415-9b9b3d81d5e3/go.mod h1:3p9vT2HGsQu2K1YbXdKPJLVgG5VJdoTa1poYQBtP1AY= golang.org/x/net v0.0.0-20180530234432-1e491301e022/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= @@ -598,8 +602,9 @@ golang.org/x/net v0.0.0-20211015210444-4f30a5c0130f/go.mod h1:9nx3DQGgdP8bBQD5qx golang.org/x/net v0.0.0-20211109214657-ef0fda0de508/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= golang.org/x/net v0.0.0-20211209124913-491a49abca63/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= golang.org/x/net v0.0.0-20211216030914-fe4d6282115f/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= -golang.org/x/net v0.0.0-20220127200216-cd36cc0744dd h1:O7DYs+zxREGLKzKoMQrtrEacpb0ZVXA5rIwylE2Xchk= golang.org/x/net v0.0.0-20220127200216-cd36cc0744dd/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk= +golang.org/x/net v0.0.0-20220531201128-c960675eff93 h1:MYimHLfoXEpOhqd/zgoA/uoXzHB86AEky4LAx5ij9xA= +golang.org/x/net v0.0.0-20220531201128-c960675eff93/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c= golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= @@ -696,8 +701,8 @@ golang.org/x/sys v0.0.0-20211210111614-af8b64212486/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220114195835-da31bd327af9/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220128215802-99c3d69c2c27/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.0.0-20220222200937-f2425489ef4c h1:sSIdNI2Dd6vGv47bKc/xArpfxVmEz2+3j0E6I484xC4= -golang.org/x/sys v0.0.0-20220222200937-f2425489ef4c/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a h1:dGzPydgVsqGcTRVwiLJ1jVbufYwmzD3LfVPLKsKg+0k= +golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= golang.org/x/text v0.0.0-20170915032832-14c0d48ead0c/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= @@ -776,8 +781,9 @@ golang.org/x/tools v0.1.2/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk= golang.org/x/tools v0.1.3/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk= golang.org/x/tools v0.1.4/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk= golang.org/x/tools v0.1.5/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk= -golang.org/x/tools v0.1.8 h1:P1HhGGuLW4aAclzjtmJdf0mJOjVUZUzOTqkAkWL+l6w= golang.org/x/tools v0.1.8/go.mod h1:nABZi5QlRsZVlzPpHl034qft6wpY4eDcsTt5AaioBiU= +golang.org/x/tools v0.1.10 h1:QjFRCZxdOhBJ/UNgnBZLbNV13DlbnK0quyivTnXJM20= +golang.org/x/tools v0.1.10/go.mod h1:Uh6Zz+xoGYZom868N8YTex3t7RhtHDBrE8Gzo9bV56E= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= @@ -900,8 +906,8 @@ google.golang.org/genproto v0.0.0-20220114231437-d2e6a121cae0/go.mod h1:5CzLGKJ6 google.golang.org/genproto v0.0.0-20220118154757-00ab72f36ad5/go.mod h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc= google.golang.org/genproto v0.0.0-20220126215142-9970aeb2e350/go.mod h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc= google.golang.org/genproto v0.0.0-20220201184016-50beb8ab5c44/go.mod h1:5CzLGKJ67TSI2B9POpiiyGha0AjJvZIUgRMt1dSmuhc= -google.golang.org/genproto v0.0.0-20220222213610-43724f9ea8cf h1:SVYXkUz2yZS9FWb2Gm8ivSlbNQzL2Z/NpPKE3RG2jWk= -google.golang.org/genproto v0.0.0-20220222213610-43724f9ea8cf/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= +google.golang.org/genproto v0.0.0-20220602131408-e326c6e8e9c8 h1:qRu95HZ148xXw+XeZ3dvqe85PxH4X8+jIo0iRPKcEnM= +google.golang.org/genproto v0.0.0-20220602131408-e326c6e8e9c8/go.mod h1:yKyY4AMRwFiC8yMMNaMi+RkCnjZJt9LoWuvhXjMs+To= google.golang.org/grpc v1.8.0/go.mod h1:yo6s7OP7yaDglbqo1J04qKzAhqBH6lvTonzMVmEdcZw= google.golang.org/grpc v1.12.0/go.mod h1:yo6s7OP7yaDglbqo1J04qKzAhqBH6lvTonzMVmEdcZw= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= @@ -931,8 +937,10 @@ google.golang.org/grpc v1.39.1/go.mod h1:PImNr+rS9TWYb2O4/emRugxiyHZ5JyHW5F+RPnD google.golang.org/grpc v1.40.0/go.mod h1:ogyxbiOoUXAkP+4+xa6PZSE9DZgIHtSpzjDTB9KAK34= google.golang.org/grpc v1.40.1/go.mod h1:ogyxbiOoUXAkP+4+xa6PZSE9DZgIHtSpzjDTB9KAK34= google.golang.org/grpc v1.42.0/go.mod h1:k+4IHHFw41K8+bbowsex27ge2rCb65oeWqe4jJ590SU= -google.golang.org/grpc v1.44.0 h1:weqSxi/TMs1SqFRMHCtBgXRs8k3X39QIDEZ0pRcttUg= google.golang.org/grpc v1.44.0/go.mod h1:k+4IHHFw41K8+bbowsex27ge2rCb65oeWqe4jJ590SU= +google.golang.org/grpc v1.46.2/go.mod h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk= +google.golang.org/grpc v1.47.0 h1:9n77onPX5F3qfFCqjy9dhn8PbNQsIKeVU04J9G7umt8= +google.golang.org/grpc v1.47.0/go.mod h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk= google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.1.0/go.mod h1:6Kw0yEErY5E/yWrBtf03jp27GLLJujG4z/JK95pnjjw= google.golang.org/grpc/examples v0.0.0-20220201220150-c7f7d3a75c27/go.mod h1:gID3PKrg7pWKntu9Ss6zTLJ0ttC0X9IHgREOCZwbCVU= google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8= @@ -947,8 +955,9 @@ google.golang.org/protobuf v1.24.0/go.mod h1:r/3tXBNzIEhYS9I1OUVjXDlt8tc493IdKGj google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c= google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= -google.golang.org/protobuf v1.27.1 h1:SnqbnDw1V7RiZcXPx5MEeqPv2s79L9i7BJUlG/+RurQ= google.golang.org/protobuf v1.27.1/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= +google.golang.org/protobuf v1.28.0 h1:w43yiav+6bVFTBQFZX0r7ipe9JQ1QsbMgHwbBziscLw= +google.golang.org/protobuf v1.28.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I= gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= @@ -975,8 +984,9 @@ gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY= gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ= gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= -gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b h1:h8qDotaEPuJATrMmW04NCwg7v22aHH28wwpauUhK9Oo= gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= +gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= +gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= honnef.co/go/tools v0.0.0-20190418001031-e561f6794a2a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= diff --git a/greetings/starter/main.go b/greetings/starter/main.go index 74fb3992..b3105a7e 100644 --- a/greetings/starter/main.go +++ b/greetings/starter/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/greetings/worker/main.go b/greetings/worker/main.go index f2fd500f..2f644d96 100644 --- a/greetings/worker/main.go +++ b/greetings/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/greetingslocal/starter/main.go b/greetingslocal/starter/main.go index 4ada6cad..445652b6 100644 --- a/greetingslocal/starter/main.go +++ b/greetingslocal/starter/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/greetingslocal/worker/main.go b/greetingslocal/worker/main.go index 8426d062..5d035be1 100644 --- a/greetingslocal/worker/main.go +++ b/greetingslocal/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/grpc-proxy/starter/main.go b/grpc-proxy/starter/main.go index 8ebcf96d..a25b0f3d 100644 --- a/grpc-proxy/starter/main.go +++ b/grpc-proxy/starter/main.go @@ -10,7 +10,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: "localhost:8081", }) if err != nil { diff --git a/grpc-proxy/worker/main.go b/grpc-proxy/worker/main.go index c141a0b8..f81cce6f 100644 --- a/grpc-proxy/worker/main.go +++ b/grpc-proxy/worker/main.go @@ -10,7 +10,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: "localhost:8081", }) if err != nil { diff --git a/helloworld/starter/main.go b/helloworld/starter/main.go index 4bff0419..102978b3 100644 --- a/helloworld/starter/main.go +++ b/helloworld/starter/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{}) + c, err := client.Dial(client.Options{}) if err != nil { log.Fatalln("Unable to create client", err) } diff --git a/helloworld/worker/main.go b/helloworld/worker/main.go index 85af0982..7120424b 100644 --- a/helloworld/worker/main.go +++ b/helloworld/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{}) + c, err := client.Dial(client.Options{}) if err != nil { log.Fatalln("Unable to create client", err) } diff --git a/interceptor/starter/main.go b/interceptor/starter/main.go index 84721078..1e24ba07 100644 --- a/interceptor/starter/main.go +++ b/interceptor/starter/main.go @@ -10,7 +10,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{}) + c, err := client.Dial(client.Options{}) if err != nil { log.Fatalln("Unable to create client", err) } diff --git a/interceptor/worker/main.go b/interceptor/worker/main.go index 639d2b8c..cb1e7850 100644 --- a/interceptor/worker/main.go +++ b/interceptor/worker/main.go @@ -15,7 +15,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{}) + c, err := client.Dial(client.Options{}) if err != nil { log.Fatalln("Unable to create client", err) } diff --git a/metrics/starter/main.go b/metrics/starter/main.go index 792f3a69..a35c9c63 100644 --- a/metrics/starter/main.go +++ b/metrics/starter/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{}) + c, err := client.Dial(client.Options{}) if err != nil { log.Fatalln("Unable to create client.", err) } diff --git a/metrics/worker/main.go b/metrics/worker/main.go index c1dc254d..f20521c0 100644 --- a/metrics/worker/main.go +++ b/metrics/worker/main.go @@ -16,7 +16,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ MetricsHandler: sdktally.NewMetricsHandler(newPrometheusScope(prometheus.Configuration{ ListenAddress: "0.0.0.0:9090", TimerType: "histogram", diff --git a/mutex/starter/main.go b/mutex/starter/main.go index 1bb944b4..1712f619 100644 --- a/mutex/starter/main.go +++ b/mutex/starter/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/mutex/worker/main.go b/mutex/worker/main.go index fcaede2f..77ff3dfd 100644 --- a/mutex/worker/main.go +++ b/mutex/worker/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/parallel/starter/main.go b/parallel/starter/main.go index fac20da4..da836ec2 100644 --- a/parallel/starter/main.go +++ b/parallel/starter/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/parallel/worker/main.go b/parallel/worker/main.go index 6ff49a9f..26dd773b 100644 --- a/parallel/worker/main.go +++ b/parallel/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/pickfirst/starter/main.go b/pickfirst/starter/main.go index cc6813bd..1f9f5b42 100644 --- a/pickfirst/starter/main.go +++ b/pickfirst/starter/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/pickfirst/worker/main.go b/pickfirst/worker/main.go index 312900e8..3ab1bdb7 100644 --- a/pickfirst/worker/main.go +++ b/pickfirst/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/pso/query/main.go b/pso/query/main.go index 22b17020..02a4df7f 100644 --- a/pso/query/main.go +++ b/pso/query/main.go @@ -18,7 +18,7 @@ func main() { flag.Parse() // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, DataConverter: pso.NewJSONDataConverter(), }) diff --git a/pso/starter/main.go b/pso/starter/main.go index 4d03d7b2..538ed385 100644 --- a/pso/starter/main.go +++ b/pso/starter/main.go @@ -17,7 +17,7 @@ func main() { flag.Parse() // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, DataConverter: pso.NewJSONDataConverter(), }) diff --git a/pso/worker/main.go b/pso/worker/main.go index f5244e1e..9ac8c5f9 100644 --- a/pso/worker/main.go +++ b/pso/worker/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, DataConverter: pso.NewJSONDataConverter(), }) diff --git a/query/query/main.go b/query/query/main.go index aeccae36..c7d481b4 100644 --- a/query/query/main.go +++ b/query/query/main.go @@ -15,7 +15,7 @@ func main() { flag.Parse() // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/query/starter/main.go b/query/starter/main.go index b84d9305..9ee4c8a9 100644 --- a/query/starter/main.go +++ b/query/starter/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/query/worker/main.go b/query/worker/main.go index 7d0b7ba4..40cfc61d 100644 --- a/query/worker/main.go +++ b/query/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/recovery/query/main.go b/recovery/query/main.go index ad2d729f..caa5fc8a 100644 --- a/recovery/query/main.go +++ b/recovery/query/main.go @@ -16,7 +16,7 @@ func main() { flag.Parse() // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/recovery/signal/main.go b/recovery/signal/main.go index 68fe326f..1338fffb 100644 --- a/recovery/signal/main.go +++ b/recovery/signal/main.go @@ -18,7 +18,7 @@ func main() { flag.Parse() // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/recovery/starter/main.go b/recovery/starter/main.go index d97a97d3..2825dd39 100644 --- a/recovery/starter/main.go +++ b/recovery/starter/main.go @@ -20,7 +20,7 @@ func main() { flag.Parse() // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { @@ -48,8 +48,8 @@ func main() { } workflowOptions := client.StartWorkflowOptions{ - ID: workflowID, - TaskQueue: "recovery", + ID: workflowID, + TaskQueue: "recovery", WorkflowExecutionTimeout: 1 * time.Minute, } we, weError = c.ExecuteWorkflow(context.Background(), workflowOptions, recovery.RecoverWorkflow, params) diff --git a/recovery/worker/main.go b/recovery/worker/main.go index c5658d64..0909f43a 100644 --- a/recovery/worker/main.go +++ b/recovery/worker/main.go @@ -14,7 +14,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/reqrespactivity/request/main.go b/reqrespactivity/request/main.go index 4cbdc472..cc3c012a 100644 --- a/reqrespactivity/request/main.go +++ b/reqrespactivity/request/main.go @@ -20,7 +20,7 @@ func main() { // Create client var err error - opts.Client, err = client.NewClient(client.Options{ + opts.Client, err = client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/reqrespactivity/starter/main.go b/reqrespactivity/starter/main.go index 18a8d938..d61df4c0 100644 --- a/reqrespactivity/starter/main.go +++ b/reqrespactivity/starter/main.go @@ -9,7 +9,7 @@ import ( ) func main() { - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/reqrespactivity/worker/main.go b/reqrespactivity/worker/main.go index b2ba6562..d2ba145e 100644 --- a/reqrespactivity/worker/main.go +++ b/reqrespactivity/worker/main.go @@ -9,7 +9,7 @@ import ( ) func main() { - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/reqrespquery/request/main.go b/reqrespquery/request/main.go index c158a4d5..ea65a0dc 100644 --- a/reqrespquery/request/main.go +++ b/reqrespquery/request/main.go @@ -20,7 +20,7 @@ func main() { // Create client var err error - opts.Client, err = client.NewClient(client.Options{ + opts.Client, err = client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/reqrespquery/starter/main.go b/reqrespquery/starter/main.go index e30b1a38..9cab4b29 100644 --- a/reqrespquery/starter/main.go +++ b/reqrespquery/starter/main.go @@ -9,7 +9,7 @@ import ( ) func main() { - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/reqrespquery/worker/main.go b/reqrespquery/worker/main.go index 0129bfd7..3c1689f1 100644 --- a/reqrespquery/worker/main.go +++ b/reqrespquery/worker/main.go @@ -9,7 +9,7 @@ import ( ) func main() { - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/retryactivity/starter/main.go b/retryactivity/starter/main.go index ba87a352..99a664e3 100644 --- a/retryactivity/starter/main.go +++ b/retryactivity/starter/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/retryactivity/worker/main.go b/retryactivity/worker/main.go index ca0e722a..8ddca337 100644 --- a/retryactivity/worker/main.go +++ b/retryactivity/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/searchattributes/starter/main.go b/searchattributes/starter/main.go index 9c1e9020..b27d8da5 100644 --- a/searchattributes/starter/main.go +++ b/searchattributes/starter/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/searchattributes/worker/main.go b/searchattributes/worker/main.go index bbe051f6..4a3f6c3b 100644 --- a/searchattributes/worker/main.go +++ b/searchattributes/worker/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/serverjwtauth/starter/main.go b/serverjwtauth/starter/main.go index 5828df38..7d991434 100644 --- a/serverjwtauth/starter/main.go +++ b/serverjwtauth/starter/main.go @@ -16,7 +16,7 @@ func main() { log.Fatalln(err) } // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HeadersProvider: &serverjwtauth.JWTHeadersProvider{ Config: serverjwtauth.JWTConfig{ Key: key, diff --git a/serverjwtauth/worker/main.go b/serverjwtauth/worker/main.go index 23fb150e..f32329f3 100644 --- a/serverjwtauth/worker/main.go +++ b/serverjwtauth/worker/main.go @@ -16,7 +16,7 @@ func main() { log.Fatalln(err) } // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HeadersProvider: &serverjwtauth.JWTHeadersProvider{ Config: serverjwtauth.JWTConfig{ Key: key, diff --git a/snappycompress/starter/main.go b/snappycompress/starter/main.go index 55ee781a..1a88367e 100644 --- a/snappycompress/starter/main.go +++ b/snappycompress/starter/main.go @@ -10,7 +10,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ // Set DataConverter here to ensure that workflow inputs and results are // compressed as required. DataConverter: snappycompress.AlwaysCompressDataConverter, diff --git a/snappycompress/worker/main.go b/snappycompress/worker/main.go index 5996b8c3..bcf6d707 100644 --- a/snappycompress/worker/main.go +++ b/snappycompress/worker/main.go @@ -10,7 +10,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ // Set DataConverter here so that workflow and activity inputs/results will // be compressed as required. DataConverter: snappycompress.AlwaysCompressDataConverter, diff --git a/splitmerge/starter/main.go b/splitmerge/starter/main.go index 596e86c0..1e7b5fc3 100644 --- a/splitmerge/starter/main.go +++ b/splitmerge/starter/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/splitmerge/worker/main.go b/splitmerge/worker/main.go index e639aab5..dceb89e9 100644 --- a/splitmerge/worker/main.go +++ b/splitmerge/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/synchronous-proxy/ui/main.go b/synchronous-proxy/ui/main.go index 5ae490bb..bf9a8f15 100644 --- a/synchronous-proxy/ui/main.go +++ b/synchronous-proxy/ui/main.go @@ -13,7 +13,7 @@ import ( ) func main() { - c, err := client.NewClient(client.Options{}) + c, err := client.Dial(client.Options{}) if err != nil { log.Fatalln("Unable to create client", err) } diff --git a/synchronous-proxy/worker/main.go b/synchronous-proxy/worker/main.go index 4b4618d6..d319e6af 100644 --- a/synchronous-proxy/worker/main.go +++ b/synchronous-proxy/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{}) + c, err := client.Dial(client.Options{}) if err != nil { log.Fatalln("Unable to create client", err) } diff --git a/temporal-fixtures/large-event-history/starter/main.go b/temporal-fixtures/large-event-history/starter/main.go index d57effc9..edcf3285 100644 --- a/temporal-fixtures/large-event-history/starter/main.go +++ b/temporal-fixtures/large-event-history/starter/main.go @@ -16,7 +16,7 @@ var ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/temporal-fixtures/large-event-history/worker/main.go b/temporal-fixtures/large-event-history/worker/main.go index f2d48cd7..5b679b65 100644 --- a/temporal-fixtures/large-event-history/worker/main.go +++ b/temporal-fixtures/large-event-history/worker/main.go @@ -10,7 +10,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/temporal-fixtures/largepayload/starter/main.go b/temporal-fixtures/largepayload/starter/main.go index 38c35035..200b7713 100644 --- a/temporal-fixtures/largepayload/starter/main.go +++ b/temporal-fixtures/largepayload/starter/main.go @@ -18,7 +18,7 @@ var ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/temporal-fixtures/largepayload/worker/main.go b/temporal-fixtures/largepayload/worker/main.go index e224e0e1..1e805495 100644 --- a/temporal-fixtures/largepayload/worker/main.go +++ b/temporal-fixtures/largepayload/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/temporal-fixtures/openNclosed/starter/main.go b/temporal-fixtures/openNclosed/starter/main.go index a9158dd4..41421ade 100644 --- a/temporal-fixtures/openNclosed/starter/main.go +++ b/temporal-fixtures/openNclosed/starter/main.go @@ -20,7 +20,7 @@ var ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{Namespace: "default"}) + c, err := client.Dial(client.Options{Namespace: "default"}) if err != nil { log.Fatalln("Unable to create client", err) } diff --git a/temporal-fixtures/openNclosed/worker/main.go b/temporal-fixtures/openNclosed/worker/main.go index edf97b13..8c7a59d7 100644 --- a/temporal-fixtures/openNclosed/worker/main.go +++ b/temporal-fixtures/openNclosed/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/temporal-fixtures/rainbow-statuses/rainbowstatusesworkflow.json b/temporal-fixtures/rainbow-statuses/rainbowstatusesworkflow.json index ec0b9fe5..6620b15b 100644 --- a/temporal-fixtures/rainbow-statuses/rainbowstatusesworkflow.json +++ b/temporal-fixtures/rainbow-statuses/rainbowstatusesworkflow.json @@ -138,7 +138,6 @@ "activityTaskScheduledEventAttributes": { "activityId": "6", "activityType": { "name": "LongActivity" }, - "namespace": "", "taskQueue": { "name": "rainbow-statuses", "kind": "Normal" }, "header": { "fields": {} }, "scheduleToCloseTimeout": "0s", diff --git a/temporal-fixtures/rainbow-statuses/starter/main.go b/temporal-fixtures/rainbow-statuses/starter/main.go index c666d759..b706d9fc 100644 --- a/temporal-fixtures/rainbow-statuses/starter/main.go +++ b/temporal-fixtures/rainbow-statuses/starter/main.go @@ -19,7 +19,7 @@ var ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{Namespace: "default"}) + c, err := client.Dial(client.Options{Namespace: "default"}) if err != nil { log.Fatalln("Unable to create client", err) } diff --git a/temporal-fixtures/rainbow-statuses/worker/main.go b/temporal-fixtures/rainbow-statuses/worker/main.go index 8187fac0..56a4aab5 100644 --- a/temporal-fixtures/rainbow-statuses/worker/main.go +++ b/temporal-fixtures/rainbow-statuses/worker/main.go @@ -10,7 +10,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/temporal-fixtures/stuck-workflows/starter/main.go b/temporal-fixtures/stuck-workflows/starter/main.go index 13cf5d08..c4e77cd5 100644 --- a/temporal-fixtures/stuck-workflows/starter/main.go +++ b/temporal-fixtures/stuck-workflows/starter/main.go @@ -12,7 +12,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/temporal-fixtures/stuck-workflows/worker/main.go b/temporal-fixtures/stuck-workflows/worker/main.go index 615c68e9..29fa537a 100644 --- a/temporal-fixtures/stuck-workflows/worker/main.go +++ b/temporal-fixtures/stuck-workflows/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/timer/starter/main.go b/timer/starter/main.go index 9c26f31d..728b6762 100644 --- a/timer/starter/main.go +++ b/timer/starter/main.go @@ -13,7 +13,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/timer/worker/main.go b/timer/worker/main.go index 9ea87a71..e7cd4b5b 100644 --- a/timer/worker/main.go +++ b/timer/worker/main.go @@ -11,7 +11,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/updatabletimer/starter/main.go b/updatabletimer/starter/main.go index aabba3ea..02e5ec46 100644 --- a/updatabletimer/starter/main.go +++ b/updatabletimer/starter/main.go @@ -11,7 +11,7 @@ import ( // Starts updatable timer workflow with initial wake-up time in 30 seconds. func main() { - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/updatabletimer/updater/main.go b/updatabletimer/updater/main.go index 729c4a6b..1e0b178b 100644 --- a/updatabletimer/updater/main.go +++ b/updatabletimer/updater/main.go @@ -12,7 +12,7 @@ import ( // Signals updatable timer workflow to change wake-up time to 20 seconds from now. func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/updatabletimer/worker/main.go b/updatabletimer/worker/main.go index 73eaa421..e03d1e1e 100644 --- a/updatabletimer/worker/main.go +++ b/updatabletimer/worker/main.go @@ -10,7 +10,7 @@ import ( func main() { // The client and worker are heavyweight objects that should be created once per process. - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ HostPort: client.DefaultHostPort, }) if err != nil { diff --git a/zapadapter/starter/main.go b/zapadapter/starter/main.go index d36c1c5a..0fefd6c1 100644 --- a/zapadapter/starter/main.go +++ b/zapadapter/starter/main.go @@ -10,7 +10,7 @@ import ( func main() { // The client is a heavyweight object that should be created once per process. - c, err := client.NewClient(client.Options{}) + c, err := client.Dial(client.Options{}) if err != nil { log.Fatalln("Unable to create client", err) } diff --git a/zapadapter/worker/main.go b/zapadapter/worker/main.go index da8e64d9..d0ecd2ab 100644 --- a/zapadapter/worker/main.go +++ b/zapadapter/worker/main.go @@ -11,7 +11,7 @@ import ( ) func main() { - c, err := client.NewClient(client.Options{ + c, err := client.Dial(client.Options{ // ZapAdapter implements log.Logger interface and can be passed // to the client constructor using client using client.Options. Logger: zapadapter.NewZapAdapter(